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

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

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

Proxy implementation of ExecutionContextDao.

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

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

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

Proxy implementation of JobExecutionDao.

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

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

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

A FactoryBean that automates the creation of a SimpleJobExplorer using in-memory DAO implementations.

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

Create an instance with the provided RemoteJobRepositoryFactoryBean as a source of Dao instances.

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

Create a factory with no RemoteJobRepositoryFactoryBean.

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

Proxy implementation of JobInstanceDao.

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

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

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

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

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

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

Proxy implementation of StepExecutionDao.

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

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

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.

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

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

Compat class for Resource.

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

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.

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

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() - Method in class org.springframework.yarn.container.AbstractYarnContainer

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.

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

Runs the given job.

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