ICollective

public interface ICollective<T>
extends java.io.Serializable

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`T`	`getOutput()`
`BaseWindowedSink<T>`	`reduce()`
`BaseWindowedSink<T>`	`reduce(ReduceWindowedFunction<T> reduceWindowedFunction)`

BaseWindowedSink<T> reduce(ReduceWindowedFunction<T> reduceWindowedFunction)

Interface ICollective<T>