Class Hierarchy
- java.lang.Object
- org.apache.flink.connector.file.sink.writer.DefaultFileWriterBucketFactory<IN> (implements org.apache.flink.connector.file.sink.writer.FileWriterBucketFactory<IN>)
- org.apache.flink.connector.file.sink.writer.FileWriter<IN> (implements org.apache.flink.api.connector.sink2.CommittingSinkWriter<InputT,CommittableT>, org.apache.flink.api.common.operators.ProcessingTimeService.ProcessingTimeCallback, org.apache.flink.api.connector.sink2.SinkWriter<InputT>, org.apache.flink.api.connector.sink2.StatefulSinkWriter<InputT,WriterStateT>)
- org.apache.flink.connector.file.sink.writer.FileWriterBucketState
- org.apache.flink.connector.file.sink.writer.FileWriterBucketStateSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
Interface Hierarchy
- java.io.Serializable
- org.apache.flink.connector.file.sink.writer.FileWriterBucketFactory<IN>