Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cal.dr | |
com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
Modifier and Type | Class and Description |
---|---|
class |
YarnClusterExecutor
The executor responsible for starting Dataflow worker containers within YARN.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PseudoDistributedExecutorService
Subinterface of DistributedExecutorService for running in
pseudo-distributed mode.
|
Modifier and Type | Method and Description |
---|---|
DistributedExecutorService |
JobContext.getDistributedExecutor()
Returns an executor service for performing work within the job.
|
DistributedExecutorService |
StorageManagerSpecifier.getService()
Returns the distributed executor service for the job.
|
Constructor and Description |
---|
StorageManagerSpecifier(JobSpecifier jobSpec,
DistributedExecutorService service)
Create a jobInfo
|
Modifier and Type | Class and Description |
---|---|
class |
com.pervasive.datarush.cal.dr.AbstractDRClusterExecutor |
Modifier and Type | Method and Description |
---|---|
DistributedExecutorService |
IterativeExecutionContext.getExecutorService()
Public only as a matter of implementation; iterative operators should not
invoke this method.
|
Copyright © 2016 Actian Corporation. All rights reserved.