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> SpecializedBulkWriterwhich 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.