public class FreshCollector extends Object implements TridentCollector
Constructor and Description |
---|
FreshCollector(TridentContext context) |
Modifier and Type | Method and Description |
---|---|
void |
emit(List<Object> values) |
TridentTuple.Factory |
getOutputFactory() |
void |
reportError(Throwable t) |
void |
setContext(ProcessorContext pc) |
public FreshCollector(TridentContext context)
public void setContext(ProcessorContext pc)
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.