Package | Description |
---|---|
org.apache.flink.connector.datagen.table | |
org.apache.flink.connector.datagen.table.types | |
org.apache.flink.streaming.api.functions.source.datagen |
Modifier and Type | Method and Description |
---|---|
DataGenerator |
DataGeneratorContainer.getGenerator() |
Modifier and Type | Method and Description |
---|---|
static DataGeneratorContainer |
DataGeneratorContainer.of(DataGenerator generator,
ConfigOption<?>... options) |
Constructor and Description |
---|
DataGenTableSource(DataGenerator<?>[] fieldGenerators,
String tableName,
DataType rowDataType,
long rowsPerSecond,
Long numberOfRows) |
Modifier and Type | Class and Description |
---|---|
class |
DataGeneratorMapper<A,B>
Utility for mapping the output of a
DataGenerator . |
class |
DecimalDataRandomGenerator
Generates random
DecimalData values. |
class |
RowDataGenerator
Data generator for Flink's internal
RowData type. |
Constructor and Description |
---|
DataGeneratorMapper(DataGenerator<A> generator,
SerializableFunction<A,B> mapper) |
RowDataGenerator(DataGenerator<?>[] fieldGenerators,
List<String> fieldNames) |
Modifier and Type | Class and Description |
---|---|
class |
RandomGenerator<T>
Random generator.
|
class |
SequenceGenerator<T>
A stateful, re-scalable
DataGenerator that emits each number from a given interval
exactly once, possibly in parallel. |
Modifier and Type | Method and Description |
---|---|
static <T> RandomGenerator<T[]> |
RandomGenerator.arrayGenerator(DataGenerator<T> generator,
int len) |
static <K,V> RandomGenerator<Map<K,V>> |
RandomGenerator.mapGenerator(DataGenerator<K> key,
DataGenerator<V> value,
int size) |
static <K,V> RandomGenerator<Map<K,V>> |
RandomGenerator.mapGenerator(DataGenerator<K> key,
DataGenerator<V> value,
int size) |
Constructor and Description |
---|
DataGeneratorSource(DataGenerator<T> generator)
Creates a source that emits records by
DataGenerator without controlling emit rate. |
DataGeneratorSource(DataGenerator<T> generator,
long rowsPerSecond,
Long numberOfRows)
Creates a source that emits records by
DataGenerator . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.