Package org.apache.iceberg.flink.sink.dynamic

Class FlinkDynamicSinkConf

java.lang.Object

org.apache.iceberg.flink.sink.dynamic.FlinkDynamicSinkConf

@Internal
public class FlinkDynamicSinkConf
extends Object

A class for common Dynamic Iceberg sink configs for Flink writes.

If a config is set at multiple levels, the following order of precedence is used (top to bottom):

1. Write options
2. Flink ReadableConfig
3. Default values

The most specific value is set in write options and takes precedence over all other configs. If no write option is provided, this class checks the flink configuration for any overrides. If no applicable value is found in the write options, this class uses the default values.

Method Summary

Methods inherited from class java.lang.Object

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