org.apache.flink.connector.file.table

Interface PartitionWriter<T>

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 and 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

Modifier and Type	Method and 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