| Package | Description |
|---|---|
| org.apache.storm.trident.operation.impl |
| Modifier and Type | Method and Description |
|---|---|
JoinState |
JoinerMultiReducer.init(TridentCollector collector,
TridentTuple group) |
JoinState |
PreservingFieldsOrderJoinerMultiReducer.init(TridentCollector collector,
TridentTuple group) |
| Modifier and Type | Method and Description |
|---|---|
void |
JoinerMultiReducer.complete(JoinState state,
TridentTuple group,
TridentCollector collector) |
void |
PreservingFieldsOrderJoinerMultiReducer.complete(JoinState state,
TridentTuple group,
TridentCollector collector) |
void |
JoinerMultiReducer.execute(JoinState state,
int streamIndex,
TridentTuple group,
TridentTuple input,
TridentCollector collector) |
void |
PreservingFieldsOrderJoinerMultiReducer.execute(JoinState state,
int streamIndex,
TridentTuple group,
TridentTuple input,
TridentCollector collector) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.