Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.pervasive.datarush.cal.dr | |
com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
Modifier and Type | Method and Description |
---|---|
NodeAllocationProvider |
YarnWorkerArgs.getAllocationProvider() |
Constructor and Description |
---|
PartitionServer(FileClient client,
Path drfsBaseDir,
String nodeID,
JobServerInformation jobWorkerInfo,
NodeAllocationProvider allocationProvider,
JobSpecifier jobSpecifier) |
YarnWorkerArgs(JobSpecifier jobSpec,
ModuleConfiguration moduleConfiguration,
FileMetaConfiguration configuration,
NodeAllocationProvider provider) |
Modifier and Type | Class and Description |
---|---|
class |
EagerNodeAllocationProvider |
Modifier and Type | Field and Description |
---|---|
protected NodeAllocationProvider |
AbstractDRClusterExecutor.allocationProvider |
Constructor and Description |
---|
AbstractDRClusterExecutor(FileClient fileClient,
JobSpecifier jobSpec,
NodeAllocationProvider allocationProvider) |
DRClusterExecutor(FileClient fileClient,
JobSpecifier jobSpec,
ExecutorOptions execOptions,
NodeAllocationProvider allocationProvider,
ResourceAllocation masterResources) |
Modifier and Type | Method and Description |
---|---|
NodeAllocationProvider |
ClientPassThru.getNodeAllocationProvider() |
Constructor and Description |
---|
ClientPassThru(ModuleConfiguration moduleConfiguration,
ResourceSpecifier requestedResources,
NodeAllocationProvider nodeAllocationProvider,
FileMetaConfiguration fileConfiguration,
ClusterSpecifier cluster,
Path storageManagementPath) |
DistributedWorkerServiceImpl(NodeAllocationProvider allocationProvider,
FileClient fileClient,
String nodeID,
JobServerInformation jobServerInfo,
JobSpecifier jobSpec,
boolean wrap) |
WorkerServer(FileClient client,
Path drfsBaseDir,
String nodeID,
JobServerInformation jobWorkerInfo,
JobSpecifier jobSpecifier,
ExecutorOptions execOptions,
NodeAllocationProvider allocationProvider,
String host) |
Copyright © 2016 Actian Corporation. All Rights Reserved.