co.cask.cdap.etl.mock.transform

Class NullFieldSplitterTransform

java.lang.Object

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

co.cask.cdap.etl.mock.transform.NullFieldSplitterTransform

All Implemented Interfaces:

Destroyable, MultiOutputPipelineConfigurable, MultiOutputTransformation<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>, StageLifecycle<TransformContext>

public class NullFieldSplitterTransform
extends SplitterTransform<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Splitter transform that sends all records that have a null value for a configurable field to one output port and all other records to another port.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NullFieldSplitterTransform.Config Config for the transform.

Field Summary

Fields

Modifier and Type	Field and Description
static PluginClass	PLUGIN_CLASS

Fields inherited from class co.cask.cdap.etl.api.SplitterTransform

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
NullFieldSplitterTransform(NullFieldSplitterTransform.Config config)

Method Summary

Modifier and Type	Method and Description
void	configurePipeline(MultiOutputPipelineConfigurer multiOutputPipelineConfigurer)
static ETLPlugin	getPlugin(String field)
void	transform(co.cask.cdap.api.data.format.StructuredRecord input, MultiOutputEmitter<co.cask.cdap.api.data.format.StructuredRecord> emitter)

Methods inherited from class co.cask.cdap.etl.api.SplitterTransform

destroy, initialize

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

NullFieldSplitterTransform

public NullFieldSplitterTransform(NullFieldSplitterTransform.Config config)

Method Detail

configurePipeline

public void configurePipeline(MultiOutputPipelineConfigurer multiOutputPipelineConfigurer)

Specified by:

configurePipeline in interface MultiOutputPipelineConfigurable

Overrides:

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

transform

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

Throws:

Exception

getPlugin

public static ETLPlugin getPlugin(String field)