public class GroupCollector extends Object implements TridentCollector
Constructor and Description |
---|
GroupCollector(TridentCollector collector,
ComboList.Factory factory) |
public GroupCollector(TridentCollector collector, ComboList.Factory factory)
public void emit(List<Object> values)
emit
in interface TridentCollector
public void reportError(Throwable t)
reportError
in interface TridentCollector
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.