Module datarush.library

Package com.pervasive.datarush.operators

Interface DeferredCompositionContext

All Superinterfaces:

CompositionContext, MetadataContext, OperatorComposable

public interface DeferredCompositionContext
extends CompositionContext

Composition context passed to DeferredCompositeOperator.compose(DeferredCompositionContext).

Method Summary

Modifier and Type	Method	Description
DistributedCallableContext	getDistributedCallableContext()	Public only as a matter if implementation; operator authors should not invoke this method.
NodeAllocationPlan	getNodeAllocation()	Returns the node allocation for the graph to which this operator belongs.
PartitionInstanceInfo	getPartitionInfo()	Returns partition id information for the partition being composed.
StatisticsRegistry	getStatisticsRegistry()	Public only as a matter of implementation; operator authors should not invoke this method.

Methods inherited from interface com.pervasive.datarush.operators.CompositionContext

getCompilationLevel

Methods inherited from interface com.pervasive.datarush.operators.MetadataContext

getCombinedMetadata, getEngineConfig, getFileClient, getMaxParallelism, getPath, getRequiredMetadata, getSourceMaxParallelism, getSourceMetadata, isParallel, isSourceConnected, isSourceParallel

Methods inherited from interface com.pervasive.datarush.operators.OperatorComposable

add, add, add, connect

Method Details

getPartitionInfo

PartitionInstanceInfo getPartitionInfo()

Returns partition id information for the partition being composed. Most operators should not need to call this method since their output will tend to be a function of the input. This is commonly used for I/O operators which, for example, must chose the output file name based on the partition ID.

Returns:

partition id information for the partition being composed.

getNodeAllocation

NodeAllocationPlan getNodeAllocation()

Returns the node allocation for the graph to which this operator belongs.

Returns:

the node allocation

getDistributedCallableContext

DistributedCallableContext getDistributedCallableContext()

Public only as a matter if implementation; operator authors should not invoke this method.

Returns the distributed callable context in which we are being composed.

Returns:

the distributed context

getStatisticsRegistry

StatisticsRegistry getStatisticsRegistry()

Public only as a matter of implementation; operator authors should not invoke this method.

Returns:

the statistics registry.