storm.trident.planner.processor
Class AppendCollector

java.lang.Object
  storm.trident.planner.processor.AppendCollector

All Implemented Interfaces:

TridentCollector

public class AppendCollector
extends java.lang.Object
implements TridentCollector

Constructor Summary

AppendCollector(TridentContext context)

Method Summary

void	emit(java.util.List<java.lang.Object> values)
TridentTuple.Factory	getOutputFactory()
void	reportError(java.lang.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(java.util.List<java.lang.Object> values)

Specified by:

emit in interface TridentCollector

reportError

public void reportError(java.lang.Throwable t)

Specified by:

reportError in interface TridentCollector

getOutputFactory

public TridentTuple.Factory getOutputFactory()