Package | Description |
---|---|
com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
Modifier and Type | Method and Description |
---|---|
List<NodeAllocationRequest> |
ClusterManagerImpl.getPendingJobs() |
List<NodeAllocationRequest> |
ClusterManager.getPendingJobs() |
Modifier and Type | Method and Description |
---|---|
String |
DataRushCluster.allocateMaster(NodeAllocationRequest request) |
void |
JobScheduler.scheduleNewJob(com.pervasive.datarush.cluster.ScheduledJobAllocator allocator,
NodeAllocationRequest request) |
void |
FIFOScheduler.scheduleNewJob(com.pervasive.datarush.cluster.ScheduledJobAllocator allocator,
NodeAllocationRequest request) |
Modifier and Type | Method and Description |
---|---|
String |
ClusterManagerImpl.initializeNodeAllocation(SerializationBridge<NodeAllocationRequest> request) |
String |
ClusterManager.initializeNodeAllocation(SerializationBridge<NodeAllocationRequest> request) |
Copyright © 2016 Actian Corporation. All Rights Reserved.