| Package | Description |
|---|---|
| storm.trident.operation | |
| storm.trident.operation.builtin | |
| storm.trident.operation.impl | |
| storm.trident.state.map |
| Modifier and Type | Method and Description |
|---|---|
void |
Operation.prepare(Map conf,
TridentOperationContext context) |
void |
BaseOperation.prepare(Map conf,
TridentOperationContext context) |
| Constructor and Description |
|---|
TridentOperationContext(TridentOperationContext parent,
TridentTuple.Factory factory) |
| Modifier and Type | Method and Description |
|---|---|
void |
Negate.prepare(Map conf,
TridentOperationContext context) |
| Modifier and Type | Method and Description |
|---|---|
void |
ReducerAggStateUpdater.prepare(Map conf,
TridentOperationContext context) |
void |
CombinerAggStateUpdater.prepare(Map conf,
TridentOperationContext context) |
void |
ReducerAggregatorImpl.prepare(Map conf,
TridentOperationContext context) |
void |
TrueFilter.prepare(Map conf,
TridentOperationContext context) |
void |
FilterExecutor.prepare(Map conf,
TridentOperationContext context) |
void |
CombinerAggregatorInitImpl.prepare(Map conf,
TridentOperationContext context) |
void |
SingleEmitAggregator.prepare(Map conf,
TridentOperationContext context) |
void |
CombinerAggregatorCombineImpl.prepare(Map conf,
TridentOperationContext context) |
void |
ChainedAggregatorImpl.prepare(Map conf,
TridentOperationContext context) |
void |
GroupedAggregator.prepare(Map conf,
TridentOperationContext context) |
| Modifier and Type | Method and Description |
|---|---|
void |
MapReducerAggStateUpdater.prepare(Map conf,
TridentOperationContext context) |
void |
MapCombinerAggStateUpdater.prepare(Map conf,
TridentOperationContext context) |
Copyright © 2015. All rights reserved.