Package org.apache.beam.sdk.io.cdap.context

Class BatchSourceContextImpl

java.lang.Object

org.apache.beam.sdk.io.cdap.context.BatchContextImpl

org.apache.beam.sdk.io.cdap.context.BatchSourceContextImpl

All Implemented Interfaces:

DatasetContext, MetadataReader, MetadataWriter, ServiceDiscoverer, BatchContext, BatchSourceContext, LineageRecorder, LookupProvider, StageContext, TransformContext

public class BatchSourceContextImpl
extends BatchContextImpl
implements BatchSourceContext

Class for creating context object of different CDAP classes with batch source type.

Field Summary

Fields inherited from class org.apache.beam.sdk.io.cdap.context.BatchContextImpl

DEFAULT_SCHEMA_FIELD_NAME, DEFAULT_SCHEMA_RECORD_NAME, inputFormatProvider, outputFormatProvider, settableArguments

Constructor Summary

Constructors

Constructor	Description
BatchSourceContextImpl()

Method Summary

Modifier and Type	Method	Description
int	getMaxPreviewRecords()
boolean	isPreviewEnabled()
void	setInput(Input input)	Overrides the input configuration of this Batch job to the specified Input.

Methods inherited from class org.apache.beam.sdk.io.cdap.context.BatchContextImpl

addProperties, addTags, addTags, createDataset, datasetExists, discardDataset, getArguments, getDataset, getDataset, getDataset, getDataset, getFailureCollector, getInputFormatProvider, getInputSchema, getInputSchemas, getLogicalStartTime, getMetadata, getMetadata, getMetrics, getNamespace, getOutputFormatProvider, getOutputPortSchemas, getOutputSchema, getPipelineName, getPluginProperties, getPluginProperties, getServiceURL, getServiceURL, getStageName, loadPluginClass, newPluginInstance, provide, record, releaseDataset, removeMetadata, removeProperties, removeProperties, removeTags, removeTags

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.cdap.cdap.etl.api.batch.BatchContext

createDataset, datasetExists, getArguments

Methods inherited from interface io.cdap.cdap.api.data.DatasetContext

discardDataset, getDataset, getDataset, getDataset, getDataset, releaseDataset

Methods inherited from interface io.cdap.cdap.etl.api.lineage.field.LineageRecorder

record

Methods inherited from interface io.cdap.cdap.etl.api.LookupProvider

provide

Methods inherited from interface io.cdap.cdap.api.metadata.MetadataReader

getMetadata, getMetadata

Methods inherited from interface io.cdap.cdap.api.metadata.MetadataWriter

addProperties, addTags, addTags, removeMetadata, removeProperties, removeProperties, removeTags, removeTags

Methods inherited from interface io.cdap.cdap.api.ServiceDiscoverer

getServiceURL, getServiceURL, getServiceURL, openConnection

Methods inherited from interface io.cdap.cdap.etl.api.StageContext

getFailureCollector, getInputSchema, getInputSchemas, getInputStages, getLogicalStartTime, getMetrics, getNamespace, getOutputPortSchemas, getOutputSchema, getPipelineName, getPluginProperties, getPluginProperties, getStageName, loadPluginClass, newPluginInstance

Constructor Details

BatchSourceContextImpl

public BatchSourceContextImpl()

Method Details

setInput

public void setInput(Input input)

Overrides the input configuration of this Batch job to the specified Input.

Specified by:

setInput in interface BatchSourceContext

isPreviewEnabled

public boolean isPreviewEnabled()

Specified by:

isPreviewEnabled in interface BatchSourceContext

getMaxPreviewRecords

public int getMaxPreviewRecords()

Specified by:

getMaxPreviewRecords in interface BatchSourceContext