KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder |
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder.setConsumedDataType(DataType consumedDataType) |
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder |
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder.setDeliveryStream(String deliveryStream) |
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder |
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder.setEncodingFormat(EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder |
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder.setFailOnError(Boolean failOnError) |
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder |
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder.setFirehoseClientProperties(Properties firehoseClientProperties) |