| Package | Description |
|---|---|
| storm.trident.operation.impl |
| Modifier and Type | Method and Description |
|---|---|
JoinerMultiReducer.JoinState |
JoinerMultiReducer.init(TridentCollector collector,
TridentTuple group) |
| Modifier and Type | Method and Description |
|---|---|
void |
JoinerMultiReducer.complete(JoinerMultiReducer.JoinState state,
TridentTuple group,
TridentCollector collector) |
void |
JoinerMultiReducer.execute(JoinerMultiReducer.JoinState state,
int streamIndex,
TridentTuple group,
TridentTuple input,
TridentCollector collector) |
Copyright © 2015. All rights reserved.