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 DistributedCallableContextgetDistributedCallableContext()Public only as a matter if implementation; operator authors should not invoke this method.NodeAllocationPlangetNodeAllocation()Returns the node allocation for the graph to which this operator belongs.PartitionInstanceInfogetPartitionInfo()Returns partition id information for the partition being composed.StatisticsRegistrygetStatisticsRegistry()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.
-
-