org.apache.flink.connector.kinesis.sink

Class KinesisStreamsSinkElementConverter.Builder<InputT>

java.lang.Object

org.apache.flink.connector.kinesis.sink.KinesisStreamsSinkElementConverter.Builder<InputT>

Enclosing class:

KinesisStreamsSinkElementConverter<InputT>

public static class KinesisStreamsSinkElementConverter.Builder<InputT>
extends Object

A builder for the KinesisStreamsSinkElementConverter.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
KinesisStreamsSinkElementConverter<InputT>	build()
KinesisStreamsSinkElementConverter.Builder<InputT>	setPartitionKeyGenerator(PartitionKeyGenerator<InputT> partitionKeyGenerator)
KinesisStreamsSinkElementConverter.Builder<InputT>	setSerializationSchema(SerializationSchema<InputT> serializationSchema)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setSerializationSchema

public KinesisStreamsSinkElementConverter.Builder<InputT> setSerializationSchema(SerializationSchema<InputT> serializationSchema)

setPartitionKeyGenerator

public KinesisStreamsSinkElementConverter.Builder<InputT> setPartitionKeyGenerator(PartitionKeyGenerator<InputT> partitionKeyGenerator)

build

public KinesisStreamsSinkElementConverter<InputT> build()