public abstract class ChainedDriver<IT,OT> extends Object implements Collector<IT>
Modifier and Type | Field and Description |
---|---|
protected TaskConfig |
config |
protected ExecutionConfig |
executionConfig |
protected boolean |
objectReuseEnabled |
protected Collector<OT> |
outputCollector |
protected String |
taskName |
protected ClassLoader |
userCodeClassLoader |
Constructor and Description |
---|
ChainedDriver() |
Modifier and Type | Method and Description |
---|---|
abstract void |
cancelTask() |
abstract void |
closeTask() |
abstract void |
collect(IT record)
Emits a record.
|
Collector<OT> |
getOutputCollector() |
abstract Function |
getStub() |
TaskConfig |
getTaskConfig() |
abstract String |
getTaskName() |
protected RuntimeContext |
getUdfRuntimeContext() |
abstract void |
openTask() |
void |
setOutputCollector(Collector<?> outputCollector) |
abstract void |
setup(AbstractInvokable parent) |
void |
setup(TaskConfig config,
String taskName,
Collector<OT> outputCollector,
AbstractInvokable parent,
ClassLoader userCodeClassLoader,
ExecutionConfig executionConfig,
Map<String,Accumulator<?,?>> accumulatorMap) |
protected TaskConfig config
protected String taskName
protected ClassLoader userCodeClassLoader
protected ExecutionConfig executionConfig
protected boolean objectReuseEnabled
public void setup(TaskConfig config, String taskName, Collector<OT> outputCollector, AbstractInvokable parent, ClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulatorMap)
public abstract void setup(AbstractInvokable parent)
public abstract void cancelTask()
public abstract Function getStub()
public abstract String getTaskName()
public abstract void collect(IT record)
Collector
protected RuntimeContext getUdfRuntimeContext()
public void setOutputCollector(Collector<?> outputCollector)
public TaskConfig getTaskConfig()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.