@PublicEvolving public class DataGenTableSourceFactory extends Object implements DynamicTableSourceFactory
DataGenTableSource
in a stream environment.DynamicTableFactory.Context
Modifier and Type | Field and Description |
---|---|
static String |
END |
static String |
FIELDS |
static String |
IDENTIFIER |
static String |
KIND |
static String |
LENGTH |
static String |
MAX |
static String |
MIN |
static String |
RANDOM |
static ConfigOption<Long> |
ROWS_PER_SECOND |
static Long |
ROWS_PER_SECOND_DEFAULT_VALUE |
static String |
SEQUENCE |
static String |
START |
Constructor and Description |
---|
DataGenTableSourceFactory() |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
createDynamicTableSource(DynamicTableFactory.Context context)
Creates a
DynamicTableSource instance from a CatalogTable and additional
context information. |
String |
factoryIdentifier()
Returns a unique identifier among same factory interfaces.
|
Set<ConfigOption<?>> |
optionalOptions()
Returns a set of
ConfigOption that an implementation of this factory consumes in
addition to Factory.requiredOptions() . |
Set<ConfigOption<?>> |
requiredOptions()
Returns a set of
ConfigOption that an implementation of this factory requires in
addition to Factory.optionalOptions() . |
public static final String IDENTIFIER
public static final Long ROWS_PER_SECOND_DEFAULT_VALUE
public static final ConfigOption<Long> ROWS_PER_SECOND
public static final String FIELDS
public static final String KIND
public static final String START
public static final String END
public static final String MIN
public static final String MAX
public static final String LENGTH
public static final String SEQUENCE
public static final String RANDOM
public String factoryIdentifier()
Factory
For consistency, an identifier should be declared as one lower case word (e.g. kafka
). If multiple factories exist for different versions, a version should be appended
using "-" (e.g. kafka-0.10
).
factoryIdentifier
in interface Factory
public Set<ConfigOption<?>> requiredOptions()
Factory
ConfigOption
that an implementation of this factory requires in
addition to Factory.optionalOptions()
.
See the documentation of Factory
for more information.
requiredOptions
in interface Factory
public Set<ConfigOption<?>> optionalOptions()
Factory
ConfigOption
that an implementation of this factory consumes in
addition to Factory.requiredOptions()
.
See the documentation of Factory
for more information.
optionalOptions
in interface Factory
public DynamicTableSource createDynamicTableSource(DynamicTableFactory.Context context)
DynamicTableSourceFactory
DynamicTableSource
instance from a CatalogTable
and additional
context information.
An implementation should perform validation and the discovery of further (nested) factories in this method.
createDynamicTableSource
in interface DynamicTableSourceFactory
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.