Uses of Class
org.apache.flink.connector.file.sink.writer.FileWriterBucketState

Packages that use FileWriterBucketState

Package	Description
org.apache.flink.connector.file.sink
org.apache.flink.connector.file.sink.writer

Uses of FileWriterBucketState in org.apache.flink.connector.file.sink

Methods in org.apache.flink.connector.file.sink that return types with arguments of type FileWriterBucketState

Modifier and Type	Method and Description
SimpleVersionedSerializer<FileWriterBucketState>	FileSink.getWriterStateSerializer()

Method parameters in org.apache.flink.connector.file.sink with type arguments of type FileWriterBucketState

Modifier and Type	Method and Description
FileWriter<IN>	FileSink.restoreWriter(Sink.InitContext context, Collection<FileWriterBucketState> recoveredState)

Uses of FileWriterBucketState in org.apache.flink.connector.file.sink.writer

Methods in org.apache.flink.connector.file.sink.writer that return FileWriterBucketState

Modifier and Type	Method and Description
FileWriterBucketState	FileWriterBucketStateSerializer.deserialize(int version, byte[] serialized)

Methods in org.apache.flink.connector.file.sink.writer that return types with arguments of type FileWriterBucketState

Modifier and Type	Method and Description
List<FileWriterBucketState>	FileWriter.snapshotState(long checkpointId)

Methods in org.apache.flink.connector.file.sink.writer with parameters of type FileWriterBucketState

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)

Method parameters in org.apache.flink.connector.file.sink.writer with type arguments of type FileWriterBucketState

Modifier and Type	Method and Description
void	FileWriter.initializeState(Collection<FileWriterBucketState> bucketStates) Initializes the state after recovery from a failure.