Package | Description |
---|---|
org.datavec.api.transform.join | |
org.datavec.local.transforms | |
org.datavec.local.transforms.join | |
org.datavec.spark.transform | |
org.datavec.spark.transform.join |
Modifier and Type | Method and Description |
---|---|
Join |
Join.Builder.build() |
Modifier and Type | Method and Description |
---|---|
static List<List<Writable>> |
LocalTransformExecutor.executeJoin(Join join,
List<List<Writable>> left,
List<List<Writable>> right)
Execute a join on the specified data
|
Constructor and Description |
---|
ExecuteJoinFromCoGroupFlatMapFunction(Join join) |
ExecuteJoinFromCoGroupFlatMapFunctionAdapter(Join join) |
Modifier and Type | Method and Description |
---|---|
static org.apache.spark.api.java.JavaRDD<List<Writable>> |
SparkTransformExecutor.executeJoin(Join join,
org.apache.spark.api.java.JavaRDD<List<Writable>> left,
org.apache.spark.api.java.JavaRDD<List<Writable>> right)
Execute a join on the specified data
|
Constructor and Description |
---|
ExecuteJoinFromCoGroupFlatMapFunction(Join join) |
Copyright © 2020. All rights reserved.