| Class and Description |
|---|
| FlatMapFunction
A function that accepts one argument and returns an
Iterable of elements as its result. |
| Function
Represents a function that accepts one argument and produces a result.
|
| Operation
The parent interface for any kind of streaming operation.
|
| PairFunction
A function that accepts an argument and produces a key-value Pair.
|
| Predicate
Represents a predicate (boolean-valued function) of a value.
|
| Class and Description |
|---|
| BiFunction
a function that accepts two arguments and produces a result.
|
| CombinerAggregator
Interface for aggregating values.
|
| Consumer
Represents an operation that accepts a single input argument and returns no result.
|
| FlatMapFunction
A function that accepts one argument and returns an
Iterable of elements as its result. |
| Function
Represents a function that accepts one argument and produces a result.
|
| PairFlatMapFunction |
| PairFunction
A function that accepts an argument and produces a key-value Pair.
|
| Predicate
Represents a predicate (boolean-valued function) of a value.
|
| Reducer
The
Reducer performs an operation on two values of the same type producing a result of the same type. |
| StateUpdater
Interface for updating state.
|
| ValueJoiner
An interface for joining two values to produce a result.
|
| Class and Description |
|---|
| BiFunction
a function that accepts two arguments and produces a result.
|
| CombinerAggregator
Interface for aggregating values.
|
| Consumer
Represents an operation that accepts a single input argument and returns no result.
|
| FlatMapFunction
A function that accepts one argument and returns an
Iterable of elements as its result. |
| Function
Represents a function that accepts one argument and produces a result.
|
| Operation
The parent interface for any kind of streaming operation.
|
| StateUpdater
Interface for updating state.
|
| ValueJoiner
An interface for joining two values to produce a result.
|
| Class and Description |
|---|
| CombinerAggregator
Interface for aggregating values.
|
| Operation
The parent interface for any kind of streaming operation.
|
| Class and Description |
|---|
| Function
Represents a function that accepts one argument and produces a result.
|
| Operation
The parent interface for any kind of streaming operation.
|
| PairFunction
A function that accepts an argument and produces a key-value Pair.
|
| Class and Description |
|---|
| CombinerAggregator
Interface for aggregating values.
|
| Consumer
Represents an operation that accepts a single input argument and returns no result.
|
| FlatMapFunction
A function that accepts one argument and returns an
Iterable of elements as its result. |
| Function
Represents a function that accepts one argument and produces a result.
|
| Predicate
Represents a predicate (boolean-valued function) of a value.
|
| Reducer
The
Reducer performs an operation on two values of the same type producing a result of the same type. |
| StateUpdater
Interface for updating state.
|
| ValueJoiner
An interface for joining two values to produce a result.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.