Package | Description |
---|---|
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
Modifier and Type | Field and Description |
---|---|
static ResourceSpecifier |
ResourceSpecifier.UNSPECIFIED
Default, unspecified resources
|
Modifier and Type | Method and Description |
---|---|
ResourceSpecifier |
ResourceSpecifier.masterResources(ResourceAllocation resources)
Returns a resource specifier applying the specified allocation for
job master resources
|
ResourceSpecifier |
ResourceSpecifier.maximumParallelism(int partitions)
Returns a resource specifier with the given specified maximum parallelism
|
ResourceSpecifier |
ResourceSpecifier.minimumParallelism(int partitions)
Returns a resource specifier with the given specified minimum parallelism
|
ResourceSpecifier |
ResourceSpecifier.parallelism(int parallelism)
Returns a resource specifier with the given specified parallelism
|
static ResourceSpecifier |
ResourceSpecifier.PARALLELISM(int parallelism)
Specifies the parallelism
|
ResourceSpecifier |
ResourceSpecifier.partitionResources(ResourceAllocation resources)
Returns a resource specifier applying the specified allocation for
per-partition resources
|
ResourceSpecifier |
JobSpecifier.requestedResources()
Returns the resources requested for the job
|
Constructor and Description |
---|
JobSpecifier(ResourceSpecifier requestedResources,
ClusterSpecifier cluster,
ClasspathSpecifier classpath,
JobInformation jobInformation,
Path storageManagementPath)
Create a new job specifier
|
JobSpecifier(ResourceSpecifier requestedResources,
ClusterSpecifier cluster,
ClasspathSpecifier classpath,
JobInformation jobInformation,
Path storageManagementPath,
String schedulerQueue,
List<String> extensionPaths)
Create a new job specifier
|
Copyright © 2021 Actian Corporation. All rights reserved.