Class AppendCollector
java.lang.Object
org.apache.storm.trident.planner.processor.AppendCollector
- All Implemented Interfaces:
- TridentCollector
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidEmits a tuple to a Stream.voidflush()Flush any buffered tuples (when batching is enabled).voidReports an error.void
- 
Constructor Details- 
AppendCollector
 
- 
- 
Method Details- 
setContext
- 
emitDescription copied from interface:TridentCollectorEmits a tuple to a Stream.- Specified by:
- emitin interface- TridentCollector
- Parameters:
- values- a list of values of which the tuple will be composed
 
- 
flushpublic void flush()Description copied from interface:TridentCollectorFlush any buffered tuples (when batching is enabled).- Specified by:
- flushin interface- TridentCollector
 
- 
reportErrorDescription copied from interface:TridentCollectorReports an error. The corresponding stack trace will be visible in the Storm UI.Note that calling this method does not alter the processing of a batch. To explicitly fail a batch and trigger a replay, components should throw FailedException.- Specified by:
- reportErrorin interface- TridentCollector
- Parameters:
- t- The instance of the error (Throwable) being reported.
 
- 
getOutputFactory
 
-