public interface IterativeExecutionContext extends LogicalSubgraphFactory, MetadataContext
CompositionIterator.execute(IterativeExecutionContext)
.
Provides methods for creating a new subgraph.Modifier and Type | Method and Description |
---|---|
DistributedExecutorService |
getExecutorService()
Public only as a matter of implementation; iterative operators should not
invoke this method.
|
<T extends LogicalPort> |
getStagedSource(T port)
Provides a handle by which one can access the staged data associated with
a given iterative port.
|
LogicalSubgraph |
newSubgraph()
Creates a new subgraph.
|
getCombinedMetadata, getEngineConfig, getFileClient, getMaxParallelism, getPath, getRequiredMetadata, getSourceMaxParallelism, getSourceMetadata, isParallel, isSourceConnected, isSourceParallel
LogicalSubgraph newSubgraph()
newSubgraph
in interface LogicalSubgraphFactory
DistributedExecutorService getExecutorService()
<T extends LogicalPort> StagedSource<T> getStagedSource(T port)
T
- the type of the sourceport
- must be an input port of the iterative operatorCopyright © 2021 Actian Corporation. All rights reserved.