storm.trident.planner.processor

Class AppendCollector

java.lang.Object

storm.trident.planner.processor.AppendCollector

All Implemented Interfaces:

TridentCollector

public class AppendCollector
extends Object
implements TridentCollector

Constructor Summary

Constructors

Constructor and Description
AppendCollector(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, TridentTuple t)

Methods inherited from class java.lang.Object

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

Constructor Detail

AppendCollector

public AppendCollector(TridentContext context)

Method Detail

setContext

public void setContext(ProcessorContext pc,
              TridentTuple t)

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()