Interface | Description |
---|---|
BiFunction<T,U,R> |
a function that accepts two arguments and produces a result.
|
CombinerAggregator<T,A,R> |
Interface for aggregating values.
|
Consumer<T> |
Represents an operation that accepts a single input argument and returns no result.
|
FlatMapFunction<T,R> |
A function that accepts one argument and returns an
Iterable of elements as its result. |
Function<T,R> |
Represents a function that accepts one argument and produces a result.
|
Operation |
The parent interface for any kind of streaming operation.
|
PairFlatMapFunction<T,K,V> | |
PairFunction<T,K,V> |
A function that accepts an argument and produces a key-value Pair.
|
Predicate<T> |
Represents a predicate (boolean-valued function) of a value.
|
Reducer<T> |
The
Reducer performs an operation on two values of the same type producing a result of the same type. |
StateUpdater<T,S> |
Interface for updating state.
|
ValueJoiner<V1,V2,R> |
An interface for joining two values to produce a result.
|
Class | Description |
---|---|
IdentityFunction<T> |
A
Function that returns the input argument itself as the result. |
PairValueJoiner<V1,V2> |
A
ValueJoiner that joins two values to produce a Pair of the two values as the result. |
PrintConsumer<T> |
A consumer that prints the input to stdout.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.