Class Hierarchy
- java.lang.Object
- org.apache.flink.connector.file.sink.FileSink<IN> (implements org.apache.flink.api.connector.sink2.Sink<InputT>, org.apache.flink.api.connector.sink2.SupportsCommitter<CommittableT>, org.apache.flink.api.common.SupportsConcurrentExecutionAttempts, org.apache.flink.streaming.api.connector.sink2.SupportsPreCommitTopology<WriterResultT,CommittableT>, org.apache.flink.api.connector.sink2.SupportsWriterState<InputT,WriterStateT>, org.apache.flink.api.connector.sink2.SupportsWriterState.WithCompatibleState)
- org.apache.flink.connector.file.sink.FileSink.BulkFormatBuilder<IN,T>
- org.apache.flink.connector.file.sink.FileSink.DefaultBulkFormatBuilder<IN>
- org.apache.flink.connector.file.sink.FileSink.RowFormatBuilder<IN,T>
- org.apache.flink.connector.file.sink.FileSink.DefaultRowFormatBuilder<IN>
- org.apache.flink.connector.file.sink.FileSinkCommittable (implements java.io.Serializable)
- org.apache.flink.connector.file.sink.FileSinkCommittableSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
- org.apache.flink.connector.file.sink.FileSinkProgram.KeyBucketAssigner (implements org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID>)
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- org.apache.flink.connector.file.sink.FileSinkProgram
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)