Modifier and Type | Method and Description |
---|---|
void |
MqttPublishFunction.prepare(Map<String,Object> conf,
TridentOperationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
Operation.prepare(Map<String,Object> conf,
TridentOperationContext context)
Called when the `Operation` is first initialized.
|
void |
BaseOperation.prepare(Map<String,Object> conf,
TridentOperationContext context)
No-op implementation.
|
Constructor and Description |
---|
TridentOperationContext(TridentOperationContext parent,
TridentTuple.Factory factory) |
Modifier and Type | Method and Description |
---|---|
void |
Negate.prepare(Map<String,Object> conf,
TridentOperationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
TrueFilter.prepare(Map<String,Object> conf,
TridentOperationContext context) |
void |
CombinerAggregatorInitImpl.prepare(Map<String,Object> conf,
TridentOperationContext context) |
void |
ReducerAggregatorImpl.prepare(Map<String,Object> conf,
TridentOperationContext context) |
void |
CombinerAggregatorCombineImpl.prepare(Map<String,Object> conf,
TridentOperationContext context) |
void |
SingleEmitAggregator.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 |
CombinerAggStateUpdater.prepare(Map<String,Object> conf,
TridentOperationContext context) |
void |
MapFunctionExecutor.prepare(Map<String,Object> conf,
TridentOperationContext context) |
void |
ReducerAggStateUpdater.prepare(Map<String,Object> conf,
TridentOperationContext context) |
void |
ChainedAggregatorImpl.prepare(Map<String,Object> conf,
TridentOperationContext context) |
void |
GroupedAggregator.prepare(Map<String,Object> conf,
TridentOperationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
MapReducerAggStateUpdater.prepare(Map<String,Object> conf,
TridentOperationContext context) |
void |
MapCombinerAggStateUpdater.prepare(Map<String,Object> conf,
TridentOperationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
WindowsStateUpdater.prepare(Map<String,Object> conf,
TridentOperationContext context) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.