Package | Description |
---|---|
org.apache.flink.runtime.operators | |
org.apache.flink.runtime.operators.chaining | |
org.apache.flink.runtime.operators.util |
Modifier and Type | Class and Description |
---|---|
class |
NoOpChainedDriver<IT>
A chained driver that just passes on the input as the output
|
Modifier and Type | Field and Description |
---|---|
protected ArrayList<ChainedDriver<?,?>> |
BatchTask.chainedTasks
A list of chained drivers, if there are any.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends ChainedDriver<?,?>> |
DriverStrategy.getPushChainDriverClass() |
Modifier and Type | Method and Description |
---|---|
static void |
BatchTask.cancelChainedTasks(List<ChainedDriver<?,?>> tasks)
Cancels all tasks via their
cancelTask() method. |
static void |
BatchTask.closeChainedTasks(List<ChainedDriver<?,?>> tasks,
AbstractInvokable parent)
Closes all chained tasks, in the order as they are stored in the array.
|
static <T> Collector<T> |
BatchTask.initOutputs(AbstractInvokable containingTask,
UserCodeClassLoader cl,
TaskConfig config,
List<ChainedDriver<?,?>> chainedTasksTarget,
List<RecordWriter<?>> eventualOutputs,
ExecutionConfig executionConfig,
Map<String,Accumulator<?,?>> accumulatorMap)
Creates a writer for each output.
|
static void |
BatchTask.openChainedTasks(List<ChainedDriver<?,?>> tasks,
AbstractInvokable parent)
Opens all chained tasks, in the order as they are stored in the array.
|
Modifier and Type | Class and Description |
---|---|
class |
ChainedAllReduceDriver<IT> |
class |
ChainedFlatMapDriver<IT,OT> |
class |
ChainedMapDriver<IT,OT> |
class |
ChainedReduceCombineDriver<T>
Chained version of ReduceCombineDriver.
|
class |
SynchronousChainedCombineDriver<IN,OUT>
The chained variant of the combine driver which is also implemented in GroupReduceCombineDriver.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends ChainedDriver<?,?>> |
TaskConfig.getChainedTask(int chainPos) |
Modifier and Type | Method and Description |
---|---|
void |
TaskConfig.addChainedTask(Class<? extends ChainedDriver> chainedTaskClass,
TaskConfig conf,
String taskName) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.