org.apache.flink.table.filesystem

Class FileSystemTableSink.ProjectionBulkFactory

java.lang.Object

org.apache.flink.table.filesystem.FileSystemTableSink.ProjectionBulkFactory

All Implemented Interfaces:

Serializable, BulkWriter.Factory<RowData>

Enclosing class:

FileSystemTableSink

public static class FileSystemTableSink.ProjectionBulkFactory
extends Object
implements BulkWriter.Factory<RowData>

Project row to non-partition fields.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ProjectionBulkFactory(BulkWriter.Factory<RowData> factory, RowDataPartitionComputer computer)

Method Summary

Modifier and Type	Method and Description
BulkWriter<RowData>	create(FSDataOutputStream out) Creates a writer that writes to the given stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProjectionBulkFactory

public ProjectionBulkFactory(BulkWriter.Factory<RowData> factory,
                             RowDataPartitionComputer computer)

Method Detail

create

public BulkWriter<RowData> create(FSDataOutputStream out)
                           throws IOException

Description copied from interface: BulkWriter.Factory

Creates a writer that writes to the given stream.

Specified by:

create in interface BulkWriter.Factory<RowData>

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.