Package | Description |
---|---|
org.apache.hadoop.hive.ql.optimizer | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.parse.spark |
Modifier and Type | Method and Description |
---|---|
DependencyCollectionTask |
GenMRProcContext.getDependencyTaskForMultiInsert()
Returns dependencyTaskForMultiInsert initializing it if necessary.
|
Modifier and Type | Method and Description |
---|---|
static void |
GenMapRedUtils.addDependentMoveTasks(Task<MoveWork> mvTask,
HiveConf hconf,
Task<? extends Serializable> parentTask,
DependencyCollectionTask dependencyTask)
Adds the dependencyTaskForMultiInsert in ctx as a dependent of parentTask.
|
static org.apache.hadoop.fs.Path |
GenMapRedUtils.createMoveTask(Task<? extends Serializable> currTask,
boolean chDir,
FileSinkOperator fsOp,
ParseContext parseCtx,
List<Task<MoveWork>> mvTasks,
HiveConf hconf,
DependencyCollectionTask dependencyTask)
Create and add any dependent move tasks
|
static void |
GenMapRedUtils.createMRWorkForMergingFiles(FileSinkOperator fsInput,
org.apache.hadoop.fs.Path finalName,
DependencyCollectionTask dependencyTask,
List<Task<MoveWork>> mvTasks,
HiveConf conf,
Task<? extends Serializable> currTask,
LineageState lineageState) |
Modifier and Type | Field and Description |
---|---|
DependencyCollectionTask |
GenTezProcContext.dependencyTask |
Modifier and Type | Field and Description |
---|---|
DependencyCollectionTask |
GenSparkProcContext.dependencyTask |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.fs.Path |
GenSparkUtils.createMoveTask(Task<? extends Serializable> currTask,
boolean chDir,
FileSinkOperator fsOp,
ParseContext parseCtx,
List<Task<MoveWork>> mvTasks,
HiveConf hconf,
DependencyCollectionTask dependencyTask)
Create and add any dependent move tasks.
|
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.