Package | Description |
---|---|
org.apache.flink.connector.file.sink | |
org.apache.flink.connector.file.sink.writer |
Modifier and Type | Method and Description |
---|---|
SinkWriter<IN,FileSinkCommittable,FileWriterBucketState> |
FileSink.createWriter(Sink.InitContext context,
List<FileWriterBucketState> states) |
Optional<SimpleVersionedSerializer<FileWriterBucketState>> |
FileSink.getWriterStateSerializer() |
Modifier and Type | Method and Description |
---|---|
SinkWriter<IN,FileSinkCommittable,FileWriterBucketState> |
FileSink.createWriter(Sink.InitContext context,
List<FileWriterBucketState> states) |
Modifier and Type | Method and Description |
---|---|
FileWriterBucketState |
FileWriterBucketStateSerializer.deserialize(int version,
byte[] serialized) |
Modifier and Type | Method and Description |
---|---|
List<FileWriterBucketState> |
FileWriter.snapshotState(long checkpointId) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN> |
FileWriterBucketFactory.restoreBucket(BucketWriter<IN,String> bucketWriter,
RollingPolicy<IN,String> rollingPolicy,
FileWriterBucketState bucketState,
OutputFileConfig outputFileConfig) |
org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN> |
DefaultFileWriterBucketFactory.restoreBucket(BucketWriter<IN,String> bucketWriter,
RollingPolicy<IN,String> rollingPolicy,
FileWriterBucketState bucketState,
OutputFileConfig outputFileConfig) |
byte[] |
FileWriterBucketStateSerializer.serialize(FileWriterBucketState state) |
Modifier and Type | Method and Description |
---|---|
void |
FileWriter.initializeState(List<FileWriterBucketState> bucketStates)
Initializes the state after recovery from a failure.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.