co.cask.cdap.etl.mock.transform

Class StringValueFilterTransform

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.transform.StringValueFilterTransform

All Implemented Interfaces:

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

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

Transform that filters out records whose configured field is a configured value. For example, can filter all records whose 'foo' field is equal to 'bar'. Assumes the field is of type string.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StringValueFilterTransform.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.Transform

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
StringValueFilterTransform(StringValueFilterTransform.Config config)

Method Summary

Methods

Modifier and Type	Method and Description
static ETLPlugin	getPlugin(String field, String value)
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

configurePipeline, destroy, getContext, 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

StringValueFilterTransform

public StringValueFilterTransform(StringValueFilterTransform.Config config)

Method Detail

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,
                  String value)