co.cask.cdap.etl.mock.alert

Class NullAlertTransform

java.lang.Object

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

co.cask.cdap.etl.mock.alert.NullAlertTransform

All Implemented Interfaces:

Destroyable, PipelineConfigurable, StageLifecycle<TransformContext>, SubmitterLifecycle<StageSubmitterContext>, Transformation<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

public class NullAlertTransform
extends Transform<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Checks if a particular field is null, emitting that record as an alert if so. Otherwise passes records on exactly as they came in.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NullAlertTransform.Conf Config for plugin

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME
static PluginClass	PLUGIN_CLASS

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

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
NullAlertTransform(NullAlertTransform.Conf conf)

Method Summary

Modifier and Type	Method and Description
void	configurePipeline(PipelineConfigurer pipelineConfigurer)
static ETLPlugin	getPlugin(String field)
void	transform(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.Transform

destroy, getContext, initialize, onRunFinish, prepareRun

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

PLUGIN_CLASS

public static final PluginClass PLUGIN_CLASS

Constructor Detail

NullAlertTransform

public NullAlertTransform(NullAlertTransform.Conf conf)

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

configurePipeline in class Transform<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,
                      Emitter<co.cask.cdap.api.data.format.StructuredRecord> emitter)
               throws Exception

Throws:

Exception

getPlugin

public static ETLPlugin getPlugin(String field)