co.cask.hydrator.common

Class ReferenceBatchSink<IN,KEY_OUT,VAL_OUT>

java.lang.Object

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

co.cask.cdap.etl.api.batch.BatchSink<IN,KEY_OUT,VAL_OUT>

co.cask.hydrator.common.ReferenceBatchSink<IN,KEY_OUT,VAL_OUT>

Type Parameters:

IN - the type of input object to the sink

KEY_OUT - the type of key the sink outputs

VAL_OUT - the type of value the sink outputs

All Implemented Interfaces:

Destroyable, PipelineConfigurable, StageLifecycle<BatchRuntimeContext>, Transformation<IN,co.cask.cdap.api.dataset.lib.KeyValue<KEY_OUT,VAL_OUT>>

public abstract class ReferenceBatchSink<IN,KEY_OUT,VAL_OUT>
extends BatchSink<IN,KEY_OUT,VAL_OUT>

A BatchSink that verifies referenceName property

Field Summary

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

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
ReferenceBatchSink(ReferencePluginConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
void	configurePipeline(PipelineConfigurer pipelineConfigurer)

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

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

ReferenceBatchSink

public ReferenceBatchSink(ReferencePluginConfig config)

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

configurePipeline in class BatchConfigurable<BatchSinkContext>