co.cask.hydrator.common

Class ReferenceRealtimeSource<T>

java.lang.Object

co.cask.cdap.etl.api.realtime.RealtimeSource<T>

co.cask.hydrator.common.ReferenceRealtimeSource<T>

Type Parameters:

T - Type of object that the source emits

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.realtime.RealtimeContext>

public abstract class ReferenceRealtimeSource<T>
extends co.cask.cdap.etl.api.realtime.RealtimeSource<T>

A RealtimeSource that verifies referenceName property and creates an externalDataset.

Field Summary

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

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
ReferenceRealtimeSource(ReferencePluginConfig config)

Method Summary

Methods

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

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

destroy, poll

Methods inherited from class java.lang.Object

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

Constructor Detail

ReferenceRealtimeSource

public ReferenceRealtimeSource(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.realtime.RealtimeSource<T>

initialize

public void initialize(co.cask.cdap.etl.api.realtime.RealtimeContext context)
                throws Exception

Specified by:

initialize in interface co.cask.cdap.etl.api.StageLifecycle<co.cask.cdap.etl.api.realtime.RealtimeContext>

Overrides:

initialize in class co.cask.cdap.etl.api.realtime.RealtimeSource<T>

Throws:

Exception