Serialized Form

Package org.apache.flink.streaming.examples.iteration

Class org.apache.flink.streaming.examples.iteration.IterateExample.InputMap extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.examples.iteration.IterateExample.OutputMap extends Object implements Serializable

serialVersionUID:

1L

Class org.apache.flink.streaming.examples.iteration.IterateExample.Step extends org.apache.flink.streaming.api.functions.ProcessFunction<org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer>,org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer>> implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.examples.sideoutput

Class org.apache.flink.streaming.examples.sideoutput.SideOutputExample.Tokenizer extends org.apache.flink.streaming.api.functions.ProcessFunction<String,org.apache.flink.api.java.tuple.Tuple2<String,Integer>> implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.examples.statemachine.dfa

Class org.apache.flink.streaming.examples.statemachine.dfa.Transition extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

eventType

EventType eventType

The event that triggers the transition.

prob

float prob

The probability of the transition.

targetState

State targetState

The target state after the transition.

Package org.apache.flink.streaming.examples.statemachine.generator

Class org.apache.flink.streaming.examples.statemachine.generator.EventsGeneratorFunction extends Object implements Serializable

Serialized Fields

errorProbability

double errorProbability

max

int max

min

int min

Package org.apache.flink.streaming.examples.statemachine.kafka

Class org.apache.flink.streaming.examples.statemachine.kafka.EventDeSerializationSchema extends Object implements Serializable

serialVersionUID:

1L

Package org.apache.flink.streaming.examples.utils

Class org.apache.flink.streaming.examples.utils.ThrottledIterator extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

lastBatchCheckTime

long lastBatchCheckTime

num

long num

sleepBatchSize

long sleepBatchSize

sleepBatchTime

long sleepBatchTime

source

Iterator<T> source

Package org.apache.flink.streaming.examples.windowing.util

Class org.apache.flink.streaming.examples.windowing.util.CarGeneratorFunction extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

distances

double[] distances

lastUpdate

long[] lastUpdate

nextCar

int nextCar

rand

Random rand

speeds

int[] speeds

Package org.apache.flink.streaming.examples.wordcount

Class org.apache.flink.streaming.examples.wordcount.WordCount.Tokenizer extends Object implements Serializable

Package org.apache.flink.streaming.examples.wordcount.util

Class org.apache.flink.streaming.examples.wordcount.util.CLI extends org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters implements Serializable

Serialized Fields

discoveryInterval

java.time.Duration discoveryInterval

executionMode

org.apache.flink.api.common.RuntimeExecutionMode executionMode

inputs

org.apache.flink.core.fs.Path[] inputs

output

org.apache.flink.core.fs.Path output

params

org.apache.flink.api.java.utils.MultipleParameterTool params