HadoopPathBasedBulkWriter (Flink : Formats : Hadoop bulk 1.20.0-cp1 API)

All Superinterfaces:

org.apache.flink.api.common.serialization.BulkWriter<T>
```
@Internal
public interface HadoopPathBasedBulkWriter<T>
extends org.apache.flink.api.common.serialization.BulkWriter<T>
```
Specialized BulkWriter which is expected to write to specified Path.

Nested Class Summary

Nested Classes
Modifier and Type Interface Description

static interface HadoopPathBasedBulkWriter.Factory<T>
A factory that creates a HadoopPathBasedBulkWriter.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`dispose()`	Disposes the writer on failures.
`long`	`getSize()`	Gets the size written by the current writer.

Methods inherited from interface org.apache.flink.api.common.serialization.BulkWriter
addElement, finish, flush

- Method Detail
  - getSize
```
long getSize()
      throws IOException
```
    Gets the size written by the current writer.
    
    Returns:
    
    The size written by the current writer.
    
    Throws:
    
    IOException
  - dispose
```
void dispose()
```
    Disposes the writer on failures. Unlike output-stream-based writers which could handled uniformly by closing the underlying output stream, the path- based writers need to be disposed explicitly.