Module datarush.library

Package com.pervasive.datarush.operators

Interface IterativeExecutionContext

All Superinterfaces:

LogicalSubgraphFactory, MetadataContext

public interface IterativeExecutionContext
extends LogicalSubgraphFactory, MetadataContext

Context passed to CompositionIterator.execute(IterativeExecutionContext). Provides methods for creating a new subgraph.

Method Summary

Modifier and Type	Method	Description
DistributedExecutorService	getExecutorService()	Public only as a matter of implementation; iterative operators should not invoke this method.
<T extends LogicalPort> StagedSource<T>	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.

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

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

Method Details

newSubgraph

LogicalSubgraph newSubgraph()

Creates a new subgraph. The subgraph has access to the input ports of the iterative operator such that they can be connected to other operators added to the subgraph.

Specified by:

newSubgraph in interface LogicalSubgraphFactory

Returns:

the new subgraph

getExecutorService

DistributedExecutorService getExecutorService()

Public only as a matter of implementation; iterative operators should not invoke this method.

Returns:

the executor service

getStagedSource

<T extends LogicalPort> StagedSource<T> getStagedSource(T port)

Provides a handle by which one can access the staged data associated with a given iterative port. This is for advanced integration only; operator authors should generally not need to call this method.

Type Parameters:

T - the type of the source

Parameters:

port - must be an input port of the iterative operator

Returns:

a staged source