storm.trident.operation

Class TridentMultiReducerContext

java.lang.Object

storm.trident.operation.TridentMultiReducerContext

public class TridentMultiReducerContext
extends Object

Constructor Summary

Constructors

Constructor and Description
TridentMultiReducerContext(List<TridentTuple.Factory> factories)

Method Summary

Methods

Modifier and Type	Method and Description
TridentTupleView.ProjectionFactory	makeProjectionFactory(int streamIndex, Fields fields)

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentMultiReducerContext

public TridentMultiReducerContext(List<TridentTuple.Factory> factories)

Method Detail

makeProjectionFactory

public TridentTupleView.ProjectionFactory makeProjectionFactory(int streamIndex,
                                                       Fields fields)