Module datarush.library
Package com.pervasive.datarush.operators
Interface DeferredCompositionContext
-
- All Superinterfaces:
CompositionContext
,MetadataContext
,OperatorComposable
public interface DeferredCompositionContext extends CompositionContext
Composition context passed toDeferredCompositeOperator.compose(DeferredCompositionContext)
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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 Detail
-
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.
-
-