org.apache.flink.connector.file.table

Interface PartitionWriterFactory<T>

All Superinterfaces:

Serializable

@Internal
public interface PartitionWriterFactory<T>
extends Serializable

Factory of PartitionWriter to avoid virtual function calls.

Method Summary

Modifier and Type	Method and Description
PartitionWriter<T>	create(PartitionWriter.Context<T> context, PartitionTempFileManager manager, PartitionComputer<T> computer, PartitionWriter.PartitionWriterListener writerListener)
static <T> PartitionWriterFactory<T>	get(boolean dynamicPartition, boolean grouped, LinkedHashMap<String,String> staticPartitions) Util for get a PartitionWriterFactory.

Method Detail

create

PartitionWriter<T> create(PartitionWriter.Context<T> context,
                          PartitionTempFileManager manager,
                          PartitionComputer<T> computer,
                          PartitionWriter.PartitionWriterListener writerListener)
                   throws Exception

Throws:

Exception

get

static <T> PartitionWriterFactory<T> get(boolean dynamicPartition,
                                         boolean grouped,
                                         LinkedHashMap<String,String> staticPartitions)

Util for get a PartitionWriterFactory.