co.cask.cdap.etl.mock.batch.aggregator

Class IdentityAggregator

java.lang.Object

co.cask.cdap.etl.api.batch.BatchConfigurable<BatchAggregatorContext>

co.cask.cdap.etl.api.batch.BatchAggregator<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

co.cask.cdap.etl.mock.batch.aggregator.IdentityAggregator

All Implemented Interfaces:

Aggregator<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>, Destroyable, PipelineConfigurable, StageLifecycle<BatchRuntimeContext>, SubmitterLifecycle<BatchAggregatorContext>

public class IdentityAggregator
extends BatchAggregator<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Identity aggregation for testing.

Field Summary

Fields

Modifier and Type	Field and Description
static PluginClass	PLUGIN_CLASS

Fields inherited from class co.cask.cdap.etl.api.batch.BatchAggregator

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
IdentityAggregator()

Method Summary

Modifier and Type	Method and Description
void	aggregate(co.cask.cdap.api.data.format.StructuredRecord structuredRecord, Iterator<co.cask.cdap.api.data.format.StructuredRecord> groupValues, Emitter<co.cask.cdap.api.data.format.StructuredRecord> emitter)
void	configurePipeline(PipelineConfigurer pipelineConfigurer)
static ETLPlugin	getPlugin()
void	groupBy(co.cask.cdap.api.data.format.StructuredRecord input, Emitter<co.cask.cdap.api.data.format.StructuredRecord> emitter)

Methods inherited from class co.cask.cdap.etl.api.batch.BatchAggregator

destroy, initialize, prepareRun

Methods inherited from class co.cask.cdap.etl.api.batch.BatchConfigurable

onRunFinish

Methods inherited from class java.lang.Object

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

Field Detail

PLUGIN_CLASS

public static final PluginClass PLUGIN_CLASS

Constructor Detail

IdentityAggregator

public IdentityAggregator()

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)
                       throws IllegalArgumentException

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

configurePipeline in class BatchAggregator<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Throws:

IllegalArgumentException

groupBy

public void groupBy(co.cask.cdap.api.data.format.StructuredRecord input,
                    Emitter<co.cask.cdap.api.data.format.StructuredRecord> emitter)
             throws Exception

Throws:

Exception

aggregate

public void aggregate(co.cask.cdap.api.data.format.StructuredRecord structuredRecord,
                      Iterator<co.cask.cdap.api.data.format.StructuredRecord> groupValues,
                      Emitter<co.cask.cdap.api.data.format.StructuredRecord> emitter)
               throws Exception

Throws:

Exception

getPlugin

public static ETLPlugin getPlugin()