public class FlinkWriteConf
extends java.lang.Object
If a config is set at multiple levels, the following order of precedence is used (top to bottom):
Note this class is NOT meant to be serialized.
Constructor and Description |
---|
FlinkWriteConf(Table table,
java.util.Map<java.lang.String,java.lang.String> writeOptions,
org.apache.flink.configuration.ReadableConfig readableConfig) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
avroCompressionCodec() |
java.lang.String |
avroCompressionLevel() |
java.lang.String |
branch() |
FileFormat |
dataFileFormat() |
DistributionMode |
distributionMode() |
java.lang.String |
orcCompressionCodec() |
java.lang.String |
orcCompressionStrategy() |
boolean |
overwriteMode() |
java.lang.String |
parquetCompressionCodec() |
java.lang.String |
parquetCompressionLevel() |
long |
targetDataFileSize() |
boolean |
upsertMode() |
int |
workerPoolSize() |
java.lang.Integer |
writeParallelism() |
public FlinkWriteConf(Table table, java.util.Map<java.lang.String,java.lang.String> writeOptions, org.apache.flink.configuration.ReadableConfig readableConfig)
public boolean overwriteMode()
public boolean upsertMode()
public FileFormat dataFileFormat()
public long targetDataFileSize()
public java.lang.String parquetCompressionCodec()
public java.lang.String parquetCompressionLevel()
public java.lang.String avroCompressionCodec()
public java.lang.String avroCompressionLevel()
public java.lang.String orcCompressionCodec()
public java.lang.String orcCompressionStrategy()
public DistributionMode distributionMode()
public int workerPoolSize()
public java.lang.String branch()
public java.lang.Integer writeParallelism()