public class HiveBulkWriterFactory extends Object implements HadoopPathBasedBulkWriter.Factory<RowData>
Constructor and Description |
---|
HiveBulkWriterFactory(HiveWriterFactory factory) |
Modifier and Type | Method and Description |
---|---|
HadoopPathBasedBulkWriter<RowData> |
create(org.apache.hadoop.fs.Path targetPath,
org.apache.hadoop.fs.Path inProgressPath)
Creates a path-based writer that writes to the inProgressPath first and commits
to targetPath finally.
|
public HiveBulkWriterFactory(HiveWriterFactory factory)
public HadoopPathBasedBulkWriter<RowData> create(org.apache.hadoop.fs.Path targetPath, org.apache.hadoop.fs.Path inProgressPath) throws IOException
HadoopPathBasedBulkWriter.Factory
create
in interface HadoopPathBasedBulkWriter.Factory<RowData>
targetPath
- The final path to commit to.inProgressPath
- The intermediate path to write to before committing.IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.