Interface | Description |
---|---|
OperatorWrapper<T,R> |
Wrappers for the given operator factory.
|
Class | Description |
---|---|
AbstractWrapperOperator<T> |
The base class of all the wrapper operators.
|
HeadOperator |
The head operator unions the initialized variable stream and the feedback stream, synchronize the
epoch watermark (round) and taking care of the checkpoints.
|
HeadOperatorFactory |
The Factory for the
HeadOperator . |
InputOperator<T> |
Input operator that wraps the user record into
IterationRecord . |
OperatorStateUtils |
Utility to deal with the states inside the operator.
|
OperatorUtils |
Utility class for operators.
|
OutputOperator<T> |
Output operator that unwraps
IterationRecord into user record, and desert all the event
records. |
ReplayOperator<T> |
Replays the data received in the round 0 in the following round.
|
TailOperator |
The tail operators is attached after each feedback operator to increment the round of each
record.
|
WrapperOperatorFactory<OUT> |
The factory to create the subclass of
AbstractWrapperOperator . |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.