DecodableStreamSinkBuilder (Decodable Pipeline SDK 1.0.0.Beta7)

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>

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

Specifies the serialization schema to be used.

DecodableStreamSinkBuilder<T>

withStreamId(String streamId)

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. Either this or withStreamId(String) may be used, but not both.
- withStreamId
  
  DecodableStreamSinkBuilder<T> withStreamId(String streamId)
  
  Specifies the id of the stream to write to. Either this or withStreamName(String) may be used, but not both.
- withSerializationSchema
  
  DecodableStreamSinkBuilder<T> withSerializationSchema(org.apache.flink.api.common.serialization.SerializationSchema<T> serializationSchema)
  
  Specifies the serialization schema to be used.
- build
  
  DecodableStreamSink<T> build()
  
  Returns a new DecodableStreamSink for the given configuration.