@Test public void shouldNotGetCurrentlyExecutingComponentInitially () { assertNull( pipelineReplicaMeter.getCurrentlyExecutingComponent() ); }
Object getCurrentlyExecutingComponent () { return currentlyInvokedOperator.get(); }
PipelineReplicaMeter { Object getCurrentlyExecutingComponent () { return currentlyInvokedOperator.get(); } }
PipelineReplicaMeter { Object getCurrentlyExecutingComponent () { return currentlyInvokedOperator.get(); } PipelineReplicaMeter( final long tickMask, final PipelineReplicaId pipelineReplicaId, final OperatorDef headOperatorDef ); }
PipelineReplicaMeter { Object getCurrentlyExecutingComponent () { return currentlyInvokedOperator.get(); } PipelineReplicaMeter( final long tickMask, final PipelineReplicaId pipelineReplicaId, final OperatorDef headOperatorDef ); PipelineReplicaId getPipelineReplicaId(); void tryTick(); String getHeadOperatorId(); int getInputPortCount(); void readInboundThroughput( final long[] inboundThroughput ); boolean isTicked(); void onInvocationStart( final String operatorId ); void count( final String operatorId, final TuplesImpl tuples ); void count( final String operatorId, final List<TuplesImpl> tuplesList, final int count ); void onInvocationComplete( final String operatorId ); }
PipelineReplicaMeter { Object getCurrentlyExecutingComponent () { return currentlyInvokedOperator.get(); } PipelineReplicaMeter( final long tickMask, final PipelineReplicaId pipelineReplicaId, final OperatorDef headOperatorDef ); PipelineReplicaId getPipelineReplicaId(); void tryTick(); String getHeadOperatorId(); int getInputPortCount(); void readInboundThroughput( final long[] inboundThroughput ); boolean isTicked(); void onInvocationStart( final String operatorId ); void count( final String operatorId, final TuplesImpl tuples ); void count( final String operatorId, final List<TuplesImpl> tuplesList, final int count ); void onInvocationComplete( final String operatorId );  }