co.cask.hydrator.common

Class ReferenceBatchSource<KEY_IN,VAL_IN,OUT>

java.lang.Object

co.cask.cdap.etl.api.batch.BatchConfigurable<co.cask.cdap.etl.api.batch.BatchSourceContext>

co.cask.cdap.etl.api.batch.BatchSource<KEY_IN,VAL_IN,OUT>

co.cask.hydrator.common.ReferenceBatchSource<KEY_IN,VAL_IN,OUT>

Type Parameters:

KEY_IN - the type of input key from the Batch run

VAL_IN - the type of input value from the Batch run

OUT - the type of output for the source

All Implemented Interfaces:

co.cask.cdap.etl.api.Destroyable, co.cask.cdap.etl.api.PipelineConfigurable, co.cask.cdap.etl.api.StageLifecycle<co.cask.cdap.etl.api.batch.BatchRuntimeContext>, co.cask.cdap.etl.api.Transformation<co.cask.cdap.api.dataset.lib.KeyValue<KEY_IN,VAL_IN>,OUT>

public abstract class ReferenceBatchSource<KEY_IN,VAL_IN,OUT>
extends co.cask.cdap.etl.api.batch.BatchSource<KEY_IN,VAL_IN,OUT>

A BatchSource that verifies referenceName property

Field Summary

Fields inherited from class co.cask.cdap.etl.api.batch.BatchSource

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
ReferenceBatchSource(ReferencePluginConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
void	configurePipeline(co.cask.cdap.etl.api.PipelineConfigurer pipelineConfigurer)

Methods inherited from class co.cask.cdap.etl.api.batch.BatchSource

destroy, initialize, transform

Methods inherited from class co.cask.cdap.etl.api.batch.BatchConfigurable

onRunFinish, prepareRun

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReferenceBatchSource

public ReferenceBatchSource(ReferencePluginConfig config)

Method Detail

configurePipeline

public void configurePipeline(co.cask.cdap.etl.api.PipelineConfigurer pipelineConfigurer)

Specified by:

configurePipeline in interface co.cask.cdap.etl.api.PipelineConfigurable

Overrides:

configurePipeline in class co.cask.cdap.etl.api.batch.BatchConfigurable<co.cask.cdap.etl.api.batch.BatchSourceContext>