Uses of Package
org.apache.storm.trident.operation
-
Classes in org.apache.storm.trident.operation used by org.apache.storm.hdfs.trident Class Description BaseOperation Convenience implementation of theOperationinterface.Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.hive.trident Class Description BaseOperation Convenience implementation of theOperationinterface.Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.jdbc.trident.state Class Description BaseOperation Convenience implementation of theOperationinterface.EachOperation Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.jms.trident Class Description BaseOperation Convenience implementation of theOperationinterface.Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.kafka.spout.trident Class Description TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.kafka.trident Class Description BaseOperation Convenience implementation of theOperationinterface.Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.redis.trident Class Description BaseFunction BaseOperation Convenience implementation of theOperationinterface.EachOperation Function A function takes in a set of input fields and emits zero or more tuples as output.Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.redis.trident.state Class Description BaseOperation Convenience implementation of theOperationinterface.EachOperation Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.starter.spout Class Description TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.starter.trident Class Description BaseFunction BaseOperation Convenience implementation of theOperationinterface.CombinerAggregator EachOperation Function A function takes in a set of input fields and emits zero or more tuples as output.Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident Class Description Aggregator Assembly The `Assembly` interface provides a means to encapsulate logic applied to aStream.CombinerAggregator Consumer Represents an operation that accepts a single input argument and returns no result.DefaultResourceDeclarer Default implementation of resources declarer.Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.FlatMapFunction A one to many transformation function.Function A function takes in a set of input fields and emits zero or more tuples as output.GroupedMultiReducer MapFunction A one-one transformation function.MultiReducer ReducerAggregator -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.drpc Class Description MultiReducer TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).TridentMultiReducerContext -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.fluent Class Description Aggregator CombinerAggregator Function A function takes in a set of input fields and emits zero or more tuples as output.ReducerAggregator -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.operation Class Description Aggregator BaseOperation Convenience implementation of theOperationinterface.DefaultResourceDeclarer Default implementation of resources declarer.EachOperation Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.FlatMapFunction A one to many transformation function.Function A function takes in a set of input fields and emits zero or more tuples as output.ITridentResource This interface is implemented by various Trident classes in order to gather and propogate resources that have been set on them.MapFunction A one-one transformation function.MultiReducer Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).TridentMultiReducerContext TridentOperationContext -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.operation.builtin Class Description Aggregator Assembly The `Assembly` interface provides a means to encapsulate logic applied to aStream.BaseAggregator BaseFilter BaseOperation Convenience implementation of theOperationinterface.CombinerAggregator EachOperation Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).TridentOperationContext -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.operation.impl Class Description Aggregator BaseOperation Convenience implementation of theOperationinterface.CombinerAggregator Consumer Represents an operation that accepts a single input argument and returns no result.EachOperation Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.FlatMapFunction A one to many transformation function.Function A function takes in a set of input fields and emits zero or more tuples as output.GroupedMultiReducer MapFunction A one-one transformation function.MultiReducer Operation Parent interface for Trident `Filter`s and `Function`s.ReducerAggregator TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).TridentMultiReducerContext TridentOperationContext -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.planner Class Description DefaultResourceDeclarer Default implementation of resources declarer.ITridentResource This interface is implemented by various Trident classes in order to gather and propogate resources that have been set on them. -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.planner.processor Class Description Aggregator Function A function takes in a set of input fields and emits zero or more tuples as output.MultiReducer TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.spout Class Description TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.state Class Description BaseOperation Convenience implementation of theOperationinterface.CombinerAggregator EachOperation Operation Parent interface for Trident `Filter`s and `Function`s.ReducerAggregator TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.state.map Class Description CombinerAggregator Operation Parent interface for Trident `Filter`s and `Function`s.ReducerAggregator TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).TridentOperationContext -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.testing Class Description Aggregator BaseAggregator BaseFilter BaseFunction BaseOperation Convenience implementation of theOperationinterface.EachOperation Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.Function A function takes in a set of input fields and emits zero or more tuples as output.Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI). -
Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.windowing Class Description Aggregator Operation Parent interface for Trident `Filter`s and `Function`s.TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).TridentOperationContext