BulkWriter.Factory (Flink : Core 1.18.1-cp1 API)

Type Parameters:

T - The type of record to write.

All Superinterfaces:

Serializable

Enclosing interface:

BulkWriter<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 BulkWriter.Factory<T>
extends Serializable
```
A factory that creates a BulkWriter.

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  BulkWriter<T> create(FSDataOutputStream out)
  Creates a writer that writes to the given stream.

- Method Detail
  - create
```
BulkWriter<T> create(FSDataOutputStream out)
              throws IOException
```
    Creates a writer that writes to the given stream.
    
    Parameters:
    
    out - The output stream to write the encoded data to.
    
    Throws:
    
    IOException - Thrown if the writer cannot be opened, or if the output stream throws an exception.