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