HadoopPathBasedBulkWriter.Factory (Flink : 2.0-preview1 API)

Type Parameters:

T - The type of record to write.

All Superinterfaces:

Serializable

Enclosing interface:

HadoopPathBasedBulkWriter<T>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
```
@FunctionalInterface
public static interface HadoopPathBasedBulkWriter.Factory<T>
extends Serializable
```
A factory that creates a HadoopPathBasedBulkWriter.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`HadoopPathBasedBulkWriter<T>`	`create(org.apache.hadoop.fs.Path targetFilePath, org.apache.hadoop.fs.Path inProgressFilePath)`	Creates a path-based writer that writes to the `inProgressPath` first and commits to `targetPath` finally.

- Method Detail
  - create
```
HadoopPathBasedBulkWriter<T> create(org.apache.hadoop.fs.Path targetFilePath,
                                    org.apache.hadoop.fs.Path inProgressFilePath)
                             throws IOException
```
    Creates a path-based writer that writes to the inProgressPath first and commits to targetPath finally.
    
    Parameters:
    
    targetFilePath - The final path to commit to.
    
    inProgressFilePath - The intermediate path to write to before committing.
    
    Returns:
    
    The created writer.
    
    Throws:
    
    IOException