co.cask.hydrator.common

Class ReferenceRealtimeSink<I>

java.lang.Object

co.cask.cdap.etl.api.realtime.RealtimeSink<I>

co.cask.hydrator.common.ReferenceRealtimeSink<I>

Type Parameters:

I - Type of object that sink operates on

All Implemented Interfaces:

Destroyable, PipelineConfigurable, StageLifecycle<RealtimeContext>

public abstract class ReferenceRealtimeSink<I>
extends RealtimeSink<I>

A RealtimeSink that verifies referenceName property and creates an externalDataset.

Field Summary

Fields inherited from class co.cask.cdap.etl.api.realtime.RealtimeSink

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
ReferenceRealtimeSink(ReferencePluginConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
void	configurePipeline(PipelineConfigurer pipelineConfigurer)
void	initialize(RealtimeContext context)

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

destroy, write

Methods inherited from class java.lang.Object

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

Constructor Detail

ReferenceRealtimeSink

public ReferenceRealtimeSink(ReferencePluginConfig config)

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

configurePipeline in class RealtimeSink<I>

initialize

public void initialize(RealtimeContext context)
                throws Exception

Specified by:

initialize in interface StageLifecycle<RealtimeContext>

Overrides:

initialize in class RealtimeSink<I>

Throws:

Exception