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.
|
Modifier and Type | Class and Description |
---|---|
class |
BlockingIncrementingMapFunction
A map function that increments values by one.
|
Modifier and Type | Class and Description |
---|---|
static class |
KMeans.SelectNearestCenter
Determines the closest cluster center for a data point.
|
Modifier and Type | Class and Description |
---|---|
class |
RollingAdditionMapper
A
RichMapFunction that continuously outputs the current total frequency count of a key. |
Modifier and Type | Class and Description |
---|---|
class |
FailureMapper<T>
This mapper simulates failure by throwing exceptions.
|
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 ArtificialStateBuilder s. |
Modifier and Type | Class and Description |
---|---|
static class |
StatefulStreamingJob.MyStatefulFunction
A stateful
RichMapFunction that keeps the required types of state. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.