co.cask.cdap.etl.mock.batch

Class LookupTransform<T>

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.batch.LookupTransform<T>

Type Parameters:

T - The type of object that will be returned for the lookup.

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 LookupTransform<T>
extends Transform<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Transform used to test lookup functionality. Takes a field name whose value will be used as the key in a lookup. If the lookup is from a Table, the value of the lookup will be a Row, and the columns of the Row will be added as individual fields of the output StructuredRecord. If the lookup is from a KeyValueTable, the value of the lookup will be a String, and the 'destinationField' will be used to determine where in the output StructuredRecord to place the value.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LookupTransform.Config Config for the source.

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
LookupTransform(LookupTransform.Config config)

Method Summary

Methods

Modifier and Type	Method and Description
static ETLPlugin	getPlugin(String lookupKey, String destinationField, String lookupName)
void	initialize(TransformContext context)
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, 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

LookupTransform

public LookupTransform(LookupTransform.Config config)

Method Detail

initialize

public void initialize(TransformContext context)
                throws Exception

Specified by:

initialize in interface StageLifecycle<TransformContext>

Overrides:

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

Throws:

Exception

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 lookupKey,
                  String destinationField,
                  String lookupName)