org.apache.flink.runtime.operators.chaining

Class GroupCombineChainedDriver<IN,OUT>

java.lang.Object

org.apache.flink.runtime.operators.chaining.ChainedDriver<IN,OUT>

org.apache.flink.runtime.operators.chaining.GroupCombineChainedDriver<IN,OUT>

Type Parameters:

IN - The data type consumed

OUT - The data type produced

All Implemented Interfaces:

Collector<IN>

public class GroupCombineChainedDriver<IN,OUT>
extends ChainedDriver<IN,OUT>

Chained variant of the GroupReduceCombineDriver Acts like a combiner with a custom output type OUT. Sorting and reducing of the elements is performed individually for each partition without data exchange. This may lead to a partial group reduce.

Field Summary

Fields inherited from class org.apache.flink.runtime.operators.chaining.ChainedDriver

config, executionConfig, metrics, numRecordsIn, numRecordsOut, objectReuseEnabled, outputCollector, taskName, userCodeClassLoader

Constructor Summary

Constructors

Constructor and Description
GroupCombineChainedDriver()

Method Summary

Modifier and Type	Method and Description
void	cancelTask()
void	close() Closes the collector.
void	closeTask()
void	collect(IN record) Emits a record.
Function	getStub()
String	getTaskName()
void	openTask()
void	setup(AbstractInvokable parent)

Methods inherited from class org.apache.flink.runtime.operators.chaining.ChainedDriver

getIOMetrics, getOutputCollector, getTaskConfig, getUdfRuntimeContext, setOutputCollector, setup

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupCombineChainedDriver

public GroupCombineChainedDriver()

Method Detail

setup

public void setup(AbstractInvokable parent)

Specified by:

setup in class ChainedDriver<IN,OUT>

openTask

public void openTask()
              throws Exception

Specified by:

openTask in class ChainedDriver<IN,OUT>

Throws:

Exception

closeTask

public void closeTask()
               throws Exception

Specified by:

closeTask in class ChainedDriver<IN,OUT>

Throws:

Exception

cancelTask

public void cancelTask()

Specified by:

cancelTask in class ChainedDriver<IN,OUT>

getStub

public Function getStub()

Specified by:

getStub in class ChainedDriver<IN,OUT>

getTaskName

public String getTaskName()

Specified by:

getTaskName in class ChainedDriver<IN,OUT>

collect

public void collect(IN record)

Description copied from interface: Collector

Emits a record.

Specified by:

collect in interface Collector<IN>

Specified by:

collect in class ChainedDriver<IN,OUT>

Parameters:

record - The record to collect.

close

public void close()

Description copied from interface: Collector

Closes the collector. If any data was buffered, that data will be flushed.