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

Class StreamingSourceContextImpl

java.lang.Object

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

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

All Implemented Interfaces:

DatasetContext, MetadataReader, MetadataWriter, ServiceDiscoverer, BatchContext, LineageRecorder, LookupProvider, StageContext, io.cdap.cdap.etl.api.streaming.StreamingSourceContext, TransformContext

public class StreamingSourceContextImpl
extends BatchContextImpl
implements io.cdap.cdap.etl.api.streaming.StreamingSourceContext

Class for creating context object of different CDAP classes with stream 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 and Description
StreamingSourceContextImpl()

Method Summary

Modifier and Type	Method and Description
boolean	isPreviewEnabled()
void	registerLineage(java.lang.String referenceName, io.cdap.cdap.api.data.schema.Schema schema)

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.StageContext

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

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

getServiceURL, getServiceURL, getServiceURL, openConnection

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.etl.api.lineage.field.LineageRecorder

record

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

provide

Constructor Detail

StreamingSourceContextImpl

public StreamingSourceContextImpl()

Method Detail

registerLineage

public void registerLineage(java.lang.String referenceName,
                            @Nullable
                            io.cdap.cdap.api.data.schema.Schema schema)
                     throws DatasetManagementException,
                            org.apache.tephra.TransactionFailureException

Specified by:

registerLineage in interface io.cdap.cdap.etl.api.streaming.StreamingSourceContext

Throws:

DatasetManagementException

org.apache.tephra.TransactionFailureException

isPreviewEnabled

public boolean isPreviewEnabled()

Specified by:

isPreviewEnabled in interface io.cdap.cdap.etl.api.streaming.StreamingSourceContext