public class ChainedAllReduceDriver<IT> extends ChainedDriver<IT,IT>
config, executionConfig, metrics, numRecordsIn, numRecordsOut, objectReuseEnabled, outputCollector, taskName, userCodeClassLoader
Constructor and Description |
---|
ChainedAllReduceDriver() |
Modifier and Type | Method and Description |
---|---|
void |
cancelTask() |
void |
close()
Closes the collector.
|
void |
closeTask() |
void |
collect(IT record)
Emits a record.
|
Function |
getStub() |
String |
getTaskName() |
void |
openTask() |
void |
setup(AbstractInvokable parent) |
getIOMetrics, getOutputCollector, getTaskConfig, getUdfRuntimeContext, setOutputCollector, setup
public void setup(AbstractInvokable parent)
setup
in class ChainedDriver<IT,IT>
public void openTask() throws Exception
openTask
in class ChainedDriver<IT,IT>
Exception
public void closeTask() throws Exception
closeTask
in class ChainedDriver<IT,IT>
Exception
public void cancelTask()
cancelTask
in class ChainedDriver<IT,IT>
public Function getStub()
getStub
in class ChainedDriver<IT,IT>
public String getTaskName()
getTaskName
in class ChainedDriver<IT,IT>
public void close()
Collector
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.