public class AppendCollector extends Object implements TridentCollector
Constructor and Description |
---|
AppendCollector(TridentContext context) |
Modifier and Type | Method and Description |
---|---|
void |
emit(List<Object> values) |
TridentTuple.Factory |
getOutputFactory() |
void |
reportError(Throwable t) |
void |
setContext(ProcessorContext pc,
TridentTuple t) |
public AppendCollector(TridentContext context)
public void setContext(ProcessorContext pc, TridentTuple t)
public void emit(List<Object> values)
emit
in interface TridentCollector
public void reportError(Throwable t)
reportError
in interface TridentCollector
public TridentTuple.Factory getOutputFactory()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.