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.
|
Modifier and Type | Method and Description |
---|---|
static PMMLVersion |
PMMLVersion.get(EngineConfig config)
Returns the PMML version to use based on the given DR engine config
|
Constructor and Description |
---|
Drunner(EngineConfig config) |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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.
|
Constructor and Description |
---|
LogicalGraphWithConfig(EngineConfig engineConfiguration,
LogicalGraph graph) |
Modifier and Type | Method and Description |
---|---|
EngineConfig |
MetadataContext.getEngineConfig()
Returns the engine settings that were passed to the graph being composed/executed.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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.
|
Copyright © 2016 Actian Corporation. All rights reserved.