co.cask.cdap.etl.mock.batch

Class IncapableSink

java.lang.Object

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

co.cask.cdap.etl.api.batch.BatchSink<co.cask.cdap.api.data.format.StructuredRecord,byte[],Put>

co.cask.cdap.etl.mock.batch.IncapableSink

All Implemented Interfaces:

Destroyable, PipelineConfigurable, StageLifecycle<BatchRuntimeContext>, SubmitterLifecycle<BatchSinkContext>, Transformation<co.cask.cdap.api.data.format.StructuredRecord,KeyValue<byte[],Put>>

public class IncapableSink
extends BatchSink<co.cask.cdap.api.data.format.StructuredRecord,byte[],Put>

Sink which has an requirement which can be meet with another special requirement

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME

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

FORMAT_PLUGIN_TYPE, PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
IncapableSink()

Method Summary

Modifier and Type	Method and Description
static ETLPlugin	getPlugin()
void	prepareRun(BatchSinkContext context)

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

configurePipeline, onRunFinish

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

Constructor Detail

IncapableSink

public IncapableSink()

Method Detail

prepareRun

public void prepareRun(BatchSinkContext context)
                throws Exception

Specified by:

prepareRun in interface SubmitterLifecycle<BatchSinkContext>

Specified by:

prepareRun in class BatchConfigurable<BatchSinkContext>

Throws:

Exception

getPlugin

public static ETLPlugin getPlugin()

Returns:

IncapableSink as the ETLPlugin