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

R

raw(String, byte[], String) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultLocalResourcesCopyConfigurer

raw(Map<String, byte[]>, String) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultLocalResourcesCopyConfigurer

raw(String, byte[], String) - Method in interface org.springframework.yarn.config.annotation.configurers.LocalResourcesCopyConfigurer

raw(Map<String, byte[]>, String) - Method in interface org.springframework.yarn.config.annotation.configurers.LocalResourcesCopyConfigurer

read() - Method in interface org.springframework.data.hadoop.store.DataReader

Read next entity from a reader.

read(Class<T>, RecordCallback<T>) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetOperations

Read all records in the dataset and call the provided callback for each record.

read(Class<T>) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetOperations

Read all records in the dataset and return as a collection.

read(Class<T>, RecordCallback<T>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate

read(Class<T>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate

read() - Method in class org.springframework.data.hadoop.store.input.DelimitedTextFileReader

read() - Method in class org.springframework.data.hadoop.store.input.TextFileReader

read() - Method in class org.springframework.data.hadoop.store.input.TextSequenceFileReader

read() - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader

readBytes(InputStream, int) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer

Helper method to read bytes from a stream.

readCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType

readHeader(InputStream) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer

Reads the first line as a protocol header and parses sizes of underlying headers and content.

readHeaders(InputStream, int) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer

Reads a message headers from inputstream with a given length.

readSkipCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType

RecordCallback<T> - Interface in org.springframework.data.hadoop.store.dataset

Callback interface for code that operates on a Dataset record.

register(FileNamingStrategy) - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy

Register a new strategy.

register(RolloverStrategy) - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy

Register a new strategy.

register(T) - Method in class org.springframework.yarn.listener.AbstractCompositeListener

Register a new listener.

registerApplicationMaster(String, Integer, String) - Method in interface org.springframework.yarn.am.AppmasterRmOperations

Register application master.

registerApplicationMaster(String, Integer, String) - Method in class org.springframework.yarn.am.AppmasterRmTemplate

registerAppmaster() - Method in class org.springframework.yarn.am.AbstractAppmaster

Register appmaster.

registerBeanDefinition(BeanDefinitionHolder, BeanDefinitionRegistry) - Method in class org.springframework.data.hadoop.config.AbstractImprovedSimpleBeanDefinitionParser

registerShutdownHook() - Method in class org.springframework.data.hadoop.test.support.HadoopClusterManager

Register a jvm shutdown hook allowing manager to gracefully shutdown clusters in case that hasn't already happened.

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

Register a jvm shutdown hook allowing manager to gracefully shutdown clusters in case that hasn't already happened.

releaseContainer(ContainerId) - Method in interface org.springframework.yarn.am.allocate.ContainerAllocator

Release container.

releaseContainer(ContainerId) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator

releaseContainers(List<Container>) - Method in interface org.springframework.yarn.am.allocate.ContainerAllocator

Release containers.

releaseContainers(List<Container>) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator

releaseTable(String, HTableInterface) - Static method in class org.springframework.data.hadoop.hbase.HbaseUtils

Releases (or closes) the given table, created via the given configuration if it is not managed externally (or bound to the thread).

releaseTable(String, HTableInterface, HTableInterfaceFactory) - Static method in class org.springframework.data.hadoop.hbase.HbaseUtils

Releases (or closes) the given table, created via the given configuration if it is not managed externally (or bound to the thread).

RemoteJobExplorer - Class in org.springframework.yarn.batch.repository

RemoteJobExplorer() - Constructor for class org.springframework.yarn.batch.repository.RemoteJobExplorer

RemoteJobExplorer(AppmasterMindScOperations) - Constructor for class org.springframework.yarn.batch.repository.RemoteJobExplorer

RemoteJobRepository - Class in org.springframework.yarn.batch.repository

RemoteJobRepository() - Constructor for class org.springframework.yarn.batch.repository.RemoteJobRepository

RemoteJobRepository(AppmasterMindScOperations) - Constructor for class org.springframework.yarn.batch.repository.RemoteJobRepository

removeConfigurer(Class<C>) - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractConfiguredAnnotationBuilder

Removes and returns the AnnotationConfigurer by its class name or null if not found.

removeConfigurers(Class<C>) - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractConfiguredAnnotationBuilder

Removes all the AnnotationConfigurer instances by its class name or an empty List if not found.

rename(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

rename(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

renameFile(Path) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport

Rename file using prefix and suffix settings.

renderMapDataAsTable(List<Map<String, Object>>, List<String>) - Static method in class org.springframework.yarn.support.console.UiUtils

Renders a textual representation of the list of provided Map data

renderParameterInfoDataAsTable(Map<String, String>, boolean, int) - Static method in class org.springframework.yarn.support.console.UiUtils

renderParameterInfoDataAsTable(Map<String, String>) - Static method in class org.springframework.yarn.support.console.UiUtils

Renders a textual representation of provided parameter map.

renderTextTable(Table) - Static method in class org.springframework.yarn.support.console.UiUtils

renderTextTable(Table, boolean) - Static method in class org.springframework.yarn.support.console.UiUtils

Renders a textual representation of the provided Table

replaceExitCode(String) - Method in class org.springframework.yarn.launch.ExitStatus

Add an exit code to an existing ExitStatus.

reportContainer(Container) - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor

Notifies monitor of Container.

reportContainer(Container) - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor

reportContainerStatus(List<ContainerStatus>) - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor

Notifies monitor for new ContainerStatus.

reportContainerStatus(ContainerStatus) - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor

Notifies monitor for new ContainerStatus.

reportContainerStatus(List<ContainerStatus>) - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor

reportContainerStatus(ContainerStatus) - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor

reset() - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy

reset() - Method in class org.springframework.data.hadoop.store.strategy.naming.CodecFileNamingStrategy

reset() - Method in interface org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategy

Resets the strategy.

reset() - Method in class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy

reset() - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy

reset() - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy

reset() - Method in class org.springframework.data.hadoop.store.strategy.rollover.NoRolloverStrategy

reset() - Method in interface org.springframework.data.hadoop.store.strategy.rollover.RolloverStrategy

Reset the strategy state.

reset() - Method in class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy

reset() - Method in class org.springframework.data.hadoop.store.support.IdleTimeoutTrigger

Notify trigger that we should get into new timeout period.

resetIdleTimeout() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport

Reset idle timeout.

resmsg - Variable in class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject

Message of a response.

resolve(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy

resolve(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.CodecFileNamingStrategy

resolve(Path) - Method in interface org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategy

Resolve a current filename.

resolve(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy

resolve(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy

resolve(Map<String, Object>) - Method in interface org.springframework.yarn.am.container.ContainerResolver

Resolve resource requests.

resolve() - Method in class org.springframework.yarn.fs.DefaultResourceLocalizer

resolve() - Method in interface org.springframework.yarn.fs.ResourceLocalizer

Only resolve localized resources.

resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.data.hadoop.config.AbstractImprovedSimpleBeanDefinitionParser

resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.data.hadoop.config.HadoopResourceLoaderRegistrarParser

resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.batch.config.BatchMasterParser

resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.config.ClientParser

resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.config.ContainerParser

resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.config.MasterParser

resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.integration.config.IntegrationAmServiceClientParser

resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.integration.config.IntegrationAmServiceParser

resolvePath(Path) - Method in class org.springframework.data.hadoop.store.support.OutputContext

Resolve path.

resolveTargetObject(Class<Object>) - Method in class org.springframework.data.hadoop.mapreduce.JarExecutor

resource(Set<Resource>) - Method in interface org.springframework.data.hadoop.config.common.annotation.configurers.ResourceConfigure

resource(Resource) - Method in interface org.springframework.data.hadoop.config.common.annotation.configurers.ResourceConfigure

resource(String) - Method in interface org.springframework.data.hadoop.config.common.annotation.configurers.ResourceConfigure

resource(Set<Resource>) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.ResourceConfigurer

Adds a Set of Resources to this builder.

resource(Resource) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.ResourceConfigurer

Adds a Resource to this builder.

resource(String) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.ResourceConfigurer

Adds a Resource to this builder.

ResourceCompat - Class in org.springframework.yarn.support.compat

Compat class for Resource.

ResourceCompat() - Constructor for class org.springframework.yarn.support.compat.ResourceCompat

ResourceConfigure<I> - Interface in org.springframework.data.hadoop.config.common.annotation.configurers

Interface for ResourceConfigurer which act as intermediate gatekeeper between a user and an AnnotationConfigurer.

ResourceConfigureAware - Interface in org.springframework.data.hadoop.config.common.annotation.configurers

Interface for AnnotationBuilder which wants to be aware of Resources configured by ResourceConfigurer.

ResourceConfigurer<O,I,B extends AnnotationBuilder<O>> - Class in org.springframework.data.hadoop.config.common.annotation.configurers

AnnotationConfigurer which knows how to handle configuring a Resources.

ResourceConfigurer() - Constructor for class org.springframework.data.hadoop.config.common.annotation.configurers.ResourceConfigurer

resourceExists(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap

resourceExists(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap

resourceExists(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.ResourceTap

ResourceLocalizer - Interface in org.springframework.yarn.fs

Interface for resource localizer implementation.

resourceManagerAddress(String) - Method in class org.springframework.yarn.config.annotation.builders.YarnConfigBuilder

resourceManagerAddress(String) - Method in interface org.springframework.yarn.config.annotation.builders.YarnConfigConfigurer

Specify a Yarn resource manager address.

ResourceTap - Class in org.springframework.data.hadoop.cascading.tap.local

SourceTap for Spring's Resource abstraction.

ResourceTap(Scheme<Properties, Resource, ?, ?, ?>, Resource) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.ResourceTap

Constructs a new ResourceTap instance.

ResourceTap(Scheme<Properties, Resource, ?, ?, ?>, Resource[]) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.ResourceTap

Constructs a new ResourceTap instance.

ResourceUtils - Class in org.springframework.data.hadoop.util

Utility class for dealing or location resources for Hadoop jobs.

ResourceUtils() - Constructor for class org.springframework.data.hadoop.util.ResourceUtils

response - Variable in class org.springframework.yarn.batch.repository.bindings.repo.IsJobInstanceExistsRes

resstate - Variable in class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject

State of a response.

ResultsExtractor<T> - Interface in org.springframework.data.hadoop.hbase

Callback handling scanner results.

retrieveMatchingFiles(Path, String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader

Retrieve files that match the given path pattern, checking the given directory and its subdirectories.

reverse() - Method in class org.springframework.data.hadoop.store.support.OrderedComposite

Public getter for the list of items in reverse.

reverse() - Method in class org.springframework.yarn.listener.OrderedComposite

Public getter for the list of items in reverse.

rm(String) - Method in class org.springframework.data.hadoop.fs.FsShell

rm(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

rm(boolean, String) - Method in class org.springframework.data.hadoop.fs.FsShell

rm(boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell

rm(boolean, boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell

RM_ADDRESS - Static variable in class org.springframework.yarn.YarnSystemConstants

Default env variable for resource manager address.

rmr(String) - Method in class org.springframework.data.hadoop.fs.FsShell

rmr(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

rmr(boolean, String) - Method in class org.springframework.data.hadoop.fs.FsShell

rmr(boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell

rollbackCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType

RollingFileNamingStrategy - Class in org.springframework.data.hadoop.store.strategy.naming

A FileNamingStrategy which simply uses a rolling counter to give unique file name.

RollingFileNamingStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy

RolloverStrategy - Interface in org.springframework.data.hadoop.store.strategy.rollover

A strategy interface used for file or stream writers to determine when a file or a stream should be rolled over.

rollStrategies() - Method in class org.springframework.data.hadoop.store.support.OutputContext

Roll strategies.

RowMapper<T> - Interface in org.springframework.data.hadoop.hbase

Callback for mapping rows of a ResultScanner on a per-row basis.

RpcMessage<T> - Interface in org.springframework.yarn.am

The central interface that any RpcMessage type must implement.

run(String...) - Method in class org.springframework.yarn.boot.app.YarnBootClientInfoApplication

run(String...) - Method in class org.springframework.yarn.boot.app.YarnBootClientInstallApplication

Run a SpringApplication build by a SpringApplicationBuilder.

run(String...) - Method in class org.springframework.yarn.boot.app.YarnBootClientSubmitApplication

run(String...) - Method in class org.springframework.yarn.boot.support.AppmasterLauncherRunner

run(String...) - Method in class org.springframework.yarn.boot.support.ContainerLauncherRunner

run() - Method in class org.springframework.yarn.container.AbstractYarnContainer

run(YarnContainer) - Method in interface org.springframework.yarn.container.ContainerRunner

Run YarnContainer.

run(YarnContainer) - Method in class org.springframework.yarn.container.SimpleContainerRunner

run() - Method in interface org.springframework.yarn.container.YarnContainer

This method is called when something is ran in a container.

runInternal() - Method in class org.springframework.yarn.batch.container.DefaultBatchYarnContainer

runInternal() - Method in class org.springframework.yarn.container.AbstractYarnContainer

Internal method to handle the actual AbstractYarnContainer.run() method.

runInternal() - Method in class org.springframework.yarn.container.DefaultYarnContainer

runJob(Job) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster

Runs the given job.

runnerClass(Class<? extends AbstractCommandLineRunner<?>>) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerRunnerConfigurer

runnerClass(Class<? extends AbstractCommandLineRunner<?>>) - Method in interface org.springframework.yarn.config.annotation.configurers.MasterContainerRunnerConfigurer

runningCount() - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor

Gets a count of running containers.

runningCount() - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor

runWithSpringApplication(ApplicationContext) - Method in interface org.springframework.yarn.boot.SpringApplicationCallback

Perform an actions with a given ApplicationContext.