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 |
TrueFilter.prepare(Map conf,
TridentOperationContext context) |
void |
SingleEmitAggregator.prepare(Map conf,
TridentOperationContext context) |
void |
ReducerAggStateUpdater.prepare(Map conf,
TridentOperationContext context) |
void |
ReducerAggregatorImpl.prepare(Map conf,
TridentOperationContext context) |
void |
GroupedAggregator.prepare(Map conf,
TridentOperationContext context) |
void |
FilterExecutor.prepare(Map conf,
TridentOperationContext context) |
void |
CombinerAggStateUpdater.prepare(Map conf,
TridentOperationContext context) |
void |
CombinerAggregatorInitImpl.prepare(Map conf,
TridentOperationContext context) |
void |
CombinerAggregatorCombineImpl.prepare(Map conf,
TridentOperationContext context) |
void |
ChainedAggregatorImpl.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 © 2016 The Apache Software Foundation. All Rights Reserved.