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

Class GroupFilterAggregator

java.lang.Object

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

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

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

All Implemented Interfaces:

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

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

Aggregator that emits errors for all records that have a specific group key.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GroupFilterAggregator.Config The plugin config

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
GroupFilterAggregator()

Method Summary

Methods

Modifier and Type	Method and Description
void	aggregate(String groupKey, 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(String field, String val)
void	groupBy(co.cask.cdap.api.data.format.StructuredRecord input, Emitter<String> 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

GroupFilterAggregator

public GroupFilterAggregator()

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)
                       throws IllegalArgumentException

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

configurePipeline in class BatchAggregator<String,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<String> emitter)
             throws Exception

Throws:

Exception

aggregate

public void aggregate(String groupKey,
             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(String field,
                  String val)