Class Hierarchy
- java.lang.Object
- org.apache.flink.connector.file.sink.FileSink<IN> (implements org.apache.flink.api.connector.sink2.StatefulSink<InputT,WriterStateT>, org.apache.flink.api.connector.sink2.StatefulSink.WithCompatibleState, org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<InputT,CommT>, org.apache.flink.streaming.api.connector.sink2.WithPreCommitTopology<InputT,CommT>)
- org.apache.flink.connector.file.sink.FileSink.BulkFormatBuilder<IN,T>
- org.apache.flink.connector.file.sink.FileSink.RowFormatBuilder<IN,T>
- 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.Generator (implements org.apache.flink.streaming.api.checkpoint.CheckpointedFunction, org.apache.flink.streaming.api.functions.source.SourceFunction<T>)
- org.apache.flink.connector.file.sink.FileSinkProgram.KeyBucketAssigner (implements org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID>)
Enum Hierarchy
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.