Class Hierarchy
- java.lang.Object
- org.apache.flink.streaming.api.functions.sink.filesystem.AbstractPartFileWriter<IN,BucketID> (implements org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter<IN,BucketID>)
- org.apache.flink.formats.hadoop.bulk.HadoopPathBasedPartFileWriter<IN,BucketID>
- org.apache.flink.formats.hadoop.bulk.DefaultHadoopFileCommitterFactory (implements org.apache.flink.formats.hadoop.bulk.HadoopFileCommitterFactory)
- org.apache.flink.formats.hadoop.bulk.HadoopPathBasedPartFileWriter.HadoopPathBasedBucketWriter<IN,BucketID> (implements org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN,BucketID>)
- org.apache.flink.streaming.api.functions.sink.filesystem.AbstractPartFileWriter<IN,BucketID> (implements org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter<IN,BucketID>)
Interface Hierarchy
- org.apache.flink.api.common.serialization.BulkWriter<T>
- org.apache.flink.formats.hadoop.bulk.HadoopPathBasedBulkWriter<T>
- org.apache.flink.formats.hadoop.bulk.HadoopFileCommitter
- java.io.Serializable
- org.apache.flink.formats.hadoop.bulk.HadoopFileCommitterFactory
- org.apache.flink.formats.hadoop.bulk.HadoopPathBasedBulkWriter.Factory<T>