storm.trident.operation.impl
Class IdentityMultiReducer

java.lang.Object
  storm.trident.operation.impl.IdentityMultiReducer

All Implemented Interfaces:

java.io.Serializable, MultiReducer

public class IdentityMultiReducer
extends java.lang.Object
implements MultiReducer

See Also:

Serialized Form

Constructor Summary

IdentityMultiReducer()

Method Summary

void	cleanup()
void	complete(java.lang.Object state, TridentCollector collector)
void	execute(java.lang.Object state, int streamIndex, TridentTuple input, TridentCollector collector)
java.lang.Object	init(TridentCollector collector)
void	prepare(java.util.Map conf, TridentMultiReducerContext context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IdentityMultiReducer

public IdentityMultiReducer()

Method Detail

prepare

public void prepare(java.util.Map conf,
                    TridentMultiReducerContext context)

Specified by:

prepare in interface MultiReducer

init

public java.lang.Object init(TridentCollector collector)

Specified by:

init in interface MultiReducer

execute

public void execute(java.lang.Object state,
                    int streamIndex,
                    TridentTuple input,
                    TridentCollector collector)

Specified by:

execute in interface MultiReducer

complete

public void complete(java.lang.Object state,
                     TridentCollector collector)

Specified by:

complete in interface MultiReducer

cleanup

public void cleanup()

Specified by:

cleanup in interface MultiReducer