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

P

padRight(String, int, char) - Static method in class org.springframework.yarn.support.console.CommonUtils

Right-pad a String with a configurable padding character.

padRight(String, int) - Static method in class org.springframework.yarn.support.console.CommonUtils

Right-pad the provided String with empty spaces.

parameter - Variable in class org.springframework.yarn.batch.repository.bindings.JobParameterType

parameters - Variable in class org.springframework.yarn.batch.repository.bindings.JobParametersType

parameterType - Variable in class org.springframework.yarn.batch.repository.bindings.JobParameterType

parse(Element, ParserContext) - Method in class org.springframework.yarn.config.AbstractYarnNamespaceHandler

parseBytes(String) - Static method in class org.springframework.yarn.support.ParsingUtils

Parses the count of bytes from a string.

parseBytesAsMegs(String) - Static method in class org.springframework.yarn.support.ParsingUtils

Parses the given string as a number representing megs.

parseInnerHandlerDefinition(Element, ParserContext) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils

Parses inner bean definition from an dom element.

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

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

parseInternal(Element, ParserContext) - Method in class org.springframework.yarn.integration.config.IntegrationConverterParser

parseJarDefinition(Element, ParserContext, BeanDefinitionBuilder) - Static method in class org.springframework.data.hadoop.config.JarRunnerParser

parseScripts(ParserContext, Element) - Static method in class org.springframework.data.hadoop.config.HiveRunnerParser

parseScripts(ParserContext, Element) - Static method in class org.springframework.data.hadoop.config.PigServerParser

parseToolDefinition(Element, ParserContext, BeanDefinitionBuilder) - Static method in class org.springframework.data.hadoop.config.ToolRunnerParser

ParsingUtils - Class in org.springframework.yarn.support

Various static string and parsing utilities.

ParsingUtils() - Constructor for class org.springframework.yarn.support.ParsingUtils

partition(int) - Method in class org.springframework.yarn.batch.partition.AbstractPartitioner

PartitionedStepExecutionEvent - Class in org.springframework.yarn.batch.event

Generic event representing that partitioned StepExecution state has been changed.

PartitionedStepExecutionEvent(Object, StepExecution) - Constructor for class org.springframework.yarn.batch.event.PartitionedStepExecutionEvent

Constructs event with the given StepExecution.

PartitionedStepExecutionStateListener - Interface in org.springframework.yarn.batch.listener

Interface used for partitioned step to notify its state.

PartitionedStepExecutionStateListener.PartitionedStepExecutionState - Enum in org.springframework.yarn.batch.listener

Enum for partitioned step states

PartitionedStepExecutionStatusReq - Class in org.springframework.yarn.batch.repository.bindings

Request binding used to notify status of remote step execution.

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

PartitionedStepExecutionStatusRes - Class in org.springframework.yarn.batch.repository.bindings

Simple reply for PartitionedStepExecutionStatusReq.

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

PassThroughLineDataMapper - Class in org.springframework.yarn.batch.item

Simple LineDataMapper implementation which just passes data as it is.

PassThroughLineDataMapper() - Constructor for class org.springframework.yarn.batch.item.PassThroughLineDataMapper

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

Utility for generating date-based paths.

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

performBuild() - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractConfiguredAnnotationBuilder

Subclasses must implement this method to build the object that is being returned.

performBuild() - Method in class org.springframework.yarn.config.annotation.builders.SpringYarnConfigBuilder

performBuild() - Method in class org.springframework.yarn.config.annotation.builders.YarnAppmasterBuilder

performBuild() - Method in class org.springframework.yarn.config.annotation.builders.YarnClientBuilder

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

performBuild() - Method in class org.springframework.yarn.config.annotation.builders.YarnContainerBuilder

performBuild() - Method in class org.springframework.yarn.config.annotation.builders.YarnEnvironmentBuilder

performBuild() - Method in class org.springframework.yarn.config.annotation.builders.YarnResourceLocalizerBuilder

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

Simple utility class that fixes the File permission problem on Windows.

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

PigCallback<T> - Interface in org.springframework.data.hadoop.pig

Callback interface for Pig code.

PigContextFactoryBean - Class in org.springframework.data.hadoop.pig

Factory for creating a PigContext instance.

PigContextFactoryBean() - Constructor for class org.springframework.data.hadoop.pig.PigContextFactoryBean

PigExecutor - Class in org.springframework.data.hadoop.pig

Common class for configuring and executing pig scripts.

PigExecutor() - Constructor for class org.springframework.data.hadoop.pig.PigExecutor

PigOperations - Interface in org.springframework.data.hadoop.pig

Interface specifying a basic set of Pig operations.

PigRunner - Class in org.springframework.data.hadoop.pig

Basic runner of Pig scripts inside a Spring environment.

PigRunner() - Constructor for class org.springframework.data.hadoop.pig.PigRunner

PigScript - Class in org.springframework.data.hadoop.pig

Holder class for a pig script.

PigScript(Resource) - Constructor for class org.springframework.data.hadoop.pig.PigScript

Constructs a new PigScript instance from the given resource.

