Package org.apache.iceberg.flink

Class FlinkConfParser.ConfParser<ThisT,T>

java.lang.Object

org.apache.iceberg.flink.FlinkConfParser.ConfParser<ThisT,T>

Direct Known Subclasses:

FlinkConfParser.BooleanConfParser, FlinkConfParser.DoubleConfParser, FlinkConfParser.DurationConfParser, FlinkConfParser.EnumConfParser, FlinkConfParser.IntConfParser, FlinkConfParser.LongConfParser, FlinkConfParser.StringConfParser

Enclosing class:

FlinkConfParser

public abstract class FlinkConfParser.ConfParser<ThisT,T>
extends Object

Constructor Summary

Constructors

Constructor	Description
ConfParser()

Method Summary

Modifier and Type	Method	Description
ThisT	flinkConfig(org.apache.flink.configuration.ConfigOption<T> newConfigOption)
ThisT	option(String name)
protected T	parse(Function<String,T> conversion, T defaultValue)
protected abstract ThisT	self()
ThisT	tableProperty(String name)

Methods inherited from class java.lang.Object

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

Constructor Details

ConfParser

public ConfParser()

Method Details

self

protected abstract ThisT self()

option

public ThisT option(String name)

flinkConfig

public ThisT flinkConfig(org.apache.flink.configuration.ConfigOption<T> newConfigOption)

tableProperty

public ThisT tableProperty(String name)

parse

protected T parse(Function<String,T> conversion,
 T defaultValue)