Package | Description |
---|---|
org.apache.flink.streaming.examples.statemachine.generator | |
org.apache.flink.streaming.examples.statemachine.kafka |
Modifier and Type | Method and Description |
---|---|
Event |
EventsGenerator.next(int minIp,
int maxIp)
Creates a new random event.
|
Event |
EventsGenerator.nextInvalid()
Creates an event for an illegal state transition of one of the internal state machines.
|
Modifier and Type | Method and Description |
---|---|
void |
EventsGeneratorSource.run(SourceFunction.SourceContext<Event> sourceContext) |
Modifier and Type | Method and Description |
---|---|
Event |
EventDeSerializer.deserialize(byte[] message) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Event> |
EventDeSerializer.getProducedType() |
Modifier and Type | Method and Description |
---|---|
boolean |
EventDeSerializer.isEndOfStream(Event nextElement) |
byte[] |
EventDeSerializer.serialize(Event evt) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.