Uses of Class
com.pervasive.datarush.graphs.EngineConfig

Packages that use EngineConfig

Package	Description
com.pervasive.datarush.analytics.pmml	Provides shared and base classes for PMML model representation of Analytics algorithms.
com.pervasive.datarush.coercion	Provides classes for dynamic coercion of data structures (for example, arrays and maps) to complex Java objects.
com.pervasive.datarush.graphs	Provides classes and interfaces for the construction of executable dataflow graphs.
com.pervasive.datarush.operators	Provides classes and interfaces for developing dataflow operators.
com.pervasive.datarush.ports	Provides classes and interfaces related to receiving and sending data in a dataflow graph.

Uses of EngineConfig in com.pervasive.datarush.analytics.pmml

Methods in com.pervasive.datarush.analytics.pmml with parameters of type EngineConfig

Modifier and Type	Method	Description
static PMMLVersion	PMMLVersion.get(EngineConfig config)	Returns the PMML version to use based on the given DR engine config

Uses of EngineConfig in com.pervasive.datarush.coercion

Constructors in com.pervasive.datarush.coercion with parameters of type EngineConfig

Constructor	Description
Drunner(EngineConfig config)

Uses of EngineConfig in com.pervasive.datarush.graphs

Methods in com.pervasive.datarush.graphs that return EngineConfig

Modifier and Type	Method	Description
EngineConfig	EngineConfig.applyConfig(EngineConfig config)	Constructs a new configuration by merging the properties of another config with this one.
EngineConfig	EngineConfig.autoParallelize()	Specifies that the engine should automatically determine the default degree of parallelism for graphs.
EngineConfig	EngineConfig.Ports.batchSize(int size)	Specifies the port should publish pushed data in batches of the specified size.
EngineConfig	EngineConfig.classpathSpecifier(ClasspathSpecifier classpath)	Sets the classpath to be used in the case of a remote job.
EngineConfig	EngineConfig.cluster(ClusterSpecifier spec)	Specifies the cluster on which we are to run
EngineConfig	EngineConfig.cluster(String url)	Specifies the cluster that we are to run on.
EngineConfig	EngineConfig.defaultStorageManagementPath()	Specifies to use the default storage management path.
EngineConfig	EngineConfig.dumpfilePath(String path)	Specifies the dump path where low-level statistics and plan dumps are placed.
EngineConfig	EngineConfig.RemoteMonitoring.enabled(boolean enabled)	Sets whether to enable remote monitoring
static EngineConfig	EngineConfig.engine()	Returns the default engine configuration
static EngineConfig	EngineConfig.engine(Properties properties)	Creates an EngineConfig from a set of properties.
EngineConfig	EngineConfig.RemoteMonitoring.ephemeralPort(boolean ephemeral)	Sets whether monitoring is done via an ephemeral port.
EngineConfig	EngineConfig.extensionPaths(String... paths)	Specifies the list of user extension directory paths to use.
EngineConfig	EngineConfig.fileConfiguration(FileMetaConfiguration configuration)	Specifies the file configuration to be used by operators in the graph.
EngineConfig	LogicalGraphWithConfig.getEngineConfig()
EngineConfig	EngineConfig.Sort.ioBuffer(String sizeSpecifier)	Sets the default value for ioBufferSize.
EngineConfig	EngineConfig.Sort.ioBufferSize(long size)	Sets the default value for ioBufferSize.
EngineConfig	EngineConfig.Sort.maxMerge(int maxMerge)	Sets the default value for maxMerge.
EngineConfig	EngineConfig.maxRetries(int maxRetries)	Specifies the maximum number of retries.
EngineConfig	EngineConfig.minParallelism(int count)	Specifies that the engine should use the given degree of parallelism for graphs.
EngineConfig	EngineConfig.moduleConfiguration(ModuleConfiguration configuration)	Specifies the module configuration to be used by operators in the graph
EngineConfig	EngineConfig.monitored(boolean enabled)	Specifies whether performance statistics should be gathered for executed graphs.
static EngineConfig	EngineConfig.monitoredEngine()	Returns a default engine configuration with monitoring enabled.
EngineConfig	EngineConfig.networkConfiguration(NetworkConfiguration networkConfiguration)	Sets the network configuration to be used for communication between the client and cluster manager.
EngineConfig	EngineConfig.Ports.noSpooling()	Disables writers writing published batches to disk.
EngineConfig	EngineConfig.parallelism(int count)	Specifies that the engine should use the given degree of parallelism for graphs.
EngineConfig	EngineConfig.RemoteMonitoring.port(int port)	Sets the port to use for remote monitoring.
<T> EngineConfig	EngineConfig.property(EngineProperty<T> property, T value)	Constructs a new configuration overriding the specified setting All other settings are left unchanged.
EngineConfig	EngineConfig.pseudoDistributed()	Specifies that we are to run in pseudo-distributed mode.
EngineConfig	EngineConfig.schedulerQueue(String queueName)	Specifies the scheduler queue to use when a job is executed.
EngineConfig	EngineConfig.Ports.sizeByReaders(boolean enabled)	Specifies whether the initial writeahead for a port should be automatically determined based on the number of readers.
EngineConfig	EngineConfig.Sort.sortBuffer(String sizeSpecifier)	Sets the default value for sortBufferSize.
EngineConfig	EngineConfig.Sort.sortBufferSize(long size)	Sets the default value for sortBufferSize.
EngineConfig	EngineConfig.Ports.spoolThreshold(int size)	Specifies the threshold at which the writer begins writing published batches to disk.
EngineConfig	EngineConfig.storageManagementPath(Path path)	Specifies the root scratch directory to use.
EngineConfig	EngineConfig.subgraphHistorySize(int size)	Sets the maximum number of subgraphs to retain when tracking execution history.
EngineConfig	EngineConfig.Ports.writeahead(int size)	Specifies the number of unread batches which a port can publish before blocking.

