co.cask.cdap.etl.mock.batch

Class IncapableSource

java.lang.Object

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

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

co.cask.cdap.etl.mock.batch.IncapableSource

All Implemented Interfaces:

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

public class IncapableSource
extends BatchSource<byte[],Row,co.cask.cdap.api.data.format.StructuredRecord>

Source which has a requirement

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME

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

FORMAT_PLUGIN_TYPE, PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
IncapableSource()

Method Summary

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

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

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

IncapableSource

public IncapableSource()

Method Detail

prepareRun

public void prepareRun(BatchSourceContext context)
                throws Exception

Specified by:

prepareRun in interface SubmitterLifecycle<BatchSourceContext>

Specified by:

prepareRun in class BatchConfigurable<BatchSourceContext>

Throws:

Exception

getPlugin

public static ETLPlugin getPlugin()

Returns:

IncapableSource as the ETLPlugin