Package co.decodable.sdk.pipeline

Interface DecodableStreamSinkBuilder<T>

public interface DecodableStreamSinkBuilder<T>

Builder for creating DecodableStreamSink instances.

Method Summary

Modifier and Type	Method	Description
DecodableStreamSink<T>	build()	Returns a new DecodableStreamSink for the given configuration.
DecodableStreamSinkBuilder<T>	withRecordSerializationSchema(DecodableRecordSerializationSchema<?> recordSerializationSchema)	Specifies the key and value serialization schema to be used which supports both key and value parts of a record.
DecodableStreamSinkBuilder<T>	withSerializationSchema(org.apache.flink.api.common.serialization.SerializationSchema<T> serializationSchema)	Deprecated. Specifies the value only serialization schema to be used.
DecodableStreamSinkBuilder<T>	withStreamId(String streamId)	Deprecated. Specifies the id of the stream to write to.
DecodableStreamSinkBuilder<T>	withStreamName(String streamName)	Specifies the name of the stream to write to.

Method Details

withStreamName

DecodableStreamSinkBuilder<T> withStreamName(String streamName)

Specifies the name of the stream to write to.

withStreamId

@Deprecated
DecodableStreamSinkBuilder<T> withStreamId(String streamId)

Deprecated.

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

withSerializationSchema

@Deprecated
DecodableStreamSinkBuilder<T> withSerializationSchema(org.apache.flink.api.common.serialization.SerializationSchema<T> serializationSchema)

Deprecated.

Specifies the value only serialization schema to be used. Use withRecordSerializationSchema(DecodableRecordSerializationSchema) instead.

withRecordSerializationSchema

DecodableStreamSinkBuilder<T> withRecordSerializationSchema(DecodableRecordSerializationSchema<?> recordSerializationSchema)

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

build

DecodableStreamSink<T> build()

Returns a new DecodableStreamSink for the given configuration.