public class ReturnResultsReducer extends Object implements MultiReducer<ReturnResultsReducer.ReturnResultsState>
Modifier and Type | Class and Description |
---|---|
static class |
ReturnResultsReducer.ReturnResultsState |
Constructor and Description |
---|
ReturnResultsReducer() |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
void |
complete(ReturnResultsReducer.ReturnResultsState state,
TridentCollector collector) |
void |
execute(ReturnResultsReducer.ReturnResultsState state,
int streamIndex,
TridentTuple input,
TridentCollector collector) |
ReturnResultsReducer.ReturnResultsState |
init(TridentCollector collector) |
void |
prepare(Map<String,Object> conf,
TridentMultiReducerContext context) |
public void prepare(Map<String,Object> conf, TridentMultiReducerContext context)
prepare
in interface MultiReducer<ReturnResultsReducer.ReturnResultsState>
public ReturnResultsReducer.ReturnResultsState init(TridentCollector collector)
init
in interface MultiReducer<ReturnResultsReducer.ReturnResultsState>
public void execute(ReturnResultsReducer.ReturnResultsState state, int streamIndex, TridentTuple input, TridentCollector collector)
execute
in interface MultiReducer<ReturnResultsReducer.ReturnResultsState>
public void complete(ReturnResultsReducer.ReturnResultsState state, TridentCollector collector)
complete
in interface MultiReducer<ReturnResultsReducer.ReturnResultsState>
public void cleanup()
cleanup
in interface MultiReducer<ReturnResultsReducer.ReturnResultsState>
Copyright © 2022 The Apache Software Foundation. All rights reserved.