PigScript(Resource, Properties) - Constructor for class org.springframework.data.hadoop.pig.PigScript

Constructs a new PigScript instance.

PigScript(Resource, Map<?, ?>) - Constructor for class org.springframework.data.hadoop.pig.PigScript

Constructs a new PigScript instance.

PigServerFactory - Interface in org.springframework.data.hadoop.pig

Factory for retrieving a PigServer instance.

PigServerFactoryBean - Class in org.springframework.data.hadoop.pig

Factory for creating a PigServer instance.

PigServerFactoryBean() - Constructor for class org.springframework.data.hadoop.pig.PigServerFactoryBean

PigServerParser - Class in org.springframework.data.hadoop.config

Parser for 'pig-server' element.

PigServerParser() - Constructor for class org.springframework.data.hadoop.config.PigServerParser

PigTasklet - Class in org.springframework.data.hadoop.batch.pig

Pig tasklet.

PigTasklet() - Constructor for class org.springframework.data.hadoop.batch.pig.PigTasklet

PigTemplate - Class in org.springframework.data.hadoop.pig

Helper class that simplifies Pig data access code.

PigTemplate() - Constructor for class org.springframework.data.hadoop.pig.PigTemplate

Constructs a new PigTemplate instance.

PigTemplate(PigServerFactory) - Constructor for class org.springframework.data.hadoop.pig.PigTemplate

Constructs a new PigTemplate instance.

PollingTaskSupport<T> - Class in org.springframework.data.hadoop.store.support

Helper class to ease working with polling tasks executed using Spring TaskScheduler and TaskExecutor.

PollingTaskSupport(TaskScheduler, TaskExecutor) - Constructor for class org.springframework.data.hadoop.store.support.PollingTaskSupport

Instantiates a new polling task support.

PollingTaskSupport(TaskScheduler, TaskExecutor, TimeUnit, long) - Constructor for class org.springframework.data.hadoop.store.support.PollingTaskSupport

Instantiates a new polling task support.

PollingTaskSupport(TaskScheduler, TaskExecutor, Trigger) - Constructor for class org.springframework.data.hadoop.store.support.PollingTaskSupport

Instantiates a new polling task support.

PollingTaskSupport<T> - Class in org.springframework.yarn.support

Helper class to ease working with polling tasks executed using Spring TaskScheduler and TaskExecutor.

PollingTaskSupport(TaskScheduler, TaskExecutor) - Constructor for class org.springframework.yarn.support.PollingTaskSupport

Instantiates a new polling task support.

PollingTaskSupport(TaskScheduler, TaskExecutor, TimeUnit, long) - Constructor for class org.springframework.yarn.support.PollingTaskSupport

Instantiates a new polling task support.

PollingTaskSupport(TaskScheduler, TaskExecutor, Trigger) - Constructor for class org.springframework.yarn.support.PollingTaskSupport

Instantiates a new polling task support.

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

Populate node manager token cache in NMTokenCache.

PortExposingTcpSocketSupport - Interface in org.springframework.yarn.integration.support

Extension of TcpSocketSupport interface adding methods to get more information about the socket ports.

postExecution(Configuration) - Method in class org.springframework.data.hadoop.mapreduce.JarExecutor

postInstallVerify(ApplicationDescriptor) - Method in class org.springframework.yarn.client.DefaultApplicationYarnClient

Post install verify.

postProcess(P) - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractConfiguredAnnotationBuilder

Performs post processing of an object.

postProcess(O) - Method in interface org.springframework.data.hadoop.config.common.annotation.ObjectPostProcessor

Initialize the object possibly returning a modified instance that should be used instead.

postProcess(Map<String, Object>) - Method in class org.springframework.data.hadoop.scripting.HdfsScriptRunner

postProcess(Object, String, Method, OnYarnContainerStart) - Method in class org.springframework.yarn.config.annotation.ContainerActivatorAnnotationPostProcessor

postProcess(Object, String, Method, T) - Method in interface org.springframework.yarn.config.annotation.MethodAnnotationPostProcessor

Post process a bean.

postProcessAfterInitialization(Object, String) - Method in class org.springframework.yarn.config.annotation.SpringYarnAnnotationPostProcessor

postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar

postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.yarn.config.ConfiguringBeanFactoryPostProcessor

postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.yarn.integration.convert.ConversionServiceCreator

postProcessBeforeInitialization(Object, String) - Method in class org.springframework.yarn.config.annotation.SpringYarnAnnotationPostProcessor

postProcessConfiguration(Configuration) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean

postProcessServerSocket(ServerSocket) - Method in class org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport

postProcessSocket(Socket) - Method in class org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport

postRequest(BaseResponseObject) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList

Handles he post request calls.

postRequest(BaseResponseObject) - Method in interface org.springframework.yarn.batch.repository.JobRepositoryRemoteServiceInterceptor

Invoked after request is made using BaseObject and before BaseResponseObject is sent to further processing.

postSubmitVerify(ApplicationId, ApplicationDescriptor) - Method in class org.springframework.yarn.client.DefaultApplicationYarnClient

Post submit verify.

