Uses of Class
org.apache.storm.trident.operation.TridentOperationContext
Package
Description
-
Uses of TridentOperationContext in org.apache.storm.trident.operation
Modifier and TypeMethodDescriptionvoid
BaseOperation.prepare
(Map<String, Object> conf, TridentOperationContext context) No-op implementation.void
Operation.prepare
(Map<String, Object> conf, TridentOperationContext context) Called when the `Operation` is first initialized.ModifierConstructorDescriptionTridentOperationContext
(TridentOperationContext parent, TridentTuple.Factory factory) -
Uses of TridentOperationContext in org.apache.storm.trident.operation.builtin
Modifier and TypeMethodDescriptionvoid
Negate.prepare
(Map<String, Object> conf, TridentOperationContext context) -
Uses of TridentOperationContext in org.apache.storm.trident.operation.impl
Modifier and TypeMethodDescriptionvoid
ChainedAggregatorImpl.prepare
(Map<String, Object> conf, TridentOperationContext context) void
CombinerAggregatorCombineImpl.prepare
(Map<String, Object> conf, TridentOperationContext context) void
CombinerAggregatorInitImpl.prepare
(Map<String, Object> conf, TridentOperationContext context) void
CombinerAggStateUpdater.prepare
(Map<String, Object> conf, TridentOperationContext context) void
FilterExecutor.prepare
(Map<String, Object> conf, TridentOperationContext context) void
FlatMapFunctionExecutor.prepare
(Map<String, Object> conf, TridentOperationContext context) void
GroupedAggregator.prepare
(Map<String, Object> conf, TridentOperationContext context) void
MapFunctionExecutor.prepare
(Map<String, Object> conf, TridentOperationContext context) void
ReducerAggregatorImpl.prepare
(Map<String, Object> conf, TridentOperationContext context) void
ReducerAggStateUpdater.prepare
(Map<String, Object> conf, TridentOperationContext context) void
SingleEmitAggregator.prepare
(Map<String, Object> conf, TridentOperationContext context) void
TrueFilter.prepare
(Map<String, Object> conf, TridentOperationContext context) -
Uses of TridentOperationContext in org.apache.storm.trident.state.map
Modifier and TypeMethodDescriptionvoid
MapCombinerAggStateUpdater.prepare
(Map<String, Object> conf, TridentOperationContext context) void
MapReducerAggStateUpdater.prepare
(Map<String, Object> conf, TridentOperationContext context) -
Uses of TridentOperationContext in org.apache.storm.trident.windowing
Modifier and TypeMethodDescriptionvoid
WindowsStateUpdater.prepare
(Map<String, Object> conf, TridentOperationContext context)