Package | Description |
---|---|
org.apache.flink.streaming.api.functions.source.datagen |
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. |
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)
Creates a source that emits records by
DataGenerator . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.