co.cask.cdap.etl.mock.transform

Class FilterErrorTransform

java.lang.Object

co.cask.cdap.etl.api.Transform<ErrorRecord<IN>,OUT>

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

co.cask.cdap.etl.mock.transform.FilterErrorTransform

All Implemented Interfaces:

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

public class FilterErrorTransform
extends ErrorTransform<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Filters out errors that have a specific error code

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
static PluginClass	PLUGIN_CLASS

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

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
FilterErrorTransform()

Method Summary

Modifier and Type	Method and Description
void	configurePipeline(PipelineConfigurer pipelineConfigurer)
static ETLPlugin	getPlugin(int code)
void	transform(ErrorRecord<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

PLUGIN_CLASS

public static final PluginClass PLUGIN_CLASS

Constructor Detail

FilterErrorTransform

public FilterErrorTransform()

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)
                       throws IllegalArgumentException

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

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

Throws:

IllegalArgumentException

transform

public void transform(ErrorRecord<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(int code)