Uses of Package
org.apache.storm.trident.operation
Package
Description
ElasticSearch Trident example classes.
-
ClassDescriptionConvenience implementation of the
Operation
interface.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionConvenience implementation of the
Operation
interface.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionConvenience implementation of the
Operation
interface.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionConvenience implementation of the
Operation
interface.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionConvenience implementation of the
Operation
interface.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionInterface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
-
ClassDescriptionConvenience implementation of the
Operation
interface.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionConvenience implementation of the
Operation
interface.A function takes in a set of input fields and emits zero or more tuples as output.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionConvenience implementation of the
Operation
interface.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionInterface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
-
ClassDescriptionConvenience implementation of the
Operation
interface.A function takes in a set of input fields and emits zero or more tuples as output.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionThe `Assembly` interface provides a means to encapsulate logic applied to a
Stream
.Represents an operation that accepts a single input argument and returns no result.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.A one-one transformation function. -
ClassDescriptionInterface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
-
ClassDescriptionA function takes in a set of input fields and emits zero or more tuples as output.
-
ClassDescriptionConvenience implementation of the
Operation
interface.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.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionThe `Assembly` interface provides a means to encapsulate logic applied to a
Stream
.Convenience implementation of theOperation
interface.Filters take in a tuple as input and decide whether or not to keep that tuple or not.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionConvenience implementation of the
Operation
interface.Represents an operation that accepts a single input argument and returns no result.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.A one-one transformation function.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionDefault implementation of resources declarer.This interface is implemented by various Trident classes in order to gather and propogate resources that have been set on them.
-
ClassDescriptionA function takes in a set of input fields and emits zero or more tuples as output.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
-
ClassDescriptionInterface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
-
ClassDescriptionConvenience implementation of the
Operation
interface.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionParent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
-
ClassDescriptionConvenience implementation of the
Operation
interface.Filters take in a tuple as input and decide whether or not to keep that tuple or not.A function takes in a set of input fields and emits zero or more tuples as output.Parent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
ClassDescriptionParent interface for Trident `Filter`s and `Function`s.Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).