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 |
EventDeSerializationSchema.deserialize(byte[] message) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Event> |
EventDeSerializationSchema.getProducedType() |
Modifier and Type | Method and Description |
---|---|
boolean |
EventDeSerializationSchema.isEndOfStream(Event nextElement) |
byte[] |
EventDeSerializationSchema.serialize(Event evt) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.