storm.trident.operation
Class TridentOperationContext

java.lang.Object
  storm.trident.operation.TridentOperationContext

public class TridentOperationContext
extends java.lang.Object

Constructor Summary

TridentOperationContext(TopologyContext topoContext, TridentTuple.Factory factory)

TridentOperationContext(TridentOperationContext parent, TridentTuple.Factory factory)

Method Summary

int	getPartitionIndex()
TridentTupleView.ProjectionFactory	makeProjectionFactory(Fields fields)
int	numPartitions()

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentOperationContext

public TridentOperationContext(TopologyContext topoContext,
                               TridentTuple.Factory factory)

TridentOperationContext

public TridentOperationContext(TridentOperationContext parent,
                               TridentTuple.Factory factory)

Method Detail

makeProjectionFactory

public TridentTupleView.ProjectionFactory makeProjectionFactory(Fields fields)

numPartitions

public int numPartitions()

getPartitionIndex

public int getPartitionIndex()