- main(String[]) - Static method in class org.springframework.yarn.am.CommandLineAppmasterRunner
-
- main(String[]) - Static method in class org.springframework.yarn.boot.app.SpringYarnBootApplication
-
- main(String[]) - Static method in class org.springframework.yarn.client.CommandLineClientRunner
-
- main(String[]) - Static method in class org.springframework.yarn.container.CommandLineContainerRunner
-
- makeQualified(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- makeQualified(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- ManagedContainerClusterAppmaster - Class in org.springframework.yarn.am.cluster
-
- ManagedContainerClusterAppmaster() - Constructor for class org.springframework.yarn.am.cluster.ManagedContainerClusterAppmaster
-
- map(String) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultPartitionStrategyConfigurer
-
- map(String) - Method in interface org.springframework.data.hadoop.store.config.annotation.configurers.PartitionStrategyConfigurer
-
- map - Variable in class org.springframework.yarn.batch.repository.bindings.ExecutionContextType
-
- MapExpressionMethods - Class in org.springframework.data.hadoop.store.expression
-
Helper class to work with a spel expressions resolving values
from a Map
.
- MapExpressionMethods() - Constructor for class org.springframework.data.hadoop.store.expression.MapExpressionMethods
-
Instantiates a new map expression methods.
- MapExpressionMethods(EvaluationContext) - Constructor for class org.springframework.data.hadoop.store.expression.MapExpressionMethods
-
Instantiates a new map expression methods with
a EvaluationContext
which is expected to be
a StandardEvaluationContext
.
- MapExpressionMethods(StandardEvaluationContext, boolean, boolean) - Constructor for class org.springframework.data.hadoop.store.expression.MapExpressionMethods
-
- mapLine(String) - Method in interface org.springframework.yarn.batch.item.LineDataMapper
-
Implementations must implement this method to map the
provided line to the parameter type T.
- mapLine(String) - Method in class org.springframework.yarn.batch.item.PassThroughLineDataMapper
-
- MapPartitionKeyPropertyAccessor - Class in org.springframework.data.hadoop.store.expression
-
A PropertyAccessor
reading values from a backing Map
used by a
partition key.
- MapPartitionKeyPropertyAccessor() - Constructor for class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor
-
- MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor - Class in org.springframework.data.hadoop.store.expression
-
- MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor(String) - Constructor for class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor
-
- mapRow(Result, int) - Method in interface org.springframework.data.hadoop.hbase.RowMapper
-
- maskPassword(String) - Static method in class org.springframework.yarn.support.console.CommonUtils
-
Simple method to replace characters in a String with asterisks to mask the password.
- masterCommands(String...) - Method in class org.springframework.yarn.config.annotation.builders.YarnClientBuilder
-
- masterCommands(String...) - Method in interface org.springframework.yarn.config.annotation.builders.YarnClientConfigurer
-
Specify a raw array of commands used to start an application master.
- MasterContainerAllocatorConfigurer - Interface in org.springframework.yarn.config.annotation.configurers
-
- MasterContainerAllocatorConfigurer.MasterContainerAllocatorCollectionConfigurer - Interface in org.springframework.yarn.config.annotation.configurers
-
MasterContainerAllocatorCollectionConfigurer
is an interface
for
DefaultMasterContainerAllocatorCollectionConfigurer
which is
used to configure
MasterContainerAllocatorConfigurer
parameters
as an identified collection.
- MasterContainerRunnerConfigurer - Interface in org.springframework.yarn.config.annotation.configurers
-
- MasterParser - Class in org.springframework.yarn.config
-
Simple namespace parser for yarn:master.
- MasterParser() - Constructor for class org.springframework.yarn.config.MasterParser
-
- matches(Method) - Method in class org.springframework.yarn.support.UniqueMethodFilter
-
- maxMessageSize - Variable in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
-
- maySetConfigurationFromContext() - Method in class org.springframework.yarn.config.annotation.configuration.SpringYarnConfiguration
-
Sets a configuration from an ApplicationContext
if one and
only one configuration of type org.apache.hadoop.conf.Configuration
or YarnConfiguration
is found.
- memberAdded(GridMember) - Method in class org.springframework.yarn.am.grid.listener.DefaultGridListener
-
- memberAdded(GridProjection, GridMember) - Method in class org.springframework.yarn.am.grid.listener.DefaultProjectedGridListener
-
- memberAdded(GridMember) - Method in interface org.springframework.yarn.am.grid.listener.GridListener
-
Invoked when member is added into a grid.
- memberAdded(GridProjection, GridMember) - Method in interface org.springframework.yarn.am.grid.listener.ProjectedGridListener
-
Invoked when a member is added into a projection.
- memberAdded(GridProjection, GridMember) - Method in class org.springframework.yarn.am.grid.listener.ProjectedGridListenerAdapter
-
- memberRemoved(GridMember) - Method in class org.springframework.yarn.am.grid.listener.DefaultGridListener
-
- memberRemoved(GridProjection, GridMember) - Method in class org.springframework.yarn.am.grid.listener.DefaultProjectedGridListener
-
- memberRemoved(GridMember) - Method in interface org.springframework.yarn.am.grid.listener.GridListener
-
Invoked when member is removed from a grid.
- memberRemoved(GridProjection, GridMember) - Method in interface org.springframework.yarn.am.grid.listener.ProjectedGridListener
-
Invoked when a member is removed from a projection.
- memberRemoved(GridProjection, GridMember) - Method in class org.springframework.yarn.am.grid.listener.ProjectedGridListenerAdapter
-
- memory(int) - Method in class org.springframework.yarn.config.annotation.builders.YarnClientBuilder
-
- memory(String) - Method in class org.springframework.yarn.config.annotation.builders.YarnClientBuilder
-
- memory(String) - Method in interface org.springframework.yarn.config.annotation.builders.YarnClientConfigurer
-
Specify a yarn application containers memory reservation.
- memory(int) - Method in interface org.springframework.yarn.config.annotation.builders.YarnClientConfigurer
-
Specify a yarn application containers memory reservation.
- memory(String) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerAllocatorConfigurer.DefaultMasterContainerAllocatorCollectionConfigurer
-
- memory(int) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerAllocatorConfigurer.DefaultMasterContainerAllocatorCollectionConfigurer
-
- memory(String) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerAllocatorConfigurer
-
- memory(int) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerAllocatorConfigurer
-
- memory(String) - Method in interface org.springframework.yarn.config.annotation.configurers.MasterContainerAllocatorConfigurer.MasterContainerAllocatorCollectionConfigurer
-
- memory(int) - Method in interface org.springframework.yarn.config.annotation.configurers.MasterContainerAllocatorConfigurer.MasterContainerAllocatorCollectionConfigurer
-
- memory(String) - Method in interface org.springframework.yarn.config.annotation.configurers.MasterContainerAllocatorConfigurer
-
- memory(int) - Method in interface org.springframework.yarn.config.annotation.configurers.MasterContainerAllocatorConfigurer
-
- merge(Object) - Method in class org.springframework.data.hadoop.config.LinkedProperties
-
- merge(Configuration, Configuration) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
-
Creates a new Configuration
by merging the given configurations.
- merge(Configuration, Configuration) - Static method in class org.springframework.data.hadoop.configuration.JobConfUtils
-
Creates a new Configuration
by merging the given configurations.
- merge(ProjectionData) - Method in class org.springframework.yarn.am.grid.support.ProjectionData
-
Merge projection data to this instance by setting fields
from other if set.
- merge(Configuration, Configuration) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
-
Creates a new Configuration
by merging the given configurations.
- merge(Configuration, Configuration) - Static method in class org.springframework.yarn.support.YarnUtils
-
Merge configurations together.
- mergeBootArgumentsIntoMap(String[], Map) - Static method in class org.springframework.yarn.boot.support.SpringYarnBootUtils
-
- mergeHadoopPropertyIntoMap(Configuration, String, String, Map) - Static method in class org.springframework.yarn.boot.support.SpringYarnBootUtils
-
- message - Variable in class org.springframework.yarn.batch.repository.bindings.repo.UpdateExecutionContextRes
-
- MessageDateFormatMethodExecutor - Class in org.springframework.data.hadoop.store.expression
-
A MethodExecutor
handling formatting using a SimpleDateFormat
.
- MessageDateFormatMethodExecutor() - Constructor for class org.springframework.data.hadoop.store.expression.MessageDateFormatMethodExecutor
-
Instantiates a new message date format method executor.
- MessageDateFormatMethodExecutor(String) - Constructor for class org.springframework.data.hadoop.store.expression.MessageDateFormatMethodExecutor
-
Instantiates a new message date format method executor.
- MessageExpressionMethods - Class in org.springframework.data.hadoop.store.expression
-
Helper class to work with a spel expressions resolving values
from a Message
.
- MessageExpressionMethods(StandardEvaluationContext) - Constructor for class org.springframework.data.hadoop.store.expression.MessageExpressionMethods
-
Instantiates a new message expression methods with
a StandardEvaluationContext
.
- MessageExpressionMethods(StandardEvaluationContext, boolean, boolean) - Constructor for class org.springframework.data.hadoop.store.expression.MessageExpressionMethods
-
Instantiates a new message expression methods with
a StandardEvaluationContext
.
- MessageExpressionMethods.MessageWrappedMessage - Class in org.springframework.data.hadoop.store.expression
-
- MessageExpressionMethods.MessageWrappedMessage(Message<?>) - Constructor for class org.springframework.data.hadoop.store.expression.MessageExpressionMethods.MessageWrappedMessage
-
- MessagePartitionKeyMethodResolver - Class in org.springframework.data.hadoop.store.expression
-
A Message
specific MethodResolver
.
- MessagePartitionKeyMethodResolver() - Constructor for class org.springframework.data.hadoop.store.expression.MessagePartitionKeyMethodResolver
-
- MessagePartitionKeyPropertyAccessor - Class in org.springframework.data.hadoop.store.expression
-
A PropertyAccessor
reading values from a backing Message
used by a
partition key.
- MessagePartitionKeyPropertyAccessor() - Constructor for class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor
-
- MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor - Class in org.springframework.data.hadoop.store.expression
-
- MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor(String) - Constructor for class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor
-
- MessagePartitionStrategy<T> - Class in org.springframework.data.hadoop.store.partition
-
A
PartitionStrategy
which is used to provide a generic partitioning support using Spring SpEL.
- MessagePartitionStrategy(Expression, StandardEvaluationContext) - Constructor for class org.springframework.data.hadoop.store.partition.MessagePartitionStrategy
-
Instantiates a new message partition strategy with
EvaluationContext
.
- MessagePartitionStrategy(String, StandardEvaluationContext) - Constructor for class org.springframework.data.hadoop.store.partition.MessagePartitionStrategy
-
Instantiates a new message partition strategy with
EvaluationContext
.
- MessagePartitionStrategy(String, StandardEvaluationContext, ExpressionParser) - Constructor for class org.springframework.data.hadoop.store.partition.MessagePartitionStrategy
-
Instantiates a new message partition strategy with
EvaluationContext
.
- METHOD_DATEFORMAT - Static variable in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- METHOD_HASH - Static variable in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- METHOD_HASHLIST - Static variable in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- METHOD_HASHRANGE - Static variable in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- METHOD_PATH - Static variable in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- MethodAnnotationPostProcessor<T extends java.lang.annotation.Annotation> - Interface in org.springframework.yarn.config.annotation
-
Strategy interface for post-processing annotated methods.
- MethodInvokingYarnContainerRuntimeProcessor<T> - Class in org.springframework.yarn.container
-
- MethodInvokingYarnContainerRuntimeProcessor(Object, Method) - Constructor for class org.springframework.yarn.container.MethodInvokingYarnContainerRuntimeProcessor
-
- MethodInvokingYarnContainerRuntimeProcessor(Object, String) - Constructor for class org.springframework.yarn.container.MethodInvokingYarnContainerRuntimeProcessor
-
- MethodInvokingYarnContainerRuntimeProcessor(Object, Class<? extends Annotation>) - Constructor for class org.springframework.yarn.container.MethodInvokingYarnContainerRuntimeProcessor
-
- MindAppmasterService - Class in org.springframework.yarn.integration.ip.mind
-
Implementation of
AppmasterService
which handles communication
via Spring Int tcp channels using mind protocol.
- MindAppmasterService() - Constructor for class org.springframework.yarn.integration.ip.mind.MindAppmasterService
-
- MindAppmasterServiceClient - Class in org.springframework.yarn.integration.ip.mind
-
- MindAppmasterServiceClient() - Constructor for class org.springframework.yarn.integration.ip.mind.MindAppmasterServiceClient
-
- MindDataConversionException - Exception in org.springframework.yarn.integration.convert
-
Simple exception indicating errors during the conversion.
- MindDataConversionException(String, Throwable) - Constructor for exception org.springframework.yarn.integration.convert.MindDataConversionException
-
Construct a new mind data conversion exception.
- MindDataConversionException(String) - Constructor for exception org.springframework.yarn.integration.convert.MindDataConversionException
-
Construct a new mind data conversion exception.
- mindHolderToObjectConverter() - Method in class org.springframework.yarn.batch.config.SimpleYarnBatchConfiguration
-
- mindHolderToObjectConverter() - Method in class org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration
-
- MindHolderToObjectConverter - Class in org.springframework.yarn.integration.convert
-
- MindHolderToObjectConverter(ObjectMapper) - Constructor for class org.springframework.yarn.integration.convert.MindHolderToObjectConverter
-
Instantiates a new mind holder to object converter.
- MindHolderToObjectConverter(ObjectMapper, String) - Constructor for class org.springframework.yarn.integration.convert.MindHolderToObjectConverter
-
Instantiates a new mind holder to object converter.
- MindHolderToObjectConverter(ObjectMapper, String[]) - Constructor for class org.springframework.yarn.integration.convert.MindHolderToObjectConverter
-
Instantiates a new mind holder to object converter.
- mindObjectToHolderConverter() - Method in class org.springframework.yarn.batch.config.SimpleYarnBatchConfiguration
-
- mindObjectToHolderConverter() - Method in class org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration
-
- MindObjectToHolderConverter - Class in org.springframework.yarn.integration.convert
-
- MindObjectToHolderConverter(ObjectMapper) - Constructor for class org.springframework.yarn.integration.convert.MindObjectToHolderConverter
-
Constructs converter with a jackson object mapper.
- MindRpcMessageHolder - Class in org.springframework.yarn.integration.ip.mind
-
Mind request and response contains a set of headers and a content.
- MindRpcMessageHolder(Map<String, String>, String) - Constructor for class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
-
Constructs holder instance with a map of headers and a content.
- MindRpcMessageHolder(Map<String, String>, byte[]) - Constructor for class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder
-
Constructs holder instance with a map of headers and a content.
- mindRpcSerializer() - Method in class org.springframework.yarn.batch.config.SimpleYarnBatchConfiguration
-
- mindRpcSerializer() - Method in class org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration
-
- MindRpcSerializer - Class in org.springframework.yarn.integration.ip.mind
-
Spring Serializer
and Deserializer
interfaces
for mind protocol.
- MindRpcSerializer() - Constructor for class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
-
- MiniHadoopCluster - Annotation Type in org.springframework.data.hadoop.test.context
-
MiniHadoopCluster
defines class-level metadata that is
used to determine how to load and configure a mini cluster
and inject it into ApplicationContext
for test classes.
- MiniMRClusterCompat - Class in org.springframework.data.hadoop.test.support.compat
-
Compatibility class accessing minimr classes at runtime
without knowing implementations during the compile time.
- MiniMRClusterCompat() - Constructor for class org.springframework.data.hadoop.test.support.compat.MiniMRClusterCompat
-
- MiniYarnCluster - Annotation Type in org.springframework.yarn.test.context
-
MiniYarnCluster
defines class-level metadata that is
used to determine how to load and configure a mini cluster
and inject it into ApplicationContext
for test classes.
- MiniYarnClusterTest - Annotation Type in org.springframework.yarn.test.context
-
- MiniYarnClusterTest.Config - Class in org.springframework.yarn.test.context
-
- MiniYarnClusterTest.Config() - Constructor for class org.springframework.yarn.test.context.MiniYarnClusterTest.Config
-
- mkdir(String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- mkdir(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- mkdirs(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- mkdirs(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- mkdirs(Path, FsPermission) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- mkdirs(String, short) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- modifyCluster(String, ContainerClusterModifyRequest) - Method in class org.springframework.yarn.boot.actuate.endpoint.mvc.YarnContainerClusterMvcEndpoint
-
Modifies a container cluster state.
- modifyCluster(String, ProjectionData) - Method in class org.springframework.yarn.boot.actuate.endpoint.YarnContainerClusterEndpoint
-
- modifyContainerCluster(String, ProjectionData) - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- modifyContainerCluster(String, ProjectionData) - Method in interface org.springframework.yarn.am.cluster.ContainerClusterAppmaster
-
- moveFromLocal(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- moveFromLocal(String, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- moveFromLocalFile(Path[], Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- moveFromLocalFile(String[], String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- moveFromLocalFile(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- moveFromLocalFile(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- moveToLocal(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- moveToLocal(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- moveToLocalFile(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- moveToLocalFile(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- MultiLocalResourcesSelector - Interface in org.springframework.yarn.fs
-
- MultiResourceLocalizer - Interface in org.springframework.yarn.fs
-
- mv(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- mv(String, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-