storm.trident.planner.processor

Class FreshCollector

java.lang.Object

storm.trident.planner.processor.FreshCollector

All Implemented Interfaces:

TridentCollector

public class FreshCollector
extends Object
implements TridentCollector

Constructor Summary

Constructors

Constructor and Description
FreshCollector(TridentContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	emit(List<Object> values)
TridentTuple.Factory	getOutputFactory()
void	reportError(Throwable t)
void	setContext(ProcessorContext pc)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FreshCollector

public FreshCollector(TridentContext context)

Method Detail

setContext

public void setContext(ProcessorContext pc)

emit

public void emit(List<Object> values)

Specified by:

emit in interface TridentCollector

reportError

public void reportError(Throwable t)

Specified by:

reportError in interface TridentCollector

getOutputFactory

public TridentTuple.Factory getOutputFactory()