Package org.apache.iceberg.flink.sink

Class SinkUtil

java.lang.Object

org.apache.iceberg.flink.sink.SinkUtil

@Internal
public class SinkUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FLINK_JOB_ID
static final String	MAX_COMMITTED_CHECKPOINT_ID
static final String	OPERATOR_ID

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	writeProperties(FileFormat format, FlinkWriteConf conf, Table table)	Based on the FileFormat overwrites the table level compression properties for the table write.

Methods inherited from class java.lang.Object

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

Field Details

FLINK_JOB_ID

public static final String FLINK_JOB_ID

See Also:

• Constant Field Values

OPERATOR_ID

public static final String OPERATOR_ID

See Also:

• Constant Field Values

MAX_COMMITTED_CHECKPOINT_ID

public static final String MAX_COMMITTED_CHECKPOINT_ID

See Also:

• Constant Field Values

Method Details

writeProperties

public static Map<String,String> writeProperties(FileFormat format,
 FlinkWriteConf conf,
 @Nullable
 Table table)

Based on the FileFormat overwrites the table level compression properties for the table write.

Parameters:

format - The FileFormat to use

conf - The write configuration

table - The table to get the table level settings

Returns:

The properties to use for writing