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)	Specifies the deserialization schema to be used.
DecodableStreamSourceBuilder<T>	withStartupMode(StartupMode startupMode)	Specifies the start-up mode to use when reading from the stream.
DecodableStreamSourceBuilder<T>	withStreamId(String streamId)	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. Either this or withStreamId(String) may be used, but not both.

withStreamId

DecodableStreamSourceBuilder<T> withStreamId(String streamId)

Specifies the id of the stream to read from. Either this or withStreamName(String) may be used, but not both.

withStartupMode

DecodableStreamSourceBuilder<T> withStartupMode(StartupMode startupMode)

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

withDeserializationSchema

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

Specifies the deserialization schema to be used.

build

DecodableStreamSource<T> build()

Returns a new DecodableStreamSource for the given configuration.