Package org.apache.iceberg.flink

Class FlinkConfParser

java.lang.Object

org.apache.iceberg.flink.FlinkConfParser

@Internal
public class FlinkConfParser
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	FlinkConfParser.BooleanConfParser
class	FlinkConfParser.ConfParser<ThisT,T>
class	FlinkConfParser.DoubleConfParser
class	FlinkConfParser.DurationConfParser
class	FlinkConfParser.EnumConfParser<E extends Enum<E>>
class	FlinkConfParser.IntConfParser
class	FlinkConfParser.LongConfParser
class	FlinkConfParser.StringConfParser

Constructor Summary

Constructors

Constructor	Description
FlinkConfParser(Table table, Map<String,String> options, org.apache.flink.configuration.ReadableConfig readableConfig)

Method Summary

Modifier and Type	Method	Description
FlinkConfParser.BooleanConfParser	booleanConf()
FlinkConfParser.DoubleConfParser	doubleConf()
FlinkConfParser.DurationConfParser	durationConf()
<E extends Enum<E>> FlinkConfParser.EnumConfParser<E>	enumConfParser(Class<E> enumClass)
FlinkConfParser.IntConfParser	intConf()
FlinkConfParser.LongConfParser	longConf()
FlinkConfParser.StringConfParser	stringConf()

Methods inherited from class java.lang.Object

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

Constructor Details

FlinkConfParser

public FlinkConfParser(Table table,
 Map<String,String> options,
 org.apache.flink.configuration.ReadableConfig readableConfig)

Method Details

booleanConf

public FlinkConfParser.BooleanConfParser booleanConf()

intConf

public FlinkConfParser.IntConfParser intConf()

longConf

public FlinkConfParser.LongConfParser longConf()

doubleConf

public FlinkConfParser.DoubleConfParser doubleConf()

enumConfParser

public <E extends Enum<E>>
FlinkConfParser.EnumConfParser<E> enumConfParser(Class<E> enumClass)

stringConf

public FlinkConfParser.StringConfParser stringConf()

durationConf

public FlinkConfParser.DurationConfParser durationConf()