Uses of Class
org.apache.flink.api.common.functions.RichMapFunction

Packages that use RichMapFunction

Package	Description
org.apache.flink.api.java.operators.translation
org.apache.flink.examples.java.clustering
org.apache.flink.examples.java.ml
org.apache.flink.streaming.kafka.test.base
org.apache.flink.streaming.tests
org.apache.flink.streaming.tests.artificialstate
org.apache.flink.test

Uses of RichMapFunction in org.apache.flink.api.java.operators.translation

Subclasses of RichMapFunction in org.apache.flink.api.java.operators.translation

Modifier and Type	Class and Description
class	KeyExtractingMapper<T,K> Mapper that extracts keys.
class	KeyRemovingMapper<T,K> Mapper that removes keys.
class	TwoKeyExtractingMapper<T,K1,K2> Mapper that extracts two keys of a value.

Uses of RichMapFunction in org.apache.flink.examples.java.clustering

Subclasses of RichMapFunction in org.apache.flink.examples.java.clustering

Modifier and Type	Class and Description
static class	KMeans.SelectNearestCenter Determines the closest cluster center for a data point.

Uses of RichMapFunction in org.apache.flink.examples.java.ml

Subclasses of RichMapFunction in org.apache.flink.examples.java.ml

Modifier and Type	Class and Description
static class	LinearRegression.SubUpdate Compute a single BGD type update for every parameters.

Uses of RichMapFunction in org.apache.flink.streaming.kafka.test.base

Subclasses of RichMapFunction in org.apache.flink.streaming.kafka.test.base

Modifier and Type	Class and Description
class	RollingAdditionMapper A RichMapFunction that continuously outputs the current total frequency count of a key.

Uses of RichMapFunction in org.apache.flink.streaming.tests

Subclasses of RichMapFunction in org.apache.flink.streaming.tests

Modifier and Type	Class and Description
static class	BucketingSinkTestProgram.SubtractingMapper Subtracts the timestamp of the previous element from the current element.
class	FailureMapper<T> This mapper simulates failure by throwing exceptions.

Uses of RichMapFunction in org.apache.flink.streaming.tests.artificialstate

Subclasses of RichMapFunction in org.apache.flink.streaming.tests.artificialstate

Modifier and Type	Class and Description
class	ArtificalOperatorStateMapper<IN,OUT> A self-verifiable RichMapFunction used to verify checkpointing and restore semantics for various kinds of operator state.
class	ArtificialKeyedStateMapper<IN,OUT> A generic, stateful MapFunction that allows specifying what states to maintain based on a provided list of ArtificialStateBuilders.

Uses of RichMapFunction in org.apache.flink.test

Subclasses of RichMapFunction in org.apache.flink.test

Modifier and Type	Class and Description
static class	StatefulStreamingJob.MyStatefulFunction A stateful RichMapFunction that keeps the required types of state.