Modifier and Type | Method and Description |
---|---|
TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT> |
TwoPhaseCommittingSink.createWriter(Sink.InitContext context)
Creates a
TwoPhaseCommittingSink.PrecommittingSinkWriter that creates committables on checkpoint or end of
input. |
StatefulSink.StatefulSinkWriter<InputT,WriterStateT> |
StatefulSink.createWriter(Sink.InitContext context)
Create a
StatefulSink.StatefulSinkWriter . |
SinkWriter<InputT> |
Sink.createWriter(Sink.InitContext context)
Creates a
SinkWriter . |
StatefulSink.StatefulSinkWriter<InputT,WriterStateT> |
StatefulSink.restoreWriter(Sink.InitContext context,
Collection<WriterStateT> recoveredState)
Create a
StatefulSink.StatefulSinkWriter from a recovered state. |
Constructor and Description |
---|
AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter,
Sink.InitContext context,
AsyncSinkWriterConfiguration configuration,
Collection<BufferedRequestState<RequestEntryT>> states) |
AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter,
Sink.InitContext context,
int maxBatchSize,
int maxInFlightRequests,
int maxBufferedRequests,
long maxBatchSizeInBytes,
long maxTimeInBufferMS,
long maxRecordSizeInBytes)
Deprecated.
|
AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter,
Sink.InitContext context,
int maxBatchSize,
int maxInFlightRequests,
int maxBufferedRequests,
long maxBatchSizeInBytes,
long maxTimeInBufferMS,
long maxRecordSizeInBytes,
Collection<BufferedRequestState<RequestEntryT>> states)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
FileWriter<IN> |
FileSink.createWriter(Sink.InitContext context) |
FileWriter<IN> |
FileSink.restoreWriter(Sink.InitContext context,
Collection<FileWriterBucketState> recoveredState) |
Modifier and Type | Method and Description |
---|---|
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> |
KinesisFirehoseSink.createWriter(Sink.InitContext context) |
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> |
KinesisFirehoseSink.restoreWriter(Sink.InitContext context,
Collection<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> recoveredState) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.connector.kafka.sink.KafkaWriter<IN> |
KafkaSink.createWriter(Sink.InitContext context) |
org.apache.flink.connector.kafka.sink.KafkaWriter<IN> |
KafkaSink.restoreWriter(Sink.InitContext context,
Collection<org.apache.flink.connector.kafka.sink.KafkaWriterState> recoveredState) |
Modifier and Type | Method and Description |
---|---|
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> |
KinesisStreamsSink.createWriter(Sink.InitContext context) |
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> |
KinesisStreamsSink.restoreWriter(Sink.InitContext context,
Collection<BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> recoveredState) |
Modifier and Type | Method and Description |
---|---|
TwoPhaseCommittingSink.PrecommittingSinkWriter<IN,PulsarCommittable> |
PulsarSink.createWriter(Sink.InitContext initContext) |
Constructor and Description |
---|
PulsarWriter(SinkConfiguration sinkConfiguration,
PulsarSerializationSchema<IN> serializationSchema,
TopicMetadataListener metadataListener,
TopicRouter<IN> topicRouter,
MessageDelayer<IN> messageDelayer,
Sink.InitContext initContext)
Constructor creating a Pulsar writer.
|
Constructor and Description |
---|
PulsarSinkContextImpl(Sink.InitContext initContext,
SinkConfiguration sinkConfiguration) |
Modifier and Type | Method and Description |
---|---|
SinkWriter<IN> |
UpsertTestSink.createWriter(Sink.InitContext context) |
Modifier and Type | Method and Description |
---|---|
SinkWriter<IN> |
PrintSink.createWriter(Sink.InitContext context) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.streaming.api.transformations.SinkV1Adapter.SinkWriterV1Adapter<InputT,CommT,WriterStateT> |
SinkV1Adapter.createWriter(Sink.InitContext context) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.