Package org.apache.storm.trident.operation
package org.apache.storm.trident.operation
-
ClassDescriptionAggregator<T>The `Assembly` interface provides a means to encapsulate logic applied to a
Stream.Convenience implementation of theOperationinterface.Represents an operation that accepts a single input argument and returns no result.DefaultResourceDeclarer<T extends DefaultResourceDeclarer>Default implementation of resources declarer.Filters take in a tuple as input and decide whether or not to keep that tuple or not.A one to many transformation function.A function takes in a set of input fields and emits zero or more tuples as output.This interface is implemented by various Trident classes in order to gather and propogate resources that have been set on them.A one-one transformation function.MultiReducer<T>Parent interface for Trident `Filter`s and `Function`s.A one to many transformation function which is aware of Operation (lifecycle of the Trident component).A one-one transformation function which is aware of Operation (lifecycle of the Trident component).Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).