Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.actian.dataflow.cal.yarn.shared | |
com.pervasive.datarush.graphs |
Provides classes and interfaces for the construction of executable
dataflow graphs.
|
com.pervasive.datarush.io |
Provides classes and interfaces performing file-like I/O operations.
|
com.pervasive.datarush.io.configuration |
Provides classes and interfaces associated with filesystem configuration
|
Modifier and Type | Method and Description |
---|---|
FileMetaConfiguration |
YarnWorkerArgs.getFileConfiguration() |
Constructor and Description |
---|
YarnWorkerArgs(JobSpecifier jobSpec,
ModuleConfiguration moduleConfiguration,
FileMetaConfiguration configuration,
com.pervasive.datarush.cal.dr.NodeAllocationProvider provider) |
Modifier and Type | Method and Description |
---|---|
FileMetaConfiguration |
YarnAppMasterArgs.getFileConfiguration() |
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) |
Modifier and Type | Field and Description |
---|---|
static EngineProperty<FileMetaConfiguration> |
EngineConfig.FILE_CONFIGURATION
Property controlling authorization for file access within the graph.
|
Modifier and Type | Method and Description |
---|---|
FileMetaConfiguration |
EngineConfig.getFileConfiguration()
Returns the file configuration to be used by operators in the graph.
|
Modifier and Type | Method and Description |
---|---|
EngineConfig |
EngineConfig.fileConfiguration(FileMetaConfiguration configuration)
Specifies the file configuration to be used by operators in the graph.
|
Modifier and Type | Method and Description |
---|---|
FileMetaConfiguration |
FileClient.getConfiguration()
Returns the meta-configuration containing the configuration of 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 FileMetaConfiguration |
FileMetaConfiguration.DEFAULT_CONFIGURATION
An empty configuration that only has default configuration.
|
Modifier and Type | Method and Description |
---|---|
static FileMetaConfiguration |
FileMetaConfiguration.configuration(FileMetaConfiguration.Entry... entries)
Creates a new meta-configuration consisting of the given entries.
|
static FileMetaConfiguration |
FileMetaConfiguration.configuration(List<FileMetaConfiguration.Entry> entries)
Creates a new meta-configuration consisting of the given entries.
|
static FileMetaConfiguration |
FileMetaConfiguration.exactConfiguration(FileMetaConfiguration.Entry... entries)
Creates a new configuration consisting of onlythe given entries;
no default configuration is acquired.
|
static FileMetaConfiguration |
FileMetaConfiguration.exactConfiguration(List<FileMetaConfiguration.Entry> entries)
Creates a new configuration consisting of onlythe given entries;
no default configuration is acquired.
|
FileMetaConfiguration |
FileMetaConfiguration.removeDefaultConfiguration()
Gets a new meta-configuration with all default configuration removed.
|
FileMetaConfiguration |
FileMetaConfiguration.resetDefaultConfiguration()
Gets a new meta-configuration with the default configuration replaced
with those from the current environment.
|
Copyright © 2021 Actian Corporation. All rights reserved.