PartitionWriter (Flink : 2.0-SNAPSHOT API)

Type Parameters:

T - The type of the consumed records.

All Known Implementing Classes:

DynamicPartitionWriter, GroupedPartitionWriter, SingleDirectoryWriter
```
@Internal
public interface PartitionWriter<T>
```
Partition writer to write records with partition.
See SingleDirectoryWriter. See DynamicPartitionWriter. See GroupedPartitionWriter.

Nested Class Summary

Nested Classes
Modifier and Type	Interface	Description
`static class`	`PartitionWriter.Context<T>`	Context for partition writer, provide some information and generation utils.
`static class`	`PartitionWriter.DefaultPartitionWriterListener`	Default implementation for PartitionWriterListener.
`static interface`	`PartitionWriter.PartitionWriterListener`	Listener for partition writer.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type Method Description

void close()
End a transaction.

void write(T in)
Write a record.

- Method Detail
  - write
```
void write(T in)
    throws Exception
```
    Write a record.
    
    Throws:
    
    Exception
  - close
```
void close()
    throws Exception
```
    End a transaction.
    
    Throws:
    
    Exception