A B C D E F G H I J K L M N O P Q R S T U V W Y

C

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

Constructs a ClientRmTemplate with a given yarn configuration.

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

Closes and remove HadoopCluster from a manager cache.

closeCluster(YarnCluster) - Method in class org.springframework.yarn.test.support.YarnClusterManager

Closes and remove YarnCluster from a manager cache.

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

Delegates to YarnClusterManager for handling lifecycle of YarnCluster.

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

ClusterStartAction - Class in org.springframework.yarn.am.cluster

ClusterStartAction() - Constructor for class org.springframework.yarn.am.cluster.ClusterStartAction

clusterStartAction() - Method in class org.springframework.yarn.am.cluster.ContainerClusterStateMachineConfiguration

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 Commands.

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

Default Yarn client utilising functionality in AbstractYarnClient.

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.

ConditionalOnYarnClient - Annotation Type in org.springframework.yarn.boot.condition

Conditional that only matches when presence of Hadoop Yarn Cluster is not detected or enable property is used manually.

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

Simple factory bean delegating retrieval of hadoop Configuration from a StandaloneHadoopCluster.

ConfigurationDelegatingFactoryBean() - Constructor for class org.springframework.data.hadoop.test.support.ConfigurationDelegatingFactoryBean

ConfigurationDelegatingFactoryBean - Class in org.springframework.yarn.test.support

Simple factory bean delegating retrieval of hadoop Configuration from a StandaloneYarnCluster.

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 Configuration via HadoopConfigBuilder builder.

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 the AnnotationBuilder by setting the necessary properties on the AnnotationBuilder.

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 Configuration via DataStoreTextWriterBuilder builder.

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 YarnConfiguration via YarnConfigBuilder builder.

configure(YarnResourceLocalizerConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer

Configure ResourceLocalizer via YarnResourceLocalizerBuilder builder.

configure(YarnEnvironmentConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer

Configure Map of environment via YarnEnvironmentBuilder builder.

configure(YarnClientConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer

Configure YarnClient via YarnClientBuilder builder.

configure(YarnAppmasterConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer

Configure YarnAppmaster via YarnAppmasterBuilder builder.

configure(YarnContainerConfigurer) - Method in interface org.springframework.yarn.config.annotation.SpringYarnConfigurer

Configure YarnContainer via YarnContainerBuilder builder.

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 Resources.

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

Configure HadoopSecurity.

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

Configuration which registers ConfiguringBeanFactoryPostProcessor as BeanFactoryPostProcessor order to create some default beans similarly to xml config.

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

Post-processor for Methods annotated with @OnContainerStart.

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 ResourceRequests.

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 Containers and ContainerStatuss.

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

Domain mapping for ContainerCluster.

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

Configuration for state machine build used by AbstractContainerClusterAppmaster.

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, HostInfoDiscovery) - Constructor for class org.springframework.yarn.boot.support.ContainerRegistrar

Instantiates a new container registrar.

containerRegistrar(HostInfoDiscovery) - 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

Converts a ExecutionContext to ExecutionContextType.

convertExecutionContextType(ExecutionContextType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory

Converts a ExecutionContextType to ExecutionContext.

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

Creates JobExecutionType from JobExecution.

convertJobExecutionType(JobExecution, StepExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory

Creates JobExecutionType from JobExecution.

convertJobExecutionType(JobExecutionType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory

Converts a JobExecutionType to JobExecution.

convertJobInstanceType(JobInstance) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory

Converts a JobInstance to JobInstanceType.

convertJobInstanceType(JobInstanceType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory

Converts a JobInstanceType to JobInstance.

convertJobParameters(JobParameters) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory

Converts a JobParameters to JobParametersType.

convertJobParametersType(JobParametersType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory

Converts a JobParametersType to JobParameters.

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

Creates StepExecutionType from StepExecution.

convertStepExecutionType(StepExecution, JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory

Creates StepExecutionType from StepExecution.

convertStepExecutionType(StepExecutionType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory

Converts a StepExecutionType to StepExecution.

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 Strings).

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

Creates a new instance of FileNamingStrategy.

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

Creates a new instance of RolloverStrategy.

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 ExecutionContexts 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

Subclass may override this method to assign a specific ContainerRequestHint to a StepExecution.

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

Specify a custom PartitionStrategy.

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

A B C D E F G H I J K L M N O P Q R S T U V W Y