Package co.cask.cdap.etl.mock.transform

Class Summary

Class	Description
AllErrorTransform	Transform used to test error emission.
DoubleTransform	Transform that doubles every record it receives.
DropNullTransform	Transform that drops a configurable field from all input records if it has a null value.
DropNullTransform.Config	Config for the transform.
ExceptionTransform	An transform that throws exception if expected condition is not met.
FieldsPrefixTransform	Transform which adds prefix to all the fields of structured record for testing multi input schemas
FieldsPrefixTransform.Config	Config for join plugin
FilterErrorTransform	Filters out errors that have a specific error code
FilterErrorTransform.Config	Config for the error transform.
FlattenErrorTransform	Adds the error code and error message to each record, then emits it.
IdentityTransform	Identity transform for testing.
IntValueFilterTransform	Transform that filters out records whose configured field is a configured value.
IntValueFilterTransform.Config	Config for the transform.
MockTransformContext	Mock context for unit tests
NullFieldSplitterTransform	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.
NullFieldSplitterTransform.Config	Config for the transform.
SleepTransform	Sleeps for a configurable amount of time before emitting the input.
SleepTransform.Config	Config for plugin
StringValueFilterTransform	Transform that filters out records whose configured field is a configured value.
StringValueFilterTransform.Config	Config for the transform.