Uses of Class org.apache.flink.api.common.functions.RichMapFunction (Flink : 2.0-SNAPSHOT API)

Packages that use RichMapFunction
Package Description

org.apache.flink.streaming.tests

org.apache.flink.streaming.tests.artificialstate

org.apache.flink.test

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

Subclasses of RichMapFunction in org.apache.flink.streaming.tests
Modifier and Type Class Description

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	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 `ArtificialStateBuilder`s.

Uses of RichMapFunction in org.apache.flink.test

Subclasses of RichMapFunction in org.apache.flink.test
Modifier and Type	Class	Description
`static class`	`StatefulStreamingJob.MyStatefulFunction`	A stateful `RichMapFunction` that keeps the required types of state.