- calculateColumnWidths() - Method in class org.springframework.yarn.support.console.Table
-
- call() - Method in class org.springframework.data.hadoop.hive.HiveRunner
-
- call() - Method in class org.springframework.data.hadoop.mapreduce.JarRunner
-
- call() - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
-
- call() - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner
-
- call() - Method in class org.springframework.data.hadoop.pig.PigRunner
-
- canConvert(Class<?>, Class<?>) - Method in class org.springframework.yarn.support.BeanFactoryTypeConverter
-
- canConvert(TypeDescriptor, TypeDescriptor) - Method in class org.springframework.yarn.support.BeanFactoryTypeConverter
-
- canFit(GridMember) - Method in class org.springframework.yarn.am.grid.support.AbstractGridProjection
-
Checks if a member can be fit in this projection.
- canRead(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor
-
- canRead(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor
-
- canRead(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor
-
- canRead(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor
-
- canWrite(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor
-
- canWrite(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor
-
- canWrite(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor
-
- cat(String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- cat(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- ChainedFileNamingStrategy - Class in org.springframework.data.hadoop.store.strategy.naming
-
A FileNamingStrategy
chaining other strategies.
- ChainedFileNamingStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
-
Instantiates a new chained rollover strategy.
- ChainedFileNamingStrategy(List<? extends FileNamingStrategy>) - Constructor for class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
-
Instantiates a new chained rollover strategy.
- ChainedRolloverStrategy - Class in org.springframework.data.hadoop.store.strategy.rollover
-
RolloverStrategy
which is simply chaining other strategies.
- ChainedRolloverStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
-
Instantiates a new chained rollover strategy.
- ChainedRolloverStrategy(List<? extends RolloverStrategy>) - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
-
Instantiates a new chained rollover strategy.
- checkClosure(int) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
-
- checkResponseMayThrow(BaseResponseObject) - Method in class org.springframework.yarn.batch.repository.AbstractRemoteDao
-
Checks status of a response and throws an exception if response status
message is set to 'error'.
- chgrp(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chgrp(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chgrp(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chgrp(boolean, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chgrpr(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chgrpr(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmod(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmod(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmod(Integer, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmod(Integer, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmod(boolean, Integer, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmod(boolean, Integer, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmod(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmod(boolean, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmodr(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmodr(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmodr(Integer, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chmodr(Integer, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chown(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chown(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chown(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chown(boolean, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chownr(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- chownr(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- clazz - Variable in class org.springframework.yarn.batch.repository.bindings.ExecutionContextType.ObjectEntry
-
- clean() - Method in class org.springframework.yarn.fs.AbstractResourceLocalizer
-
- clean() - Method in interface org.springframework.yarn.fs.SmartResourceLocalizer
-
Cleans all leftovers what has been created during
the distribute process.
- ClientApplicationRunner<R> - Interface in org.springframework.yarn.boot.app
-
Interface for running client applications.
- clientClass(Class<? extends YarnClient>) - Method in class org.springframework.yarn.config.annotation.builders.YarnClientBuilder
-
- clientClass(String) - Method in class org.springframework.yarn.config.annotation.builders.YarnClientBuilder
-
- clientClass(Class<? extends YarnClient>) - Method in interface org.springframework.yarn.config.annotation.builders.YarnClientConfigurer
-
Specify a YarnClient
class.
- clientClass(String) - Method in interface org.springframework.yarn.config.annotation.builders.YarnClientConfigurer
-
Specify a YarnClient
as a fully qualified class name.
- ClientLauncherRunner - Class in org.springframework.yarn.boot.support
-
A
CommandLineRunner
handling a default action for
YarnClient
.
- ClientLauncherRunner() - Constructor for class org.springframework.yarn.boot.support.ClientLauncherRunner
-
Instantiates a new client launcher runner.
- ClientLauncherRunner(String) - Constructor for class org.springframework.yarn.boot.support.ClientLauncherRunner
-
Instantiates a new client launcher runner.
- clientLauncherRunner() - Method in class org.springframework.yarn.boot.YarnClientAutoConfiguration.RunnerConfig
-
- ClientMasterRunnerConfigurer - Interface in org.springframework.yarn.config.annotation.configurers
-
- ClientParser - Class in org.springframework.yarn.config
-
Simple namespace parser for yarn:client.
- ClientParser() - Constructor for class org.springframework.yarn.config.ClientParser
-
- ClientRmOperations - Interface in org.springframework.yarn.client
-
Interface for client to resource manager communication.
- ClientRmTemplate - Class in org.springframework.yarn.client
-
Template implementation for
ClientRmOperations
wrapping
communication using
ApplicationClientProtocol
.
- ClientRmTemplate(Configuration) - Constructor for class org.springframework.yarn.client.ClientRmTemplate
-
- CliSystemConstants - Class in org.springframework.yarn.boot.cli
-
Various constants for cli system.
- CliSystemConstants() - Constructor for class org.springframework.yarn.boot.cli.CliSystemConstants
-
- close() - Method in class org.springframework.data.hadoop.batch.item.HdfsItemWriter
-
- close() - Method in class org.springframework.data.hadoop.fs.FsShell
-
- close() - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
- close() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- close() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
- close() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
- close() - Method in class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
-
- close() - Method in class org.springframework.data.hadoop.store.input.TextFileReader
-
- close() - Method in class org.springframework.data.hadoop.store.input.TextSequenceFileReader
-
- close() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
- close() - Method in class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
-
- close() - Method in class org.springframework.data.hadoop.store.output.OutputStreamWriter
-
- close() - Method in class org.springframework.data.hadoop.store.output.TextFileWriter
-
- close() - Method in class org.springframework.data.hadoop.store.output.TextSequenceFileWriter
-
- close() - Method in class org.springframework.data.hadoop.store.support.SequenceFileWriterHolder
-
- close() - Method in class org.springframework.data.hadoop.store.support.StreamsHolder
-
Close both streams in this holder.
- close() - Method in class org.springframework.data.hadoop.test.support.HadoopClusterManager
-
Close the manager, removes shutdown hook and
closes all running clusters.
- close() - Method in class org.springframework.yarn.batch.item.DataStoreItemReader
-
- close() - Method in class org.springframework.yarn.test.support.YarnClusterManager
-
Close the manager, removes shutdown hook and
closes all running clusters.
- closeCluster(HadoopCluster) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterManager
-
- closeCluster(YarnCluster) - Method in class org.springframework.yarn.test.support.YarnClusterManager
-
- closeReader(Reader) - Static method in class org.springframework.yarn.support.console.CommonUtils
-
- closeTimeout(long) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- closeTimeout(long) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's close timeout.
- ClusterAllocatingAction - Class in org.springframework.yarn.am.cluster
-
- ClusterAllocatingAction() - Constructor for class org.springframework.yarn.am.cluster.ClusterAllocatingAction
-
- clusterAllocatingAction() - Method in class org.springframework.yarn.am.cluster.ContainerClusterStateMachineConfiguration
-
- clusterCreate(ContainerClusterCreateRequest) - Method in interface org.springframework.yarn.boot.app.YarnContainerClusterOperations
-
Create a container cluster.
- clusterCreate(ContainerClusterCreateRequest) - Method in class org.springframework.yarn.boot.app.YarnContainerClusterTemplate
-
- ClusterDelegatingFactoryBean - Class in org.springframework.yarn.test.support
-
- ClusterDelegatingFactoryBean() - Constructor for class org.springframework.yarn.test.support.ClusterDelegatingFactoryBean
-
- clusterDestroy(String) - Method in interface org.springframework.yarn.boot.app.YarnContainerClusterOperations
-
Destroy a container cluster.
- clusterDestroy(String) - Method in class org.springframework.yarn.boot.app.YarnContainerClusterTemplate
-
- ClusterDestroyingAction - Class in org.springframework.yarn.am.cluster
-
- ClusterDestroyingAction() - Constructor for class org.springframework.yarn.am.cluster.ClusterDestroyingAction
-
- clusterDestroyingAction() - Method in class org.springframework.yarn.am.cluster.ContainerClusterStateMachineConfiguration
-
- ClusterEvent - Enum in org.springframework.yarn.am.cluster
-
Possible events controlling this machine.
- ClusterInfo - Class in org.springframework.data.hadoop.test.support
-
Object keeping some testing cluster init info.
- ClusterInfo() - Constructor for class org.springframework.data.hadoop.test.support.ClusterInfo
-
- ClusterInfo(String, int) - Constructor for class org.springframework.data.hadoop.test.support.ClusterInfo
-
- clusterInfo(String) - Method in class org.springframework.yarn.boot.actuate.endpoint.mvc.YarnContainerClusterMvcEndpoint
-
Gets a status of a specific container cluster.
- clusterInfo(String) - Method in interface org.springframework.yarn.boot.app.YarnContainerClusterOperations
-
Get a container cluster info.
- clusterInfo(String) - Method in class org.springframework.yarn.boot.app.YarnContainerClusterTemplate
-
- ClusterInfo - Class in org.springframework.yarn.test.support
-
Object keeping some testing cluster init info.
- ClusterInfo() - Constructor for class org.springframework.yarn.test.support.ClusterInfo
-
- ClusterInfo(String, int, int) - Constructor for class org.springframework.yarn.test.support.ClusterInfo
-
- clusterInfoReportBuilder() - Static method in class org.springframework.yarn.support.console.ContainerClusterReport
-
- clusterModify(String, ContainerClusterCreateRequest) - Method in interface org.springframework.yarn.boot.app.YarnContainerClusterOperations
-
Modify a container cluster.
- clusterModify(String, ContainerClusterCreateRequest) - Method in class org.springframework.yarn.boot.app.YarnContainerClusterTemplate
-
- clustersInfoReportBuilder() - Static method in class org.springframework.yarn.support.console.ContainerClusterReport
-
- clusterStart(String, ContainerClusterModifyRequest) - Method in interface org.springframework.yarn.boot.app.YarnContainerClusterOperations
-
Start a container cluster.
- clusterStart(String, ContainerClusterModifyRequest) - Method in class org.springframework.yarn.boot.app.YarnContainerClusterTemplate
-
- ClusterState - Enum in org.springframework.yarn.am.cluster
-
Possible states of this machine.
- clusterStop(String, ContainerClusterModifyRequest) - Method in interface org.springframework.yarn.boot.app.YarnContainerClusterOperations
-
Stop a container cluster.
- clusterStop(String, ContainerClusterModifyRequest) - Method in class org.springframework.yarn.boot.app.YarnContainerClusterTemplate
-
- ClusterStoppingAction - Class in org.springframework.yarn.am.cluster
-
- ClusterStoppingAction() - Constructor for class org.springframework.yarn.am.cluster.ClusterStoppingAction
-
- clusterStoppingAction() - Method in class org.springframework.yarn.am.cluster.ContainerClusterStateMachineConfiguration
-
- codec(CodecInfo) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- codec(String) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- codec(Codecs) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- codec(CodecInfo) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's compression coded.
- codec(String) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's compression coded.
- codec(Codecs) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's compression coded.
- codec() - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultNamingStrategyConfigurer
-
- codec() - Method in interface org.springframework.data.hadoop.store.config.annotation.configurers.NamingStrategyConfigurer
-
Adds a codec naming part to a strategy.
- CodecFileNamingStrategy - Class in org.springframework.data.hadoop.store.strategy.naming
-
A FileNamingStrategy
which adds suffix based on known codec.
- CodecFileNamingStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.naming.CodecFileNamingStrategy
-
Instantiates a new codec file naming strategy.
- CodecInfo - Interface in org.springframework.data.hadoop.store.codec
-
Generic interface for supported codec info.
- Codecs - Enum in org.springframework.data.hadoop.store.codec
-
Default codecs supported by store framework.
- collectionToCommaDelimitedString(Collection<String>) - Static method in class org.springframework.yarn.support.console.CommonUtils
-
Convert a List of Strings to a comma delimited String.
- COLUMN_1 - Static variable in class org.springframework.yarn.support.console.UiUtils
-
- COLUMN_2 - Static variable in class org.springframework.yarn.support.console.UiUtils
-
- COLUMN_3 - Static variable in class org.springframework.yarn.support.console.UiUtils
-
- COLUMN_4 - Static variable in class org.springframework.yarn.support.console.UiUtils
-
- COLUMN_5 - Static variable in class org.springframework.yarn.support.console.UiUtils
-
- COLUMN_6 - Static variable in class org.springframework.yarn.support.console.UiUtils
-
- CommandCompleter - Class in org.springframework.yarn.boot.cli.shell
-
JLine Completer
for Spring Boot Command
s.
- CommandCompleter(ConsoleReader, ArgumentCompleter.ArgumentDelimiter, Iterable<Command>) - Constructor for class org.springframework.yarn.boot.cli.shell.CommandCompleter
-
- CommandLineAppmasterRunner - Class in org.springframework.yarn.am
-
Simple launcher for application master.
- CommandLineAppmasterRunner() - Constructor for class org.springframework.yarn.am.CommandLineAppmasterRunner
-
- CommandLineClientRunner - Class in org.springframework.yarn.client
-
A simple client runner executing a bean named "yarnClient".
- CommandLineClientRunner() - Constructor for class org.springframework.yarn.client.CommandLineClientRunner
-
- CommandLineContainerRunner - Class in org.springframework.yarn.container
-
A simple container runner executing a bean
named "yarnContainer".
- CommandLineContainerRunner() - Constructor for class org.springframework.yarn.container.CommandLineContainerRunner
-
- CommandLineRunnerSupport - Class in org.springframework.yarn.boot.support
-
Base support class for CommandLineRunner
implementations.
- CommandLineRunnerSupport() - Constructor for class org.springframework.yarn.boot.support.CommandLineRunnerSupport
-
- CommandYarnClient - Class in org.springframework.yarn.client
-
- CommandYarnClient(ClientRmOperations) - Constructor for class org.springframework.yarn.client.CommandYarnClient
-
Constructs a default client with a given template.
- commitCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
-
- CommonUtils - Class in org.springframework.yarn.support.console
-
Contains common non-ui related helper methods for rendering text to the console.
- CommonUtils() - Constructor for class org.springframework.yarn.support.console.CommonUtils
-
- compareTo(ExitStatus) - Method in class org.springframework.yarn.launch.ExitStatus
-
- complete(String, int, List<CharSequence>) - Method in class org.springframework.yarn.boot.cli.shell.CommandCompleter
-
- COMPLETED - Static variable in class org.springframework.yarn.launch.ExitStatus
-
Convenient constant value representing finished processing.
- completed(List<ContainerStatus>) - Method in class org.springframework.yarn.listener.CompositeContainerAllocatorListener
-
- completed(List<ContainerStatus>) - Method in interface org.springframework.yarn.listener.ContainerAllocatorListener
-
Invoked when containers are releases and thus
marked as completed.
- completedCount() - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor
-
Gets a count of completed containers.
- completedCount() - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
-
- completeLocalOutput(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- completeLocalOutput(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- CompositeAppmasterStateListener - Class in org.springframework.yarn.listener
-
Composite listener for handling appmaster state events.
- CompositeAppmasterStateListener() - Constructor for class org.springframework.yarn.listener.CompositeAppmasterStateListener
-
- CompositeContainerAllocatorListener - Class in org.springframework.yarn.listener
-
Composite listener for handling allocation events.
- CompositeContainerAllocatorListener() - Constructor for class org.springframework.yarn.listener.CompositeContainerAllocatorListener
-
- CompositeContainerMonitorStateListener - Class in org.springframework.yarn.listener
-
Composite listener for handling container monitor events.
- CompositeContainerMonitorStateListener() - Constructor for class org.springframework.yarn.listener.CompositeContainerMonitorStateListener
-
- CompositeContainerStateListener - Class in org.springframework.yarn.listener
-
Composite listener for handling container state events.
- CompositeContainerStateListener() - Constructor for class org.springframework.yarn.listener.CompositeContainerStateListener
-
- CompositePartitionedStepExecutionStateListener - Class in org.springframework.yarn.batch.listener
-
Composite listener for handling partitioned step state events.
- CompositePartitionedStepExecutionStateListener() - Constructor for class org.springframework.yarn.batch.listener.CompositePartitionedStepExecutionStateListener
-
- computeSplitSize(long, long, long) - Method in class org.springframework.data.hadoop.store.split.AbstractSplitter
-
Compute split size.
- computeSplitSize(long, long, long) - Method in class org.springframework.data.hadoop.store.split.StaticBlockSplitter
-
- ConditionalOnMissingYarn - Annotation Type in org.springframework.yarn.boot.condition
-
Conditional
that only matches when presence of
Hadoop Yarn Cluster is not detected.
- ConditionalOnYarn - Annotation Type in org.springframework.yarn.boot.condition
-
Conditional
that only matches when presence of
Hadoop Yarn Cluster is detected.
- ConditionalOnYarnAppmaster - Annotation Type in org.springframework.yarn.boot.condition
-
Conditional
that only matches when Hadoop Yarn
appmaster execution is detected.
- ConditionalOnYarnContainer - Annotation Type in org.springframework.yarn.boot.condition
-
Conditional
that only matches when Hadoop Yarn
container execution is detected.
- configFile(String, Properties) - Method in class org.springframework.yarn.boot.app.YarnPushApplication
-
Associates a new Properties
with a name.
- configuration() - Method in class org.springframework.data.hadoop.config.annotation.configuration.SpringHadoopConfiguration
-
- configuration(Configuration) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- configuration(Configuration) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's Hadoop configuration.
- configuration - Variable in class org.springframework.data.hadoop.test.junit.AbstractHadoopClusterTests
-
- configuration(Configuration) - Method in class org.springframework.yarn.config.annotation.builders.YarnAppmasterBuilder
-
- configuration(Configuration) - Method in class org.springframework.yarn.config.annotation.builders.YarnClientBuilder
-
- configuration(Configuration) - Method in class org.springframework.yarn.config.annotation.builders.YarnContainerBuilder
-
- configuration(Configuration) - Method in class org.springframework.yarn.config.annotation.builders.YarnEnvironmentBuilder
-
Sets the yarn configuration.
- configuration(Configuration) - Method in class org.springframework.yarn.config.annotation.builders.YarnResourceLocalizerBuilder
-
- configuration - Variable in class org.springframework.yarn.test.junit.AbstractYarnClusterTests
-
- ConfigurationDelegatingFactoryBean - Class in org.springframework.data.hadoop.test.support
-
- ConfigurationDelegatingFactoryBean() - Constructor for class org.springframework.data.hadoop.test.support.ConfigurationDelegatingFactoryBean
-
- ConfigurationDelegatingFactoryBean - Class in org.springframework.yarn.test.support
-
- ConfigurationDelegatingFactoryBean() - Constructor for class org.springframework.yarn.test.support.ConfigurationDelegatingFactoryBean
-
- ConfigurationFactoryBean - Class in org.springframework.data.hadoop.configuration
-
FactoryBean for creating Configuration
instances.
- ConfigurationFactoryBean() - Constructor for class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
- ConfigurationFactoryBean - Class in org.springframework.yarn.configuration
-
FactoryBean for creating YarnConfiguration
instances.
- ConfigurationFactoryBean() - Constructor for class org.springframework.yarn.configuration.ConfigurationFactoryBean
-
- ConfigurationUtils - Class in org.springframework.data.hadoop.configuration
-
Reusable utility class for common Configuration
operations.
- ConfigurationUtils() - Constructor for class org.springframework.data.hadoop.configuration.ConfigurationUtils
-
- ConfigurationUtils - Class in org.springframework.yarn.configuration
-
Reusable utility class for common Configuration
operations.
- ConfigurationUtils() - Constructor for class org.springframework.yarn.configuration.ConfigurationUtils
-
- configure(HadoopConfigConfigurer) - Method in class org.springframework.data.hadoop.boot.HadoopAutoConfiguration.SpringHadoopConfig
-
- configure(HadoopConfigConfigurer) - Method in interface org.springframework.data.hadoop.config.annotation.SpringHadoopConfigurer
-
- configure(SpringHadoopConfigBuilder) - Method in class org.springframework.data.hadoop.config.annotation.SpringHadoopConfigurerAdapter
-
- configure(HadoopConfigConfigurer) - Method in class org.springframework.data.hadoop.config.annotation.SpringHadoopConfigurerAdapter
-
- configure(B) - Method in interface org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurer
-
- configure(B) - Method in class org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurerAdapter
-
- configure(B) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultPropertiesConfigurer
-
- configure(B) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultResourceConfigurer
-
- configure(B) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultSecurityConfigurer
-
- configure(DataStoreTextWriterBuilder) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultNamingStrategyConfigurer
-
- configure(DataStoreTextWriterBuilder) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultPartitionStrategyConfigurer
-
- configure(DataStoreTextWriterBuilder) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultRolloverStrategyConfigurer
-
- configure(DataStoreTextWriterConfigurer) - Method in interface org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurer
-
- configure(SpringDataStoreTextWriterBuilder) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurerAdapter
-
- configure(DataStoreTextWriterConfigurer) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurerAdapter
-
- configure(StateMachineConfigurationConfigurer<ClusterState, ClusterEvent>) - Method in class org.springframework.yarn.am.cluster.ContainerClusterStateMachineConfiguration
-
- configure(StateMachineStateConfigurer<ClusterState, ClusterEvent>) - Method in class org.springframework.yarn.am.cluster.ContainerClusterStateMachineConfiguration
-
- configure(StateMachineTransitionConfigurer<ClusterState, ClusterEvent>) - Method in class org.springframework.yarn.am.cluster.ContainerClusterStateMachineConfiguration
-
- configure(YarnConfigConfigurer) - Method in class org.springframework.yarn.boot.YarnClientAutoConfiguration.SpringYarnConfig
-
- configure(YarnResourceLocalizerConfigurer) - Method in class org.springframework.yarn.boot.YarnClientAutoConfiguration.SpringYarnConfig
-
- configure(YarnEnvironmentConfigurer) - Method in class org.springframework.yarn.boot.YarnClientAutoConfiguration.SpringYarnConfig
-
- configure(YarnClientConfigurer) - Method in class org.springframework.yarn.boot.YarnClientAutoConfiguration.SpringYarnConfig
-
- configure(YarnConfigConfigurer) - Method in class org.springframework.yarn.boot.YarnContainerAutoConfiguration.SpringYarnConfig
-
- configure(YarnContainerConfigurer) - Method in class org.springframework.yarn.boot.YarnContainerAutoConfiguration.SpringYarnConfig
-
- configure(YarnClientBuilder) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultClientMasterRunnerConfigurer
-
- configure(YarnEnvironmentBuilder) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultEnvironmentClasspathConfigurer
-
- configure(YarnResourceLocalizerBuilder) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultLocalResourcesCopyConfigurer
-
- configure(YarnResourceLocalizerBuilder) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultLocalResourcesHdfsConfigurer
-
- configure(YarnAppmasterBuilder) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerAllocatorConfigurer
-
- configure(YarnAppmasterBuilder) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerRunnerConfigurer
-
- configure(YarnConfigConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer
-
- configure(YarnResourceLocalizerConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer
-
- configure(YarnEnvironmentConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer
-
- configure(YarnClientConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer
-
- configure(YarnAppmasterConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer
-
- configure(YarnContainerConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer
-
- configure(SpringYarnConfigBuilder) - Method in class org.springframework.yarn.config.annotation.SpringYarnConfigurerAdapter
-
- configure(YarnConfigConfigurer) - Method in class org.springframework.yarn.config.annotation.SpringYarnConfigurerAdapter
-
- configure(YarnResourceLocalizerConfigurer) - Method in class org.springframework.yarn.config.annotation.SpringYarnConfigurerAdapter
-
- configure(YarnEnvironmentConfigurer) - Method in class org.springframework.yarn.config.annotation.SpringYarnConfigurerAdapter
-
- configure(YarnClientConfigurer) - Method in class org.springframework.yarn.config.annotation.SpringYarnConfigurerAdapter
-
- configure(YarnAppmasterConfigurer) - Method in class org.springframework.yarn.config.annotation.SpringYarnConfigurerAdapter
-
- configure(YarnContainerConfigurer) - Method in class org.springframework.yarn.config.annotation.SpringYarnConfigurerAdapter
-
- configureProperties(Properties) - Method in class org.springframework.data.hadoop.config.annotation.builders.HadoopConfigBuilder
-
- configureProperties(B, Properties) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultPropertiesConfigurer
-
Configure properties.
- configureProperties(Properties) - Method in interface org.springframework.data.hadoop.config.common.annotation.configurers.PropertiesConfigurerAware
-
Configure Properties
.
- configureProperties(Properties) - Method in class org.springframework.yarn.config.annotation.builders.YarnConfigBuilder
-
- configureProperties(Properties) - Method in class org.springframework.yarn.config.annotation.builders.YarnEnvironmentBuilder
-
- configureResources(Set<Resource>) - Method in class org.springframework.data.hadoop.config.annotation.builders.HadoopConfigBuilder
-
- configureResources(B, Set<Resource>) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultResourceConfigurer
-
Configure resources.
- configureResources(Set<Resource>) - Method in interface org.springframework.data.hadoop.config.common.annotation.configurers.ResourceConfigurerAware
-
Configure Resource
s.
- configureResources(Set<Resource>) - Method in class org.springframework.yarn.config.annotation.builders.YarnConfigBuilder
-
- configureSecurity(HadoopSecurity) - Method in class org.springframework.data.hadoop.config.annotation.builders.HadoopConfigBuilder
-
- configureSecurity(B, HadoopSecurity) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultSecurityConfigurer
-
Configure security.
- configureSecurity(HadoopSecurity) - Method in interface org.springframework.data.hadoop.config.common.annotation.configurers.SecurityConfigurerAware
-
- configureSecurity(HadoopSecurity) - Method in class org.springframework.yarn.config.annotation.builders.YarnConfigBuilder
-
- CONFIGURING_POSTPROCESSOR_BEAN_NAME - Static variable in class org.springframework.yarn.config.AbstractYarnNamespaceHandler
-
- ConfiguringBeanFactoryPostProcessor - Class in org.springframework.yarn.config
-
Bean factory post processor which adds creates default task
scheduler and executor if necessary.
- ConfiguringBeanFactoryPostProcessor() - Constructor for class org.springframework.yarn.config.ConfiguringBeanFactoryPostProcessor
-
- ConfiguringBeanFactoryPostProcessorConfiguration - Class in org.springframework.yarn.config.annotation
-
- ConfiguringBeanFactoryPostProcessorConfiguration() - Constructor for class org.springframework.yarn.config.annotation.ConfiguringBeanFactoryPostProcessorConfiguration
-
- consumerEndpointFactoryBean() - Method in class org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration
-
- CONTAINER_COUNT - Static variable in class org.springframework.yarn.am.AppmasterConstants
-
Constant used to indicate number of container launched
- ContainerActivatorAnnotationPostProcessor - Class in org.springframework.yarn.config.annotation
-
- ContainerActivatorAnnotationPostProcessor(ListableBeanFactory) - Constructor for class org.springframework.yarn.config.annotation.ContainerActivatorAnnotationPostProcessor
-
- ContainerAllocateData - Class in org.springframework.yarn.am.allocate
-
Acts as a main entry point abstracting access for
ResourceRequest
s.
- ContainerAllocateData() - Constructor for class org.springframework.yarn.am.allocate.ContainerAllocateData
-
Instantiates a new container allocate data.
- ContainerAllocateDataResource - Class in org.springframework.yarn.boot.actuate.endpoint.mvc.domain
-
- ContainerAllocateDataResource() - Constructor for class org.springframework.yarn.boot.actuate.endpoint.mvc.domain.ContainerAllocateDataResource
-
- ContainerAllocationEvent - Class in org.springframework.yarn.event
-
Generic event representing that Container
has been allocated.
- ContainerAllocationEvent(Object, Container) - Constructor for class org.springframework.yarn.event.ContainerAllocationEvent
-
Constructs event with the given Container
.
- ContainerAllocator - Interface in org.springframework.yarn.am.allocate
-
General interface for container allocators.
- ContainerAllocatorListener - Interface in org.springframework.yarn.listener
-
Interface used for allocator to notify newly allocated
and completed containers.
- ContainerAssign<E> - Interface in org.springframework.yarn.am.assign
-
Interface storing and keeping data associated with
a container.
- ContainerAware - Interface in org.springframework.yarn.am.monitor
-
Interface for container monitoring components wanting
to be aware of Container
s and ContainerStatus
s.
- containerClass(Class<? extends YarnContainer>) - Method in class org.springframework.yarn.config.annotation.builders.YarnContainerBuilder
-
- containerClass(String) - Method in class org.springframework.yarn.config.annotation.builders.YarnContainerBuilder
-
- containerClass(Class<? extends YarnContainer>) - Method in interface org.springframework.yarn.config.annotation.builders.YarnContainerConfigurer
-
Specify a YarnContainer
class.
- containerClass(String) - Method in interface org.springframework.yarn.config.annotation.builders.YarnContainerConfigurer
-
Specify a YarnContainer
as a fully qualified class name.
- ContainerCluster - Interface in org.springframework.yarn.am.cluster
-
- ContainerClusterAppmaster - Interface in org.springframework.yarn.am.cluster
-
Interface for
YarnAppmaster
which is controlling
container clusters.
- ContainerClusterAppmasterAutoConfiguration - Class in org.springframework.yarn.boot
-
- ContainerClusterAppmasterAutoConfiguration() - Constructor for class org.springframework.yarn.boot.ContainerClusterAppmasterAutoConfiguration
-
- ContainerClusterAppmasterAutoConfiguration.ContainerClusterEndPointConfig - Class in org.springframework.yarn.boot
-
- ContainerClusterAppmasterAutoConfiguration.ContainerClusterEndPointConfig() - Constructor for class org.springframework.yarn.boot.ContainerClusterAppmasterAutoConfiguration.ContainerClusterEndPointConfig
-
- ContainerClusterCreateRequest - Class in org.springframework.yarn.boot.actuate.endpoint.mvc
-
- ContainerClusterCreateRequest() - Constructor for class org.springframework.yarn.boot.actuate.endpoint.mvc.ContainerClusterCreateRequest
-
- ContainerClusterInfo - Class in org.springframework.yarn.am.cluster
-
- ContainerClusterInfo(String, GridProjection) - Constructor for class org.springframework.yarn.am.cluster.ContainerClusterInfo
-
- ContainerClusterModifyRequest - Class in org.springframework.yarn.boot.actuate.endpoint.mvc
-
- ContainerClusterModifyRequest() - Constructor for class org.springframework.yarn.boot.actuate.endpoint.mvc.ContainerClusterModifyRequest
-
- ContainerClusterModifyRequest.ModifyAction - Enum in org.springframework.yarn.boot.actuate.endpoint.mvc
-
- ContainerClusterReport - Class in org.springframework.yarn.support.console
-
Utility class creating reports for container clusters.
- ContainerClusterReport.ClusterInfoField - Enum in org.springframework.yarn.support.console
-
Enums for cluster fields.
- ContainerClusterReport.ClusterInfoReportBuilder - Class in org.springframework.yarn.support.console
-
- ContainerClusterReport.ClustersInfoField - Enum in org.springframework.yarn.support.console
-
Enums for clusters fields.
- ContainerClusterReport.ClustersInfoReportBuilder - Class in org.springframework.yarn.support.console
-
- ContainerClusterReport.ClustersInfoReportData - Class in org.springframework.yarn.support.console
-
- ContainerClusterReport.ClustersInfoReportData(String, Integer, Integer, Map<String, Integer>, Map<String, Integer>, Integer, Map<String, Integer>, Map<String, Integer>) - Constructor for class org.springframework.yarn.support.console.ContainerClusterReport.ClustersInfoReportData
-
- ContainerClusterResource - Class in org.springframework.yarn.boot.actuate.endpoint.mvc.domain
-
- ContainerClusterResource() - Constructor for class org.springframework.yarn.boot.actuate.endpoint.mvc.domain.ContainerClusterResource
-
- ContainerClusterResource(ContainerCluster) - Constructor for class org.springframework.yarn.boot.actuate.endpoint.mvc.domain.ContainerClusterResource
-
- ContainerClusterStateMachineConfiguration - Class in org.springframework.yarn.am.cluster
-
- ContainerClusterStateMachineConfiguration() - Constructor for class org.springframework.yarn.am.cluster.ContainerClusterStateMachineConfiguration
-
- ContainerClusterStateResource - Class in org.springframework.yarn.boot.actuate.endpoint.mvc.domain
-
- ContainerClusterStateResource() - Constructor for class org.springframework.yarn.boot.actuate.endpoint.mvc.domain.ContainerClusterStateResource
-
- ContainerClusterStateResource(ClusterState) - Constructor for class org.springframework.yarn.boot.actuate.endpoint.mvc.domain.ContainerClusterStateResource
-
- containerCommands(String[]) - Method in class org.springframework.yarn.config.annotation.builders.YarnAppmasterBuilder
-
- containerCommands(String, String[]) - Method in class org.springframework.yarn.config.annotation.builders.YarnAppmasterBuilder
-
- containerCommands(String[]) - Method in interface org.springframework.yarn.config.annotation.builders.YarnAppmasterConfigurer
-
Specify a raw array of commands used to start a container.
- containerCommands(String, String[]) - Method in interface org.springframework.yarn.config.annotation.builders.YarnAppmasterConfigurer
-
Specify a raw array of commands used to start a container.
- ContainerCompletedEvent - Class in org.springframework.yarn.event
-
Generic event representing that Container
has been completed.
- ContainerCompletedEvent(Object, ContainerStatus) - Constructor for class org.springframework.yarn.event.ContainerCompletedEvent
-
Constructs event with the given ContainerStatus
.
- ContainerHandler - Class in org.springframework.yarn.container
-
Handler for a common object representing something to be run.
- ContainerHandler(Object) - Constructor for class org.springframework.yarn.container.ContainerHandler
-
Instantiates a new container handler.
- ContainerHandler(Object, Method) - Constructor for class org.springframework.yarn.container.ContainerHandler
-
Instantiates a new container handler.
- ContainerHandler(Object, String) - Constructor for class org.springframework.yarn.container.ContainerHandler
-
Instantiates a new container handler.
- ContainerHandler(MethodInvokingYarnContainerRuntimeProcessor<T>) - Constructor for class org.springframework.yarn.container.ContainerHandler
-
Instantiates a new container handler.
- ContainerLaunchedEvent - Class in org.springframework.yarn.event
-
Generic event representing that Container
has been launched.
- ContainerLaunchedEvent(Object, Container) - Constructor for class org.springframework.yarn.event.ContainerLaunchedEvent
-
Constructs event with the given Container
.
- ContainerLauncher - Interface in org.springframework.yarn.am.container
-
General interface for container launcher.
- ContainerLauncherInterceptor - Interface in org.springframework.yarn.am
-
Interface for interceptors that are able to view and/or modify the
ContainerLaunchContext
before the container is launched.
- ContainerLauncherRunner - Class in org.springframework.yarn.boot.support
-
CommandLineRunner
to
run
Spring Yarn container.
- ContainerLauncherRunner() - Constructor for class org.springframework.yarn.boot.support.ContainerLauncherRunner
-
- containerLauncherRunner() - Method in class org.springframework.yarn.boot.YarnContainerAutoConfiguration.RunnerConfig
-
- ContainerLaunchRequestFailedEvent - Class in org.springframework.yarn.event
-
Generic event representing that Container
launch request has failed.
- ContainerLaunchRequestFailedEvent(Object, Container) - Constructor for class org.springframework.yarn.event.ContainerLaunchRequestFailedEvent
-
Constructs event with the given Container
.
- ContainerLogUtils - Class in org.springframework.yarn.test.support
-
Utilities for checking container logs.
- ContainerLogUtils() - Constructor for class org.springframework.yarn.test.support.ContainerLogUtils
-
- ContainerMethodInvokerHelper<T> - Class in org.springframework.yarn.container
-
A helper class using spel to execute target methods.
- ContainerMethodInvokerHelper(Object, Method) - Constructor for class org.springframework.yarn.container.ContainerMethodInvokerHelper
-
- ContainerMethodInvokerHelper(Object, Method, Class<?>) - Constructor for class org.springframework.yarn.container.ContainerMethodInvokerHelper
-
- ContainerMethodInvokerHelper(Object, String) - Constructor for class org.springframework.yarn.container.ContainerMethodInvokerHelper
-
- ContainerMethodInvokerHelper(Object, String, Class<?>) - Constructor for class org.springframework.yarn.container.ContainerMethodInvokerHelper
-
- ContainerMethodInvokerHelper(Object, Class<? extends Annotation>) - Constructor for class org.springframework.yarn.container.ContainerMethodInvokerHelper
-
- ContainerMethodInvokerHelper(Object, Class<? extends Annotation>, Class<?>) - Constructor for class org.springframework.yarn.container.ContainerMethodInvokerHelper
-
- ContainerMethodInvokerHelper.ParametersWrapper - Class in org.springframework.yarn.container
-
Wrapping everything we need to work with spel.
- ContainerMethodInvokerHelper.ParametersWrapper(Map<String, String>, Properties) - Constructor for class org.springframework.yarn.container.ContainerMethodInvokerHelper.ParametersWrapper
-
- ContainerMonitor - Interface in org.springframework.yarn.am.monitor
-
General interface for components able to monitor application
and container statuses.
- ContainerMonitorListener - Interface in org.springframework.yarn.listener
-
Interface used for monitor to state of the monitor.
- ContainerMonitorListener.ContainerMonitorState - Class in org.springframework.yarn.listener
-
Class holding state info.
- ContainerMonitorListener.ContainerMonitorState(int, int, int, int) - Constructor for class org.springframework.yarn.listener.ContainerMonitorListener.ContainerMonitorState
-
Instantiates a new container monitor state.
- ContainerParser - Class in org.springframework.yarn.config
-
Simple namespace parser for yarn:container.
- ContainerParser() - Constructor for class org.springframework.yarn.config.ContainerParser
-
- containerRef(YarnContainer) - Method in class org.springframework.yarn.config.annotation.builders.YarnContainerBuilder
-
- containerRef(YarnContainer) - Method in interface org.springframework.yarn.config.annotation.builders.YarnContainerConfigurer
-
Specify a YarnContainer
reference.
- ContainerRegisterEvent - Class in org.springframework.yarn.event
-
Generic event representing that Container
has been registered.
- ContainerRegisterEvent(Object, String, String) - Constructor for class org.springframework.yarn.event.ContainerRegisterEvent
-
Instantiates a new container register event.
- ContainerRegisterInfo - Class in org.springframework.yarn.am.container
-
Domain class for keeping container register information together.
- ContainerRegisterInfo() - Constructor for class org.springframework.yarn.am.container.ContainerRegisterInfo
-
Instantiates a new container register info.
- ContainerRegisterInfo(String) - Constructor for class org.springframework.yarn.am.container.ContainerRegisterInfo
-
Instantiates a new container register info.
- ContainerRegisterResource - Class in org.springframework.yarn.boot.actuate.endpoint.mvc.domain
-
- ContainerRegisterResource() - Constructor for class org.springframework.yarn.boot.actuate.endpoint.mvc.domain.ContainerRegisterResource
-
- ContainerRegisterResource(String, String) - Constructor for class org.springframework.yarn.boot.actuate.endpoint.mvc.domain.ContainerRegisterResource
-
- ContainerRegistrar - Class in org.springframework.yarn.boot.support
-
Component which registers itself with container registrar boot endpoint.
- ContainerRegistrar(String, String) - Constructor for class org.springframework.yarn.boot.support.ContainerRegistrar
-
Instantiates a new container registrar.
- containerRegistrar() - Method in class org.springframework.yarn.boot.YarnContainerAutoConfiguration.ContainerRegistrarConfig
-
- ContainerRequestHint - Class in org.springframework.yarn.am.container
-
Helper class used to add request data hints.
- ContainerRequestHint(Object, Resource, String[], String[], Priority) - Constructor for class org.springframework.yarn.am.container.ContainerRequestHint
-
Instantiates a new container request data.
- ContainerResolver - Interface in org.springframework.yarn.am.container
-
Interface for implementations which knows how to resolve
container locations.
- ContainerRunner - Interface in org.springframework.yarn.container
-
A
ContainerRunner
is an interface against
YarnContainer
order to execute its run logic.
- ContainerShutdown - Interface in org.springframework.yarn.am.container
-
Generic strategy interface to shutdown containers.
- containerShutdown() - Method in class org.springframework.yarn.boot.YarnAppmasterAutoConfiguration.ContainerRegisterEndPointConfig
-
- ContainerStateListener - Interface in org.springframework.yarn.listener
-
Interface used for container to notify its state.
- ContainerStateListener.ContainerState - Enum in org.springframework.yarn.listener
-
Enum for container states
- containsToken(NMTokenCache, String) - Static method in class org.springframework.yarn.support.compat.NMTokenCacheCompat
-
- contextClass(Class<?>) - Method in interface org.springframework.yarn.config.annotation.configurers.ClientMasterRunnerConfigurer
-
- contextClass(Class<?>) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultClientMasterRunnerConfigurer
-
- contextClass(Class<?>) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerRunnerConfigurer
-
- contextClass(Class<?>) - Method in interface org.springframework.yarn.config.annotation.configurers.MasterContainerRunnerConfigurer
-
- contextFile(String) - Method in interface org.springframework.yarn.config.annotation.configurers.ClientMasterRunnerConfigurer
-
- contextFile(String) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultClientMasterRunnerConfigurer
-
- contextFile(String) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerRunnerConfigurer
-
- contextFile(String) - Method in interface org.springframework.yarn.config.annotation.configurers.MasterContainerRunnerConfigurer
-
- CONVERSION_SERVICE_BEAN_NAME - Static variable in class org.springframework.yarn.support.YarnContextUtils
-
- ConversionServiceCreator - Class in org.springframework.yarn.integration.convert
-
Post processor which automatically creates an instance
of conversion service if it doesn't exists.
- ConversionServiceCreator() - Constructor for class org.springframework.yarn.integration.convert.ConversionServiceCreator
-
- convert(MindRpcMessageHolder) - Method in class org.springframework.yarn.integration.convert.MindHolderToObjectConverter
-
- convert(BaseObject) - Method in class org.springframework.yarn.integration.convert.MindObjectToHolderConverter
-
- convertEntity(R) - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
Convert entity used by a reading into a entity
returned.
- convertEntity(T) - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
Convert entity to be written into a entity used
by a writer.
- convertEntity(T) - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreReader
-
- convertEntity(T) - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreWriter
-
- convertEntity(GenericRecord) - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreReader
-
- convertEntity(T) - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
-
- ConverterRegistrar - Class in org.springframework.yarn.integration.convert
-
Utility class that keeps track of a set of Converters in order to register
them with the "integrationConversionService" upon initialization.
- ConverterRegistrar(Set<Converter<?, ?>>) - Constructor for class org.springframework.yarn.integration.convert.ConverterRegistrar
-
- convertException(Exception) - Method in class org.springframework.yarn.batch.repository.AbstractRemoteDao
-
Converts given exception to Spring dao exception.
- convertExecutionContext(ExecutionContext) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertExecutionContextType(ExecutionContextType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertHbaseAccessException(Exception) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
-
- convertHbaseException(Exception) - Static method in class org.springframework.data.hadoop.hbase.HbaseUtils
-
Converts the given (Hbase) exception to an appropriate exception from org.springframework.dao hierarchy.
- convertHiveAccessException(Exception) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
-
Converts the given Hive exception to an appropriate exception from the org.springframework.dao hierarchy.
- convertJobExecutionType(JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertJobExecutionType(JobExecution, StepExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertJobExecutionType(JobExecutionType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertJobInstanceType(JobInstance) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertJobInstanceType(JobInstanceType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertJobParameters(JobParameters) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertJobParametersType(JobParametersType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertPigAccessException(IOException) - Method in class org.springframework.data.hadoop.pig.PigTemplate
-
Converts the given Pig exception to an appropriate exception from the org.springframework.dao hierarchy.
- convertPigAccessException(ExecException) - Method in class org.springframework.data.hadoop.pig.PigTemplate
-
Converts the given Pig exception to an appropriate exception from the org.springframework.dao hierarchy.
- convertStepExecutionType(StepExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertStepExecutionType(StepExecution, JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertStepExecutionType(StepExecutionType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
-
- convertValue(Object, TypeDescriptor, TypeDescriptor) - Method in class org.springframework.yarn.support.BeanFactoryTypeConverter
-
- convertYarnAccessException(YarnRuntimeException) - Static method in class org.springframework.yarn.support.YarnUtils
-
Converts YarnRuntimeException
to a Spring dao exception.
- convertYarnAccessException(IOException) - Static method in class org.springframework.yarn.support.YarnUtils
-
Converts IOException
to a Spring dao exception.
- convertYarnAccessException(RemoteException) - Static method in class org.springframework.yarn.support.YarnUtils
-
Converts RemoteException
to a Spring dao exception.
- convertYarnAccessException(YarnException) - Static method in class org.springframework.yarn.support.YarnUtils
-
Converts YarnException
to a Spring dao exception.
- copy(EnumSet<DistCp.Preserve>, Boolean, Boolean, Boolean, Boolean, String...) - Method in class org.springframework.data.hadoop.fs.DistCp
-
Copies the given resources using the given parameters.
- copy(EnumSet<DistCp.Preserve>, Boolean, Boolean, String, Integer, Boolean, Boolean, Boolean, Long, Long, String, String...) - Method in class org.springframework.data.hadoop.fs.DistCp
-
Copies the given resources using the given parameters.
- copy(Boolean, Boolean, Boolean, Boolean, Boolean, Boolean, Boolean, String, Integer, Boolean, Boolean, Boolean, Long, Long, String, String...) - Method in class org.springframework.data.hadoop.fs.DistCp
-
Copies the given resources using the given parameters.
- copy(String, String) - Method in class org.springframework.data.hadoop.fs.DistCp
-
Initiate a basic copy operation, between a source and a destination using
the defaults.
- copy(String, String, String) - Method in class org.springframework.data.hadoop.fs.DistCp
-
Initiate a basic copy operation, between two sources and a destination
using the defaults.
- copy(String...) - Method in class org.springframework.data.hadoop.fs.DistCp
-
Initiate a copy operation using a command-line style (arguments are
specified as String
s).
- copy(InputStream, DataStoreWriter<byte[]>) - Static method in class org.springframework.data.hadoop.store.support.StoreUtils
-
Copy the contents of the given InputStream to the given DataStoreWriter.
- copy(String, String, boolean) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultLocalResourcesCopyConfigurer
-
- copy(String[], String, boolean) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultLocalResourcesCopyConfigurer
-
- copy(String, String, boolean) - Method in interface org.springframework.yarn.config.annotation.configurers.LocalResourcesCopyConfigurer
-
- copy(String[], String, boolean) - Method in interface org.springframework.yarn.config.annotation.configurers.LocalResourcesCopyConfigurer
-
- copy() - Method in class org.springframework.yarn.fs.AbstractResourceLocalizer
-
- copy() - Method in interface org.springframework.yarn.fs.SmartResourceLocalizer
-
If resource localizer has knowledge to copy files
into file system, calling this method effectively
should do all tasks for that specific functionality.
- copyFromLocal(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- copyFromLocal(String, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- copyFromLocalFile(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyFromLocalFile(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyFromLocalFile(boolean, Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyFromLocalFile(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyFromLocalFile(boolean, boolean, Path[], Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyFromLocalFile(boolean, boolean, String[], String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyFromLocalFile(boolean, boolean, Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyFromLocalFile(boolean, boolean, String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyStream(InputStream, DataStoreWriter<byte[]>) - Static method in class org.springframework.data.hadoop.store.support.StoreUtils
-
Copy the contents of the given InputStream to the given DataStoreWriter.
- copyToLocal(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- copyToLocal(boolean, boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- copyToLocalFile(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyToLocalFile(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyToLocalFile(boolean, Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- copyToLocalFile(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- count(String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- count(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- count(boolean, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- count(boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- count - Variable in class org.springframework.yarn.batch.repository.bindings.exp.FindJobInstancesByJobNameReq
-
- count - Variable in class org.springframework.yarn.batch.repository.bindings.exp.GetJobInstanceCountRes
-
- count - Variable in class org.springframework.yarn.batch.repository.bindings.exp.GetJobInstancesReq
-
- count - Variable in class org.springframework.yarn.batch.repository.bindings.repo.GetStepExecutionCountRes
-
- countDownLatch() - Method in class org.springframework.yarn.boot.support.CommandLineRunnerSupport
-
Count down current latch by one.
- cp(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- cp(String, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- create(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(String, boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(Path, boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(String, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(Path, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(String, short) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(Path, short) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(String, short, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(Path, short, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(String, boolean, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(Path, boolean, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(Path, boolean, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(String, boolean, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(Path, boolean, int, short, long) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(String, boolean, int, short, long) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(Path, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(String, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- create(String, FsPermission, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- createClassLoaderForJar(Resource, ClassLoader, Configuration) - Method in class org.springframework.data.hadoop.mapreduce.JarExecutor
-
- createCluster(ContainerClusterCreateRequest) - Method in class org.springframework.yarn.boot.actuate.endpoint.mvc.YarnContainerClusterMvcEndpoint
-
Creates a new container cluster.
- createCluster(String, String, ProjectionData, Map<String, Object>) - Method in class org.springframework.yarn.boot.actuate.endpoint.YarnContainerClusterEndpoint
-
- createConfiguration(Configuration) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
Creates a configuration instance potentially using the existing one (passed as an argument - which can be null).
- createConfiguration(Configuration) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
-
Creates a configuration instance potentially using the existing one (passed as an argument - which can be null).
- createContainerCluster(String, ProjectionData) - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- createContainerCluster(String, String, ProjectionData, Map<String, Object>) - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- createContainerCluster(String, ProjectionData) - Method in interface org.springframework.yarn.am.cluster.ContainerClusterAppmaster
-
- createContainerCluster(String, String, ProjectionData, Map<String, Object>) - Method in interface org.springframework.yarn.am.cluster.ContainerClusterAppmaster
-
- createElementDescription(Element) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
-
Provides a user friendly description of an element based on its node name
and, if available, its "id" attribute value.
- createEnvironment() - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
-
Creates the Map
to be returned from this factory bean.
- createExecutionContext(Resource, Split) - Method in class org.springframework.yarn.batch.partition.AbstractPartitioner
-
Creates the execution context.
- createExecutionContext(Path, Split) - Method in class org.springframework.yarn.batch.partition.AbstractPartitioner
-
Creates the execution context.
- createFrom(Configuration, Properties) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
-
Creates a new Configuration
based on the given arguments.
- createFrom(Configuration, Properties) - Static method in class org.springframework.data.hadoop.configuration.JobConfUtils
-
Creates a new JobConf
based on the given arguments.
- createFrom(Configuration, Properties) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
-
Creates a new Configuration
based on the given arguments.
- createFrom(YarnConfiguration, Properties) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
-
Creates a new YarnConfiguration
based on the given arguments.
- createHiveClient() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
-
- createHiveClient() - Method in class org.springframework.data.hadoop.hive.HiveTemplate
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.CodecFileNamingStrategy
-
- createInstance() - Method in interface org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategyFactory
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.rollover.AbstractRolloverStrategy
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.rollover.NoRolloverStrategy
-
- createInstance() - Method in interface org.springframework.data.hadoop.store.strategy.rollover.RolloverStrategyFactory
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy
-
- createJobExecution(String, JobParameters) - Method in class org.springframework.yarn.batch.repository.RemoteJobRepository
-
- createJobExecution(JobInstance, JobParameters, String) - Method in class org.springframework.yarn.batch.repository.RemoteJobRepository
-
- CreateJobExecutionReq - Class in org.springframework.yarn.batch.repository.bindings.repo
-
Request binding for JobRepository.createJobExecution(String, JobParameters)
.
- CreateJobExecutionReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.repo.CreateJobExecutionReq
-
- CreateJobExecutionRes - Class in org.springframework.yarn.batch.repository.bindings.repo
-
Response binding for JobRepository.createJobExecution(String, JobParameters)
.
- CreateJobExecutionRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.repo.CreateJobExecutionRes
-
- CreateJobExecutionWithJobInstanceReq - Class in org.springframework.yarn.batch.repository.bindings.repo
-
Request binding for JobRepository.createJobExecution(JobInstance, JobParameters, String)
.
- CreateJobExecutionWithJobInstanceReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.repo.CreateJobExecutionWithJobInstanceReq
-
- CreateJobExecutionWithJobInstanceRes - Class in org.springframework.yarn.batch.repository.bindings.repo
-
Response binding for JobRepository.createJobExecution(String, JobParameters)
.
- CreateJobExecutionWithJobInstanceRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.repo.CreateJobExecutionWithJobInstanceRes
-
- createJobInstance(String, JobParameters) - Method in class org.springframework.yarn.batch.repository.RemoteJobRepository
-
- CreateJobInstanceReq - Class in org.springframework.yarn.batch.repository.bindings.repo
-
Request binding for JobRepository.createJobExecution(String, JobParameters)
.
- CreateJobInstanceReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.repo.CreateJobInstanceReq
-
- CreateJobInstanceRes - Class in org.springframework.yarn.batch.repository.bindings.repo
-
Response binding for JobRepository.createJobInstance(String, JobParameters)
.
- CreateJobInstanceRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.repo.CreateJobInstanceRes
-
- createNewFile(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- createNewFile(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- createOptimalAccessor(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor
-
- createOptimalAccessor(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor
-
- createPartitions() - Method in class org.springframework.yarn.batch.partition.AbstractPartitioner
-
Creates the ExecutionContext
s for partitions.
- createPartitions() - Method in class org.springframework.yarn.batch.partition.SplitterPartitioner
-
- createPigInstance() - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
-
- createPigServer() - Method in class org.springframework.data.hadoop.pig.PigTemplate
-
- createProxy() - Method in class org.springframework.yarn.rpc.YarnRpcAccessor
-
Creates the proxy.
- createReader() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
Creates a DatasetReader
.
- createReader() - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreReader
-
- createReader() - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreReader
-
- createReader(InputStream) - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
-
Creates the reader.
- createRequestData(Set<StepExecution>) - Method in class org.springframework.yarn.batch.partition.AbstractPartitionHandler
-
- createRequestData(Set<StepExecution>) - Method in class org.springframework.yarn.batch.partition.SplitterPartitionHandler
-
- createSplits(StepExecutionSplitter, StepExecution) - Method in class org.springframework.yarn.batch.partition.AbstractPartitionHandler
-
Creates the splits.
- createSplits(StepExecutionSplitter, StepExecution) - Method in class org.springframework.yarn.batch.partition.SplitterPartitionHandler
-
- createSplits(StepExecutionSplitter, StepExecution) - Method in class org.springframework.yarn.batch.partition.StaticPartitionHandler
-
- createStandardEvaluationContext() - Static method in class org.springframework.yarn.support.ExpressionUtils
-
Used to create a context with no BeanFactory, usually in tests.
- createStandardEvaluationContext(BeanFactory) - Static method in class org.springframework.yarn.support.ExpressionUtils
-
Obtains the context from the beanFactory if not null; emits a warning if the beanFactory
is null.
- createTime - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
-
- createWriter() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
Creates a DatasetWriter
.
- createWriter() - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreWriter
-
- createWriter() - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
-
- createWriter(Configuration, Path, CodecInfo) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
Need to be implemented by a subclass for an actual writer.
- createWriter(Configuration, Path, CodecInfo) - Method in class org.springframework.data.hadoop.store.output.PartitionTextFileWriter
-
- CSV - Static variable in class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
-
CSV Mode
- CSV - Static variable in class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
-
CSV Mode
- custom(PartitionStrategy<?, ?>) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultPartitionStrategyConfigurer
-
- custom(PartitionStrategy<?, ?>) - Method in interface org.springframework.data.hadoop.store.config.annotation.configurers.PartitionStrategyConfigurer
-
- customAppmasterClass() - Method in class org.springframework.yarn.boot.YarnAppmasterAutoConfiguration.RuntimeConfig
-
- customContainerClass() - Method in class org.springframework.yarn.boot.YarnContainerAutoConfiguration.RuntimeConfig
-
- CustomResourceLoaderRegistrar - Class in org.springframework.data.hadoop.fs
-
Utility class that overrides the built-in
ResourceEditor
to allow
HdfsResourceLoader
to be searched first.
- CustomResourceLoaderRegistrar() - Constructor for class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar
-