Uses of Interface
org.apache.flink.connector.file.table.PartitionComputer
-
Packages that use PartitionComputer Package Description org.apache.flink.connector.file.table org.apache.flink.connector.file.table.batch.compact -
-
Uses of PartitionComputer in org.apache.flink.connector.file.table
Classes in org.apache.flink.connector.file.table that implement PartitionComputer Modifier and Type Class Description classRowDataPartitionComputerPartitionComputerforRowData.classRowPartitionComputerPartitionComputerforRow.Methods in org.apache.flink.connector.file.table with parameters of type PartitionComputer Modifier and Type Method Description PartitionWriter<T>PartitionWriterFactory. create(PartitionWriter.Context<T> context, PartitionTempFileManager manager, PartitionComputer<T> computer, PartitionWriter.PartitionWriterListener writerListener)FileSystemOutputFormat.Builder<T>FileSystemOutputFormat.Builder. setPartitionComputer(PartitionComputer<T> computer) -
Uses of PartitionComputer in org.apache.flink.connector.file.table.batch.compact
Constructors in org.apache.flink.connector.file.table.batch.compact with parameters of type PartitionComputer Constructor Description BatchFileWriter(FileSystemFactory fsFactory, org.apache.flink.core.fs.Path tmpPath, String[] partitionColumns, boolean dynamicGrouped, LinkedHashMap<String,String> staticPartitions, OutputFormatFactory<T> formatFactory, PartitionComputer<T> computer, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)
-