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