preExecution(Configuration) - Method in class org.springframework.data.hadoop.mapreduce.JarExecutor

preInstallVerify(ApplicationDescriptor) - Method in class org.springframework.yarn.client.DefaultApplicationYarnClient

Pre install verify.

preLaunch(Container, ContainerLaunchContext) - Method in class org.springframework.yarn.am.AbstractProcessingAppmaster

preLaunch(Container, ContainerLaunchContext) - Method in class org.springframework.yarn.am.container.AbstractLauncher.ContainerLauncherInterceptorList

Handles the pre launch calls.

preLaunch(Container, ContainerLaunchContext) - Method in interface org.springframework.yarn.am.ContainerLauncherInterceptor

Invoked before the ContainerLaunchContext is used to launch the container.

preLaunch(Container, ContainerLaunchContext) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster

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

Pre-process allocated containers.

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

preRequest(BaseObject) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList

Handles the pre request calls.

preRequest(BaseObject) - Method in interface org.springframework.yarn.batch.repository.JobRepositoryRemoteServiceInterceptor

Invoked after request is made using BaseObject.

presetSystemExiter(SystemExiter) - Static method in class org.springframework.yarn.launch.AbstractCommandLineRunner

Sets the SystemExiter.

preSubmitVerify(ApplicationDescriptor) - Method in class org.springframework.yarn.client.DefaultApplicationYarnClient

Pre submit verify.

priority(Integer) - Method in class org.springframework.yarn.config.annotation.builders.YarnClientBuilder

priority(Integer) - Method in interface org.springframework.yarn.config.annotation.builders.YarnClientConfigurer

Specify a yarn application priority.

priority(Integer) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerAllocatorConfigurer

priority(Integer) - Method in interface org.springframework.yarn.config.annotation.configurers.MasterContainerAllocatorConfigurer

Specify a container priority for ContainerAllocator.

process(YarnContainerRuntime) - Method in class org.springframework.yarn.container.ContainerMethodInvokerHelper

process(YarnContainerRuntime) - Method in class org.springframework.yarn.container.MethodInvokingYarnContainerRuntimeProcessor

process(YarnContainerRuntime) - Method in interface org.springframework.yarn.container.YarnContainerRuntimeProcessor

Process the container based on information available from YarnContainerRuntime.

processAllocatedContainer(Container) - Method in class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker

processJob(Job) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean

processReadCount(int) - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper

Processing a count of bytes read from a stream.

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

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

Default id for no minicluster profile.

profiles - Variable in class org.springframework.yarn.boot.app.AbstractClientApplication

profiles(String...) - Method in class org.springframework.yarn.boot.app.AbstractClientApplication

Sets an additional profiles to be used when running an SpringApplication.

properties(Properties) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultPropertiesConfigurer

Adds a Properties to this builder.

properties(Properties) - Method in interface org.springframework.data.hadoop.config.common.annotation.configurers.PropertiesConfigurer

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

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

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

Interface for AnnotationBuilder which wants to be aware of Properties configured by DefaultPropertiesConfigurer.

propertiesLocation(String...) - Method in class org.springframework.yarn.config.annotation.builders.YarnEnvironmentBuilder

propertiesLocation(String...) - Method in interface org.springframework.yarn.config.annotation.builders.YarnEnvironmentConfigurer

Specify properties locations.

propertiesToBootArguments(Properties) - Static method in class org.springframework.yarn.boot.support.SpringYarnBootUtils

property(String, String) - Method in class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultPropertiesConfigurer

Adds a property to this builder.

property(String, String) - Method in interface org.springframework.data.hadoop.config.common.annotation.configurers.PropertiesConfigurer

publishContainerAllocated(Object, Container) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher

publishContainerAllocated(Object, Container) - Method in interface org.springframework.yarn.event.YarnEventPublisher

Publish an application event containing information about the allocated Container.

publishContainerCompleted(Object, ContainerStatus) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher

publishContainerCompleted(Object, ContainerStatus) - Method in interface org.springframework.yarn.event.YarnEventPublisher

Publish an application event containing information about the completed ContainerStatus.

publishContainerLaunched(Object, Container) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher

publishContainerLaunched(Object, Container) - Method in interface org.springframework.yarn.event.YarnEventPublisher

Publish an application event containing information about the launched Container.

publishContainerLaunchRequestFailed(Object, Container) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher

publishContainerLaunchRequestFailed(Object, Container) - Method in interface org.springframework.yarn.event.YarnEventPublisher

Publish an application event containing information about the failed Container launch request.

publishEvent(AbstractStoreEvent) - Method in class org.springframework.data.hadoop.store.event.DefaultStoreEventPublisher

publishEvent(AbstractStoreEvent) - Method in interface org.springframework.data.hadoop.store.event.StoreEventPublisher

Publish a general application event of type AbstractStoreEvent.

publishEvent(AbstractYarnEvent) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher

publishEvent(AbstractYarnEvent) - Method in interface org.springframework.yarn.event.YarnEventPublisher

Publish a general application event of type AbstractYarnEvent.

put(Object, Object) - Method in class org.springframework.data.hadoop.config.LinkedProperties

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

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