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 © 2016 The Apache Software Foundation. All Rights Reserved.