public interface ReducerAggregator<T> extends Serializable
Modifier and Type | Method and Description |
---|---|
T |
init() |
T |
reduce(T curr,
TridentTuple tuple) |
T init()
T reduce(T curr, TridentTuple tuple)
Copyright © 2022 The Apache Software Foundation. All rights reserved.