Class FreshCollector
java.lang.Object
org.apache.storm.trident.planner.processor.FreshCollector
- All Implemented Interfaces:
TridentCollector
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Emits a tuple to a Stream.void
flush()
Flush any buffered tuples (when batching is enabled).void
Reports an error.void
-
Constructor Details
-
FreshCollector
-
-
Method Details
-
setContext
-
emit
Description copied from interface:TridentCollector
Emits a tuple to a Stream.- Specified by:
emit
in interfaceTridentCollector
- Parameters:
values
- a list of values of which the tuple will be composed
-
flush
public void flush()Description copied from interface:TridentCollector
Flush any buffered tuples (when batching is enabled).- Specified by:
flush
in interfaceTridentCollector
-
reportError
Description copied from interface:TridentCollector
Reports 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:
reportError
in interfaceTridentCollector
- Parameters:
t
- The instance of the error (Throwable) being reported.
-
getOutputFactory
-