File tree 2 files changed +4
-2
lines changed
src/main/java/io/numaproj/numaflow/accumulator
2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change 9
9
import io .numaproj .numaflow .accumulator .v1 .AccumulatorOuterClass ;
10
10
import lombok .AllArgsConstructor ;
11
11
12
+ /**
13
+ * Accumulator Actor is responsible for invoking accumulator handle and handling exceptions.
14
+ */
12
15
@ AllArgsConstructor
13
16
public class AccumulatorActor extends AbstractActor {
14
17
private Accumulator accumulator ;
Original file line number Diff line number Diff line change @@ -11,8 +11,7 @@ public abstract class Accumulator {
11
11
*
12
12
* @param datum current message to be processed by the accumulator
13
13
* @param outputStream observer for sending the output {@link Message} to the
14
- * output
15
- * stream.
14
+ * output stream.
16
15
*/
17
16
public abstract void processMessage (
18
17
Datum datum ,
You can’t perform that action at this time.
0 commit comments