Package | Description |
---|---|
com.actian.dataflow.cal.yarn.client | |
com.actian.dataflow.cal.yarn.server | |
com.actian.dataflow.cal.yarn.shared | |
com.actian.dataflow.operators.io.orc | |
com.pervasive.datarush.authentication |
Provides classes and interfaces related to authentication.
|
com.pervasive.datarush.graphs |
Provides classes and interfaces for the construction of executable
dataflow graphs.
|
com.pervasive.datarush.hbase | |
com.pervasive.datarush.io |
Provides classes and interfaces performing file-like I/O operations.
|
com.pervasive.datarush.modules |
Modifier and Type | Method and Description |
---|---|
static com.pervasive.datarush.hadoop.shims.yarn.ResourceManagerClient |
YarnShimFactory.createClient(ClusterSpecifier clusterSpec,
ModuleConfiguration moduleCfg)
Get a client interface to the YARN Resource Manager.
|
Modifier and Type | Method and Description |
---|---|
ModuleConfiguration |
YarnWorkerArgs.getModuleConfiguration() |
Constructor and Description |
---|
YarnWorkerArgs(JobSpecifier jobSpec,
ModuleConfiguration moduleConfiguration,
FileMetaConfiguration configuration,
com.pervasive.datarush.cal.dr.NodeAllocationProvider provider) |
Modifier and Type | Method and Description |
---|---|
ModuleConfiguration |
YarnAppMasterArgs.getModuleConfiguration() |
Constructor and Description |
---|
YarnAppMasterArgs(JobSpecifier jobSpec,
ModuleConfiguration moduleCfg,
FileMetaConfiguration fileCfg,
ClasspathSpecifier classpathSpec,
com.pervasive.datarush.cluster.ExecutorOptions options,
List<com.pervasive.datarush.hadoop.shims.yarn.YarnNodeDescriptor> nodeDescriptors,
Path cacheLocation,
Path libArchiveLocation,
int jobPriority,
com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPreferences,
Map<String,ApplicationResource> appResources) |
Constructor and Description |
---|
ORCFormat(ORCMetadata orcMetadata,
FileMetadata fileMetadata,
ModuleConfiguration moduleConfiguration,
com.actian.dataflow.hive.shims.ORCOptions options) |
ORCFormat(ORCMetadata orcMetadata,
ModuleConfiguration moduleConfiguration,
com.actian.dataflow.hive.shims.ORCOptions options) |
Modifier and Type | Method and Description |
---|---|
Subject |
ProcessSubjectProvider.accquireCredentials(ModuleConfiguration moduleConfig,
ProcessAuthenticationSettings config)
Creates a subject based on the authentication settings provided.
|
Subject |
KerberosSubjectProvider.accquireCredentials(ModuleConfiguration moduleConfig,
ProcessAuthenticationSettings credentialSettings) |
static Subject |
ProcessAuthentication.getSubject(ModuleConfiguration moduleConfig,
ProcessAuthenticationSettings config)
Constructs a subject for process-level authentication.
|
Modifier and Type | Field and Description |
---|---|
static EngineProperty<ModuleConfiguration> |
EngineConfig.MODULE_CONFIGURATION
Property controlling classpath that is used for launching remote jobs
|
Modifier and Type | Method and Description |
---|---|
ModuleConfiguration |
EngineConfig.getModuleConfiguration()
Returns the module configuration to be used by operators in the graph.
|
Modifier and Type | Method and Description |
---|---|
EngineConfig |
EngineConfig.moduleConfiguration(ModuleConfiguration configuration)
Specifies the module configuration to be used by operators in the graph
|
Modifier and Type | Method and Description |
---|---|
ModuleConfiguration |
HBasePartitioningFunction.getModuleConfiguration() |
Modifier and Type | Method and Description |
---|---|
void |
HBasePartitioningFunction.setModuleConfiguration(ModuleConfiguration moduleConfiguration) |
Constructor and Description |
---|
HBasePartitioningFunction(ModuleConfiguration moduleConfiguration,
String tableName,
HadoopConfiguration configuration,
Set<String> families,
List<String> keys) |
Modifier and Type | Method and Description |
---|---|
ModuleConfiguration |
FileClient.getModuleConfiguration()
Returns the module configuration for this file client
|
Modifier and Type | Method and Description |
---|---|
static FileClient |
FileClient.configuredClient(FileMetaConfiguration configuration,
ModuleConfiguration moduleConfiguration)
Creates a new client, authorized according to the given configuration.
|
static FileClient |
FileClient.configuredClient(FileMetaConfiguration configuration,
ModuleConfiguration moduleConfiguration,
File indexPathBase,
Path[] tempFsRootDirs)
Creates a new client, authorized according to the given configuration.
|
Modifier and Type | Field and Description |
---|---|
static ModuleConfiguration |
ModuleConfiguration.EMPTY_CONFIGURATION |
Modifier and Type | Method and Description |
---|---|
static ModuleConfiguration |
ModuleConfiguration.modules(Set<String> enabledModules) |
static ModuleConfiguration |
ModuleConfiguration.modules(String... modules) |
Copyright © 2021 Actian Corporation. All rights reserved.