Package co.decodable.sdk.pipeline

Interface DecodableStreamSourceBuilder<T>

public interface DecodableStreamSourceBuilder<T>

Builder for creating DecodableStreamSource instances.

Method Summary

Modifier and Type	Method	Description
DecodableStreamSource<T>	build()	Returns a new DecodableStreamSource for the given configuration.
DecodableStreamSourceBuilder<T>	withDeserializationSchema(org.apache.flink.api.common.serialization.DeserializationSchema<T> deserializationSchema)	Deprecated. Specifies the value only deserialization schema to be used.
DecodableStreamSourceBuilder<T>	withRecordDeserializationSchema(DecodableRecordDeserializationSchema<?> recordDeserializationSchema)	Specifies the record deserialization schema to be used which supports both key and value parts of a record.
DecodableStreamSourceBuilder<T>	withStartupMode(StartupMode startupMode)	Specifies the start-up mode to use when reading from the stream.
DecodableStreamSourceBuilder<T>	withStreamId(String streamId)	Deprecated. Specifies the id of the stream to read from.
DecodableStreamSourceBuilder<T>	withStreamName(String streamName)	Specifies the name of the stream to read from.

Method Details

withStreamName

DecodableStreamSourceBuilder<T> withStreamName(String streamName)

Specifies the name of the stream to read from.

withStreamId

@Deprecated
DecodableStreamSourceBuilder<T> withStreamId(String streamId)

Deprecated.

Specifies the id of the stream to read from. Use withStreamName(String) instead.

withStartupMode

DecodableStreamSourceBuilder<T> withStartupMode(StartupMode startupMode)

Specifies the start-up mode to use when reading from the stream.

withDeserializationSchema

@Deprecated
DecodableStreamSourceBuilder<T> withDeserializationSchema(org.apache.flink.api.common.serialization.DeserializationSchema<T> deserializationSchema)

Deprecated.

Specifies the value only deserialization schema to be used. Use withRecordDeserializationSchema(DecodableRecordDeserializationSchema) instead.

withRecordDeserializationSchema

DecodableStreamSourceBuilder<T> withRecordDeserializationSchema(DecodableRecordDeserializationSchema<?> recordDeserializationSchema)

Specifies the record deserialization schema to be used which supports both key and value parts of a record.

build

DecodableStreamSource<T> build()

Returns a new DecodableStreamSource for the given configuration.