co.cask.cdap.data.stream

Class StreamInputFormatProvider

java.lang.Object

co.cask.cdap.data.stream.StreamInputFormatProvider

All Implemented Interfaces:

co.cask.cdap.api.data.batch.InputFormatProvider

public class StreamInputFormatProvider
extends Object
implements co.cask.cdap.api.data.batch.InputFormatProvider

A InputFormatProvider to provide InputFormat to read from stream.

Constructor Summary

Constructors

Constructor and Description
StreamInputFormatProvider(Id.Namespace namespaceId, co.cask.cdap.api.data.stream.StreamBatchReadable streamBatchReadable, StreamAdmin streamAdmin)

Method Summary

Methods

Modifier and Type	Method and Description
String	getInputFormatClassName()
Map<String,String>	getInputFormatConfiguration()
Id.Stream	getStreamId() Returns the stream Id of the stream that will be consumed by InputFormat.
Map<String,String>	setDecoderType(Map<String,String> configuration, Type type) Sets the StreamEventDecoder to be used by the InputFormat for the given type.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamInputFormatProvider

public StreamInputFormatProvider(Id.Namespace namespaceId,
                         co.cask.cdap.api.data.stream.StreamBatchReadable streamBatchReadable,
                         StreamAdmin streamAdmin)

Method Detail

getStreamId

public Id.Stream getStreamId()

Returns the stream Id of the stream that will be consumed by InputFormat.

setDecoderType

public Map<String,String> setDecoderType(Map<String,String> configuration,
                                Type type)

Sets the StreamEventDecoder to be used by the InputFormat for the given type. If the StreamBatchReadable already defined a StreamEventDecoder or FormatSpecification, this method is a no-op.

Parameters:

configuration - configuration to update

type - type for StreamEventData to decode to

Returns:

the same configuration map as in the argument.

getInputFormatClassName

public String getInputFormatClassName()

Specified by:

getInputFormatClassName in interface co.cask.cdap.api.data.batch.InputFormatProvider

getInputFormatConfiguration

public Map<String,String> getInputFormatConfiguration()

Specified by:

getInputFormatConfiguration in interface co.cask.cdap.api.data.batch.InputFormatProvider