Class CaptureCollector
java.lang.Object
org.apache.storm.trident.operation.impl.CaptureCollector
- All Implemented Interfaces:
TridentCollector
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidEmits a tuple to a Stream.voidflush()Flush any buffered tuples (when batching is enabled).voidReports an error.voidsetCollector(TridentCollector coll)
-
Field Details
-
captured
-
-
Constructor Details
-
CaptureCollector
public CaptureCollector()
-
-
Method Details
-
setCollector
-
emit
Description copied from interface:TridentCollectorEmits a tuple to a Stream.- Specified by:
emitin interfaceTridentCollector- Parameters:
values- a list of values of which the tuple will be composed
-
flush
public void flush()Description copied from interface:TridentCollectorFlush any buffered tuples (when batching is enabled).- Specified by:
flushin interfaceTridentCollector
-
reportError
Description 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 interfaceTridentCollector- Parameters:
t- The instance of the error (Throwable) being reported.
-