org.apache.flink.runtime.operators.chaining

Class ChainedDriver<IT,OT>

java.lang.Object

org.apache.flink.runtime.operators.chaining.ChainedDriver<IT,OT>

All Implemented Interfaces:

org.apache.flink.util.Collector<IT>

Direct Known Subclasses:

ChainedAllReduceDriver, ChainedCollectorMapDriver, ChainedFlatMapDriver, ChainedMapDriver, ChainedTerminationCriterionDriver, GroupCombineChainedDriver, SynchronousChainedCombineDriver

public abstract class ChainedDriver<IT,OT>
extends Object
implements org.apache.flink.util.Collector<IT>

The interface to be implemented by drivers that do not run in an own pact task context, but are chained to other tasks.

Field Summary

Fields

Modifier and Type	Field and Description
protected TaskConfig	config
protected org.apache.flink.api.common.ExecutionConfig	executionConfig
protected boolean	objectReuseEnabled
protected org.apache.flink.util.Collector<OT>	outputCollector
protected String	taskName
protected ClassLoader	userCodeClassLoader

Constructor Summary

Constructors

Constructor and Description
ChainedDriver()

Method Summary

Modifier and Type	Method and Description
abstract void	cancelTask()
abstract void	closeTask()
abstract void	collect(IT record)
org.apache.flink.util.Collector<OT>	getOutputCollector()
abstract org.apache.flink.api.common.functions.Function	getStub()
TaskConfig	getTaskConfig()
abstract String	getTaskName()
protected org.apache.flink.api.common.functions.RuntimeContext	getUdfRuntimeContext()
abstract void	openTask()
void	setOutputCollector(org.apache.flink.util.Collector<?> outputCollector)
abstract void	setup(AbstractInvokable parent)
void	setup(TaskConfig config, String taskName, org.apache.flink.util.Collector<OT> outputCollector, AbstractInvokable parent, ClassLoader userCodeClassLoader, org.apache.flink.api.common.ExecutionConfig executionConfig)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.util.Collector

close

Field Detail

config

protected TaskConfig config

taskName

protected String taskName

outputCollector

protected org.apache.flink.util.Collector<OT> outputCollector

userCodeClassLoader

protected ClassLoader userCodeClassLoader

executionConfig

protected org.apache.flink.api.common.ExecutionConfig executionConfig

objectReuseEnabled

protected boolean objectReuseEnabled

Constructor Detail

ChainedDriver

public ChainedDriver()

Method Detail

setup

public void setup(TaskConfig config,
                  String taskName,
                  org.apache.flink.util.Collector<OT> outputCollector,
                  AbstractInvokable parent,
                  ClassLoader userCodeClassLoader,
                  org.apache.flink.api.common.ExecutionConfig executionConfig)

setup

public abstract void setup(AbstractInvokable parent)

openTask

public abstract void openTask()
                       throws Exception

Throws:

Exception

closeTask

public abstract void closeTask()
                        throws Exception

Throws:

Exception

cancelTask

public abstract void cancelTask()

getStub

public abstract org.apache.flink.api.common.functions.Function getStub()

getTaskName

public abstract String getTaskName()

collect

public abstract void collect(IT record)

Specified by:

collect in interface org.apache.flink.util.Collector<IT>

getUdfRuntimeContext

protected org.apache.flink.api.common.functions.RuntimeContext getUdfRuntimeContext()

setOutputCollector

public void setOutputCollector(org.apache.flink.util.Collector<?> outputCollector)

getOutputCollector

public org.apache.flink.util.Collector<OT> getOutputCollector()

getTaskConfig

public TaskConfig getTaskConfig()