Package | Description |
---|---|
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
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
|
Modifier and Type | Method and Description |
---|---|
ResourceSpecifier |
MasterDescriptor.getRequestedResources()
Resources requested for the job.
|
ResourceSpecifier |
ClientPassThru.getRequestedResources() |
ResourceSpecifier |
NodeAllocationRequest.getResources() |
Constructor and Description |
---|
ClientPassThru(ModuleConfiguration moduleConfiguration,
ResourceSpecifier requestedResources,
NodeAllocationProvider nodeAllocationProvider,
FileMetaConfiguration fileConfiguration,
ClusterSpecifier cluster,
Path storageManagementPath) |
MasterDescriptor(String applicationID,
String containerID,
String logHTTPAddr,
JobInformation jobInfo,
ResourceSpecifier requestedResources,
String host,
InetSocketAddress appMasterAddress,
long submissionTime) |
NodeAllocationRequest(JobInformation jobInformation,
ResourceSpecifier resources,
NodeAllocationStrategy strategy) |
NodeAllocationRequest(long submitTime,
JobInformation jobInformation,
ResourceSpecifier resources,
NodeAllocationStrategy strategy) |
NodeAllocationRequest(String jobID,
long submitTime,
JobInformation jobInformation,
ResourceSpecifier resources,
NodeAllocationStrategy strategy) |
Copyright © 2015 Actian Corporation. All Rights Reserved.