co.cask.cdap.etl.mock.realtime

Class LookupSource

java.lang.Object

co.cask.cdap.etl.api.realtime.RealtimeSource<co.cask.cdap.api.data.format.StructuredRecord>

co.cask.cdap.etl.mock.realtime.LookupSource

All Implemented Interfaces:

Destroyable, PipelineConfigurable, StageLifecycle<RealtimeContext>

public class LookupSource
extends RealtimeSource<co.cask.cdap.api.data.format.StructuredRecord>

Source used to test lookup functionality. Takes a set of fields as config and emits a single record with each field value being the result of lookup for that field.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LookupSource.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.realtime.RealtimeSource

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
LookupSource(LookupSource.Config config)

Method Summary

Methods

Modifier and Type	Method and Description
static ETLPlugin	getPlugin(Set<String> fields, String lookupName)
void	initialize(RealtimeContext context)
SourceState	poll(Emitter<co.cask.cdap.api.data.format.StructuredRecord> writer, SourceState currentState)

Methods inherited from class co.cask.cdap.etl.api.realtime.RealtimeSource

configurePipeline, destroy

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

LookupSource

public LookupSource(LookupSource.Config config)

Method Detail

initialize

public void initialize(RealtimeContext context)
                throws Exception

Specified by:

initialize in interface StageLifecycle<RealtimeContext>

Overrides:

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

Throws:

Exception

poll

@Nullable
public SourceState poll(Emitter<co.cask.cdap.api.data.format.StructuredRecord> writer,
                        SourceState currentState)
                 throws Exception

Specified by:

poll in class RealtimeSource<co.cask.cdap.api.data.format.StructuredRecord>

Throws:

Exception

getPlugin

public static ETLPlugin getPlugin(Set<String> fields,
                  String lookupName)