Methods in com.pervasive.datarush.graphs with parameters of type EngineConfig

Modifier and Type	Method	Description
EngineConfig	EngineConfig.applyConfig(EngineConfig config)	Constructs a new configuration by merging the properties of another config with this one.
LogicalGraphInstance	LogicalGraph.compile(EngineConfig config)	Creates an executable instance of the logical graph.
static LogicalGraph	LogicalGraphFactory.newLogicalGraph(OperatorSettings settings, EngineConfig defaultConfig)	Creates an empty logical graph with specified OperatorSettings and default EngineConfig.
LogicalGraphInstance	LogicalGraph.run(EngineConfig config)	Creates an instance of the logical graph and executes it synchronously.
LogicalGraphInstanceView	LogicalGraph.validate(EngineConfig config)	Performs validation but does not return an executable graph.

Constructors in com.pervasive.datarush.graphs with parameters of type EngineConfig

Constructor	Description
LogicalGraphWithConfig(EngineConfig engineConfiguration, LogicalGraph graph)

Uses of EngineConfig in com.pervasive.datarush.operators

Methods in com.pervasive.datarush.operators that return EngineConfig

Modifier and Type	Method	Description
protected EngineConfig	AbstractOperatorTestCase.createTestConfig()
EngineConfig	OperatorTestHelper.createTestConfig()
EngineConfig	MetadataContext.getEngineConfig()	Returns the engine settings that were passed to the graph being composed/executed.

Uses of EngineConfig in com.pervasive.datarush.ports

Methods in com.pervasive.datarush.ports that return EngineConfig

Modifier and Type	Method	Description
abstract EngineConfig	PortSetting.apply(EngineConfig config)	Creates a new EngineConfig, overriding those settings defined by the port setting.
static EngineConfig	PortSettings.apply(EngineConfig config, PortSetting... settings)	Specifies the default properties for ports in the graph.

Methods in com.pervasive.datarush.ports with parameters of type EngineConfig

Modifier and Type	Method	Description
abstract EngineConfig	PortSetting.apply(EngineConfig config)	Creates a new EngineConfig, overriding those settings defined by the port setting.
static EngineConfig	PortSettings.apply(EngineConfig config, PortSetting... settings)	Specifies the default properties for ports in the graph.