Package org.apache.flink.connector.datagen.table

Class DataGenConnectorOptions

java.lang.Object

org.apache.flink.connector.datagen.table.DataGenConnectorOptions

@PublicEvolving
public class DataGenConnectorOptions
extends Object

Options for the DataGen connector.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<String>	FIELD_END	Placeholder ConfigOption.
static org.apache.flink.configuration.ConfigOption<String>	FIELD_KIND	Placeholder ConfigOption.
static org.apache.flink.configuration.ConfigOption<Integer>	FIELD_LENGTH	Placeholder ConfigOption.
static org.apache.flink.configuration.ConfigOption<String>	FIELD_MAX	Placeholder ConfigOption.
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	FIELD_MAX_PAST	Placeholder ConfigOption.
static org.apache.flink.configuration.ConfigOption<String>	FIELD_MIN	Placeholder ConfigOption.
static org.apache.flink.configuration.ConfigOption<Float>	FIELD_NULL_RATE	Placeholder ConfigOption.
static org.apache.flink.configuration.ConfigOption<String>	FIELD_START	Placeholder ConfigOption.
static org.apache.flink.configuration.ConfigOption<Boolean>	FIELD_VAR_LEN	Placeholder ConfigOption.
static org.apache.flink.configuration.ConfigOption<Long>	NUMBER_OF_ROWS
static org.apache.flink.configuration.ConfigOption<Long>	ROWS_PER_SECOND
static org.apache.flink.configuration.ConfigOption<Integer>	SOURCE_PARALLELISM

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

ROWS_PER_SECOND

public static final org.apache.flink.configuration.ConfigOption<Long> ROWS_PER_SECOND

NUMBER_OF_ROWS

public static final org.apache.flink.configuration.ConfigOption<Long> NUMBER_OF_ROWS

SOURCE_PARALLELISM

public static final org.apache.flink.configuration.ConfigOption<Integer> SOURCE_PARALLELISM

FIELD_KIND

public static final org.apache.flink.configuration.ConfigOption<String> FIELD_KIND

Placeholder ConfigOption. Not used for retrieving values.

FIELD_MIN

public static final org.apache.flink.configuration.ConfigOption<String> FIELD_MIN

Placeholder ConfigOption. Not used for retrieving values.

FIELD_MAX

public static final org.apache.flink.configuration.ConfigOption<String> FIELD_MAX

Placeholder ConfigOption. Not used for retrieving values.

FIELD_MAX_PAST

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> FIELD_MAX_PAST

Placeholder ConfigOption. Not used for retrieving values.

FIELD_LENGTH

public static final org.apache.flink.configuration.ConfigOption<Integer> FIELD_LENGTH

Placeholder ConfigOption. Not used for retrieving values.

FIELD_START

public static final org.apache.flink.configuration.ConfigOption<String> FIELD_START

Placeholder ConfigOption. Not used for retrieving values.

FIELD_END

public static final org.apache.flink.configuration.ConfigOption<String> FIELD_END

Placeholder ConfigOption. Not used for retrieving values.

FIELD_NULL_RATE

public static final org.apache.flink.configuration.ConfigOption<Float> FIELD_NULL_RATE

Placeholder ConfigOption. Not used for retrieving values.

FIELD_VAR_LEN

public static final org.apache.flink.configuration.ConfigOption<Boolean> FIELD_VAR_LEN

Placeholder ConfigOption. Not used for retrieving values.