ChainedReduceCombineDriver (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.operators.chaining.ChainedDriver<T,T>
- - org.apache.flink.runtime.operators.chaining.ChainedReduceCombineDriver<T>

All Implemented Interfaces:

Collector<T>
```
public class ChainedReduceCombineDriver<T>
extends ChainedDriver<T,T>
```
Chained version of ReduceCombineDriver.

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 Description

ChainedReduceCombineDriver()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cancelTask()`
`void`	`close()`	Closes the collector.
`void`	`closeTask()`
`void`	`collect(T 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
  - ChainedReduceCombineDriver
```
public ChainedReduceCombineDriver()
```
- Method Detail
  - getStub
```
public Function getStub()
```
    Specified by:
    
    getStub in class ChainedDriver<T,T>
  - getTaskName
```
public String getTaskName()
```
    Specified by:
    
    getTaskName in class ChainedDriver<T,T>
  - setup
```
public void setup(AbstractInvokable parent)
```
    Specified by:
    
    setup in class ChainedDriver<T,T>
  - openTask
```
public void openTask()
              throws Exception
```
    Specified by:
    
    openTask in class ChainedDriver<T,T>
    
    Throws:
    
    Exception
  - collect
```
public void collect(T record)
```
    Description copied from interface: Collector
    
    Emits a record.
    
    Specified by:
    
    collect in interface Collector<T>
    
    Specified by:
    
    collect in class ChainedDriver<T,T>
    
    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.
  - closeTask
```
public void closeTask()
               throws Exception
```
    Specified by:
    
    closeTask in class ChainedDriver<T,T>
    
    Throws:
    
    Exception
  - cancelTask
```
public void cancelTask()
```
    Specified by:
    
    cancelTask in class ChainedDriver<T,T>