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

D

decode(String) - Static method in class org.springframework.data.hadoop.util.ResourceUtils

Decodes the given encoded source String into an URI.

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

Default name of appmaster context file.

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

Default name of client context file.

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

Default name of container context file.

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

Default bean id for appmaster service.

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

Default bean id for appmaster service client.

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

Default bean id for appmaster track service.

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

Default bean id for appmaster.

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

Default bean id for client.

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

Default bean id for appmaster client service.

DEFAULT_ID_CLUSTER - Static variable in class org.springframework.yarn.test.YarnTestSystemConstants

Default id for mini yarn cluster.

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

Default bean id for resource yarn configuration.

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

Default bean id for container.

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

Default bean id for resource environment.

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

Default bean id for Yarn event publisher.

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

Default bean id for resource localizer.

DEFAULT_ID_MINIYARNCLUSTER - Static variable in class org.springframework.yarn.test.YarnTestSystemConstants

Default bean id for mini yarn cluster.

DEFAULT_ID_MINIYARNCLUSTER_CONFIG - Static variable in class org.springframework.yarn.test.YarnTestSystemConstants

Default bean id for mini yarn cluster configured configuration.

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

Default staging directory base name.

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

Default staging directory name.

DefaultAllocateCountTracker - Class in org.springframework.yarn.am.allocate

Helper class tracking allocation counts.

DefaultAllocateCountTracker() - Constructor for class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker

DefaultBatchYarnContainer - Class in org.springframework.yarn.batch.container

Default implementation of AbstractBatchYarnContainer to handle Spring Batch remote steps.

DefaultBatchYarnContainer() - Constructor for class org.springframework.yarn.batch.container.DefaultBatchYarnContainer

DefaultContainerAllocator - Class in org.springframework.yarn.am.allocate

Default allocator which polls resource manager, requests new containers and acts as a heart beat sender at the same time.

DefaultContainerAllocator() - Constructor for class org.springframework.yarn.am.allocate.DefaultContainerAllocator

DefaultContainerAssign - Class in org.springframework.yarn.am.assign

Default ContainerAssign implementation using Objects as assigned data.

DefaultContainerAssign() - Constructor for class org.springframework.yarn.am.assign.DefaultContainerAssign

DefaultContainerLauncher - Class in org.springframework.yarn.am.container

Default container launcher.

DefaultContainerLauncher() - Constructor for class org.springframework.yarn.am.container.DefaultContainerLauncher

DefaultContainerMonitor - Class in org.springframework.yarn.am.monitor

Default implementation of ContainerMonitor which simple tracks number of total and completed containers.

DefaultContainerMonitor() - Constructor for class org.springframework.yarn.am.monitor.DefaultContainerMonitor

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

defaultId(ParserContext, Element) - Method in class org.springframework.data.hadoop.config.PigServerParser

defaultId(ParserContext, Element) - Method in class org.springframework.yarn.config.LocalresourcesParser

DefaultMindAppmasterServiceClient - Class in org.springframework.yarn.integration.ip.mind

Default implementation of MindAppmasterServiceClient which handles the message serialization using type information in mind message headers.

DefaultMindAppmasterServiceClient() - Constructor for class org.springframework.yarn.integration.ip.mind.DefaultMindAppmasterServiceClient

DefaultPortExposingTcpSocketSupport - Class in org.springframework.yarn.integration.support

Implementation of TcpSocketSupport which extends its base functionality by catching socket information, like listen address and port.

DefaultPortExposingTcpSocketSupport() - Constructor for class org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport

DefaultResourceLocalizer - Class in org.springframework.yarn.fs

Default implementation of ResourceLocalizer which is only capable of re-using files already in HDFS and preparing correct parameters for created LocalResource entries.

DefaultResourceLocalizer(Configuration, Collection<LocalResourcesFactoryBean.TransferEntry>, Collection<LocalResourcesFactoryBean.CopyEntry>) - Constructor for class org.springframework.yarn.fs.DefaultResourceLocalizer

Instantiates a new default resource localizer.

DefaultResourceLocalizer(Configuration, Collection<LocalResourcesFactoryBean.TransferEntry>, Collection<LocalResourcesFactoryBean.CopyEntry>, Path) - Constructor for class org.springframework.yarn.fs.DefaultResourceLocalizer

Instantiates a new default resource localizer.

DefaultYarnEventPublisher - Class in org.springframework.yarn.event

The default strategy for publishing Yarn events.

DefaultYarnEventPublisher() - Constructor for class org.springframework.yarn.event.DefaultYarnEventPublisher

