Package org.apache.flink.formats.hadoop.bulk
-
Interface Summary Interface Description HadoopFileCommitter The committer publishes an intermediate Hadoop file to the target path after it finishes writing.HadoopFileCommitterFactory The factory to create theHadoopFileCommitter
.HadoopPathBasedBulkWriter<T> SpecializedBulkWriter
which is expected to write to specifiedPath
.HadoopPathBasedBulkWriter.Factory<T> A factory that creates aHadoopPathBasedBulkWriter
. -
Class Summary Class Description DefaultHadoopFileCommitterFactory The default hadoop file committer factory which always useHadoopRenameFileCommitter
.HadoopPathBasedPartFileWriter<IN,BucketID> The part-file writer that writes to the specified hadoop path.HadoopPathBasedPartFileWriter.HadoopPathBasedBucketWriter<IN,BucketID> Factory to createHadoopPathBasedPartFileWriter
.