KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder.setConsumedDataType(DataType consumedDataType) |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder.setEncodingFormat(EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder.setFailOnError(Boolean failOnError) |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder.setKinesisClientProperties(Properties kinesisClientProperties) |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder.setPartitioner(PartitionKeyGenerator<RowData> partitioner) |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder.setStream(String stream) |