Constructs default strategy without an event publisher.

DefaultYarnEventPublisher(ApplicationEventPublisher) - Constructor for class org.springframework.yarn.event.DefaultYarnEventPublisher

Constructs default strategy with an event publisher.

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

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

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

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

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

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

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

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

destroy() - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean

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

destroy() - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader

destroy() - Method in class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean

destroy() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean

destroy() - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor

destroy() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean

destroy() - Method in class org.springframework.yarn.rpc.YarnRpcAccessor

destroy() - Method in class org.springframework.yarn.test.support.ClusterDelegatingFactoryBean

destroy() - Method in class org.springframework.yarn.test.support.YarnClusterFactoryBean

determineRootDir(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader

DistCp - Class in org.springframework.data.hadoop.fs

Exposes the Hadoop command-line distcp as an embeddable API.

DistCp(Configuration) - Constructor for class org.springframework.data.hadoop.fs.DistCp

Constructs a new DistCp instance.

DistCp(Configuration, String) - Constructor for class org.springframework.data.hadoop.fs.DistCp

DistCp.Preserve - Enum in org.springframework.data.hadoop.fs

Enumeration for the possible attributes that can be preserved by a copy operation.

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

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

If underlying implementation needs to do operations on hdfs filesystem or any other preparation work, calling of this method should make implementation ready to return resources from ResourceLocalizer.getResources() command.

DistributedCacheFactoryBean - Class in org.springframework.data.hadoop.fs

Factory for easy declarative configuration of a DistributedCache.

DistributedCacheFactoryBean() - Constructor for class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean

DistributedCacheFactoryBean.CacheEntry - Class in org.springframework.data.hadoop.fs

Class describing an entry of the distributed cache.

DistributedCacheFactoryBean.CacheEntry(DistributedCacheFactoryBean.CacheEntry.EntryType, String) - Constructor for class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean.CacheEntry

Constructs a new CacheEntry instance.

DistributedCacheFactoryBean.CacheEntry.EntryType - Enum in org.springframework.data.hadoop.fs

A distributed cache entry type.

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

Bring down and un-register all the running clusters.

doContainerRequest() - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator

Subclasses needs to implements this method to do container requests against resource manager.

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

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

Do file copy.

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

Gets a map of localized resources.

doInHive(HiveClient) - Method in interface org.springframework.data.hadoop.hive.HiveClientCallback

Gets called by HiveTemplate.execute(HiveClientCallback) with an active HiveClient.

doInPig(PigServer) - Method in interface org.springframework.data.hadoop.pig.PigCallback

Gets called by PigTemplate.execute(PigCallback) with an active PigServer.

doInTable(HTableInterface) - Method in interface org.springframework.data.hadoop.hbase.TableCallback

Gets called by HbaseTemplate execute with an active Hbase table.

doInYarn(P) - Method in interface org.springframework.yarn.rpc.YarnRpcCallback

Execute callback.

doMain(String[]) - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner

Main method visible to sub-classes.

doMindRequest(BaseObject) - Method in interface org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations

doMindRequest(BaseObject) - Method in class org.springframework.yarn.integration.ip.mind.MindAppmasterServiceClient

doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.AbstractGenericOptionsParser

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

doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.AbstractPropertiesConfiguredBeanDefinitionParser

doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.HiveRunnerParser

doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.JarRunnerParser

doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.PigServerParser

doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.ScriptParser

doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.ToolRunnerParser

doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.yarn.config.ClientParser

doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.yarn.config.ContainerParser

doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.yarn.config.LocalresourcesParser

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

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

doStart() - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator

doStart() - Method in class org.springframework.yarn.am.container.DefaultContainerLauncher

doStart() - Method in class org.springframework.yarn.am.StaticAppmaster

doStart() - Method in class org.springframework.yarn.batch.am.BatchAppmaster

doStart() - Method in class org.springframework.yarn.integration.IntegrationAppmasterService

doStart() - Method in class org.springframework.yarn.support.LifecycleObjectSupport

Subclasses may implement this method with the start behavior.

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

doStop() - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator

doStop() - Method in class org.springframework.yarn.am.container.DefaultContainerLauncher

doStop() - Method in class org.springframework.yarn.integration.IntegrationAppmasterService

doStop() - Method in class org.springframework.yarn.support.LifecycleObjectSupport

Subclasses may implement this method with the stop behavior.

doWrite(List<? extends T>) - Method in class org.springframework.data.hadoop.batch.item.HdfsItemWriter

Performs the actual write to the store via the template.

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

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

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

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

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

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