public interface GroupByCollectorProcessor<InTuple,OutTuple> extends Serializable
Modifier and Type | Method and Description |
---|---|
Runnable |
accumulate(InTuple input) |
Collection<OutTuple> |
finish() |
Collection<OutTuple> finish()
Copyright © 2006–2021 JBoss by Red Hat. All rights reserved.