- DataReader<T> - Interface in org.springframework.data.hadoop.store
-
A DataReader
is an interface for reader implementation
able to read entities from a store.
- DatasetDefinition - Class in org.springframework.data.hadoop.store.dataset
-
Class to define the options for a Dataset
- DatasetDefinition() - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetDefinition(boolean) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetDefinition(boolean, String) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetDefinition(Class<?>, boolean, String) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetDefinition(Class<?>, PartitionStrategy) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetDefinition(Class<?>, String, PartitionStrategy) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetOperations - Interface in org.springframework.data.hadoop.store.dataset
-
Interface specifying a basic set of Dataset
operations against a specific
DatasetRepository
.
- DatasetRepositoryCallback - Interface in org.springframework.data.hadoop.store.dataset
-
Callback interface for code that operates on a DatasetRepository
.
- DatasetRepositoryFactory - Class in org.springframework.data.hadoop.store.dataset
-
Factory class responsible for creating DatasetRepository
instances.
- DatasetRepositoryFactory() - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory
-
- DatasetStoreObjectSupport - Class in org.springframework.data.hadoop.store.dataset
-
Support class adding timeout poller functionality.
- DatasetStoreObjectSupport() - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetStoreObjectSupport
-
- DatasetTemplate - Class in org.springframework.data.hadoop.store.dataset
-
This is the central class in the store.dataset package.
- DatasetTemplate() - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- DatasetTemplate(DatasetRepositoryFactory) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- DatasetTemplate(DatasetRepositoryFactory, DatasetDefinition) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- DatasetUtils - Class in org.springframework.data.hadoop.store.dataset
-
This is a utility class in the store.dataset package.
- DatasetUtils() - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetUtils
-
- DataStoreItemReader<T> - Class in org.springframework.yarn.batch.item
-
Implementation of ItemReader
able
to read items from HDFS file splits.
- DataStoreItemReader() - Constructor for class org.springframework.yarn.batch.item.DataStoreItemReader
-
Instantiates a new data store item reader.
- DataStoreItemReader(DataStoreReader<T>) - Constructor for class org.springframework.yarn.batch.item.DataStoreItemReader
-
Instantiates a new data store item reader.
- DataStoreReader<T> - Interface in org.springframework.data.hadoop.store
-
A DataStoreReader
is an extension of DataReader
adding methods from Closeable
interface.
- DataStoreTextWriterBuilder - Class in org.springframework.data.hadoop.store.config.annotation.builders
-
- DataStoreTextWriterBuilder() - Constructor for class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
Instantiates a new data store writer builder.
- DataStoreTextWriterBuilder(ObjectPostProcessor<Object>) - Constructor for class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
Instantiates a new data store writer builder.
- DataStoreTextWriterConfigurer - Interface in org.springframework.data.hadoop.store.config.annotation.builders
-
- DataStoreWriter<T> - Interface in org.springframework.data.hadoop.store
-
A DataStoreWriter
is an extension of DataWriter
adding methods from Flushable
and Closeable
interfaces.
- DataWriter<T> - Interface in org.springframework.data.hadoop.store
-
A DataWriter
is an interface for writer implementation
able to write entities into a store.
- dateFormat(String, Integer) - Static method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
-
- dateFormat(String, Long) - Static method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
-
- dateFormat(String, Date) - Static method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
-
- dateFormat(String, String) - Static method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
-
- dateFormat(String, String, String) - Static method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
-
- dateFormat(String) - Method in class org.springframework.data.hadoop.store.expression.MessageExpressionMethods.MessageWrappedMessage
-
- DateFormatMethodExecutor - Class in org.springframework.data.hadoop.store.expression
-
A MethodExecutor
handling formatting using a SimpleDateFormat
.
- DateFormatMethodExecutor() - Constructor for class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
-
Instantiates a new date format method executor.
- DateFormatMethodExecutor(String) - Constructor for class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
-
Instantiates a new date format method executor.
- decode(String) - Static method in class org.springframework.data.hadoop.util.ResourceUtils
-
Decodes the given encoded source String into an URI.
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnClusterCreateCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnClusterDestroyCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnClusterInfoCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnClusterModifyCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnClustersInfoCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnClusterStartCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnClusterStopCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnKillCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnPushCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnPushedCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnShutdownCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnSubmitCommand
-
- DEFAULT_COMMAND - Static variable in class org.springframework.yarn.boot.cli.YarnSubmittedCommand
-
- DEFAULT_CONTAINER_SHUTDOWN - Static variable in class org.springframework.yarn.YarnSystemConstants
-
Default bean id for Yarn container shutdown.
- 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_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnClusterCreateCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnClusterDestroyCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnClusterInfoCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnClusterModifyCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnClustersInfoCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnClusterStartCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnClusterStopCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnKillCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnPushCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnPushedCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnShutdownCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnSubmitCommand
-
- DEFAULT_DESC - Static variable in class org.springframework.yarn.boot.cli.YarnSubmittedCommand
-
- 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.data.hadoop.test.HadoopTestSystemConstants
-
Default id for mini hadoop cluster.
- 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.data.hadoop.HadoopSystemConstants
-
Default bean id for hadoop configuration.
- 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_CONTAINER_CLASS - Static variable in class org.springframework.yarn.YarnSystemConstants
-
Default bean id for container class.
- DEFAULT_ID_CONTAINER_REF - Static variable in class org.springframework.yarn.YarnSystemConstants
-
Default bean id for container ref.
- 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.data.hadoop.store.StoreSystemConstants
-
Default bean id for store event publisher.
- DEFAULT_ID_EVENT_PUBLISHER - Static variable in class org.springframework.yarn.YarnSystemConstants
-
Default bean id for Yarn event publisher.
- DEFAULT_ID_FSSHELL - Static variable in class org.springframework.data.hadoop.HadoopSystemConstants
-
Default bean id for hadoop fsshell.
- DEFAULT_ID_LOCAL_RESOURCES - Static variable in class org.springframework.yarn.YarnSystemConstants
-
Default bean id for resource localizer.
- DEFAULT_ID_MINIHADOOPCLUSTER - Static variable in class org.springframework.data.hadoop.test.HadoopTestSystemConstants
-
Default bean id for mini hadoop cluster.
- DEFAULT_ID_MINIHADOOPCLUSTER_CONFIG - Static variable in class org.springframework.data.hadoop.test.HadoopTestSystemConstants
-
Default bean id for mini hadoop cluster configured configuration.
- 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_ID_RESOURCE_LOADER - Static variable in class org.springframework.data.hadoop.HadoopSystemConstants
-
Default bean id for resource loader.
- DEFAULT_ID_RESOURCE_LOADER_REGISTRAR - Static variable in class org.springframework.data.hadoop.HadoopSystemConstants
-
Default bean id for resource loader registrar.
- DEFAULT_ID_RESTTEMPLATE - Static variable in class org.springframework.yarn.YarnSystemConstants
-
Default bean id for yarn specific rest template.
- DEFAULT_MAX_OPEN_ATTEMPTS - Static variable in class org.springframework.data.hadoop.store.output.AbstractDataStreamWriter
-
- DEFAULT_SPLIT_SLOP - Static variable in class org.springframework.data.hadoop.store.split.SlopBlockSplitter
-
- 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(Configuration) - Constructor for class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker
-
Instantiates a new default allocate count tracker.
- DefaultAllocateCountTracker(String, Configuration) - Constructor for class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker
-
- DefaultAllocateCountTracker.AllocateCountInfo - Class in org.springframework.yarn.am.allocate
-
- DefaultAllocateCountTracker.AllocateCountInfo() - Constructor for class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker.AllocateCountInfo
-
- DefaultApplicationYarnClient - Class in org.springframework.yarn.client
-
- DefaultApplicationYarnClient(ClientRmOperations) - Constructor for class org.springframework.yarn.client.DefaultApplicationYarnClient
-
Instantiates a new default application yarn client.
- DefaultBatchYarnContainer - Class in org.springframework.yarn.batch.container
-
- DefaultBatchYarnContainer() - Constructor for class org.springframework.yarn.batch.container.DefaultBatchYarnContainer
-
- DefaultClientMasterRunnerConfigurer - Class in org.springframework.yarn.config.annotation.configurers
-
- DefaultClientMasterRunnerConfigurer() - Constructor for class org.springframework.yarn.config.annotation.configurers.DefaultClientMasterRunnerConfigurer
-
- DefaultCodecInfo - Class in org.springframework.data.hadoop.store.codec
-
A default CodecInfo
implementation.
- DefaultCodecInfo(String, boolean, String) - Constructor for class org.springframework.data.hadoop.store.codec.DefaultCodecInfo
-
Instantiates a new default codec info.
- 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
-
- DefaultContainerAssign() - Constructor for class org.springframework.yarn.am.assign.DefaultContainerAssign
-
- DefaultContainerCluster - Class in org.springframework.yarn.am.cluster
-
- DefaultContainerCluster(String, GridProjection, StateMachine<ClusterState, ClusterEvent>) - Constructor for class org.springframework.yarn.am.cluster.DefaultContainerCluster
-
- DefaultContainerCluster(String, GridProjection, StateMachine<ClusterState, ClusterEvent>, Map<String, Object>) - Constructor for class org.springframework.yarn.am.cluster.DefaultContainerCluster
-
- 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
-
- DefaultEnvironmentClasspathConfigurer - Class in org.springframework.yarn.config.annotation.configurers
-
- DefaultEnvironmentClasspathConfigurer() - Constructor for class org.springframework.yarn.config.annotation.configurers.DefaultEnvironmentClasspathConfigurer
-
- DefaultEnvironmentClasspathConfigurer(String) - Constructor for class org.springframework.yarn.config.annotation.configurers.DefaultEnvironmentClasspathConfigurer
-
- DefaultGrid - Class in org.springframework.yarn.am.grid.support
-
Default implementation of
Grid
.
- DefaultGrid() - Constructor for class org.springframework.yarn.am.grid.support.DefaultGrid
-
- DefaultGridListener - Class in org.springframework.yarn.am.grid.listener
-
Composite listener for handling grid member events.
- DefaultGridListener() - Constructor for class org.springframework.yarn.am.grid.listener.DefaultGridListener
-
- DefaultGridMember - Class in org.springframework.yarn.am.grid.support
-
- DefaultGridMember(Container) - Constructor for class org.springframework.yarn.am.grid.support.DefaultGridMember
-
Instantiates a new default grid member.
- DefaultGridProjection - Class in org.springframework.yarn.am.grid.support
-
- DefaultGridProjection() - Constructor for class org.springframework.yarn.am.grid.support.DefaultGridProjection
-
Instantiates a new default grid projection.
- DefaultGridProjection(Configuration) - Constructor for class org.springframework.yarn.am.grid.support.DefaultGridProjection
-
Instantiates a new default grid projection.
- DefaultGridProjectionFactory - Class in org.springframework.yarn.am.grid.support
-
- DefaultGridProjectionFactory() - Constructor for class org.springframework.yarn.am.grid.support.DefaultGridProjectionFactory
-
Instantiates a new default grid projection factory.
- defaultGridProjectionFactory() - Method in class org.springframework.yarn.boot.YarnAppmasterAutoConfiguration.ContainerClusterFactoryConfig
-
- defaultId(ParserContext, Element) - Method in class org.springframework.data.hadoop.config.namespace.AbstractImprovedSimpleBeanDefinitionParser
-
- defaultId(ParserContext, Element) - Method in class org.springframework.data.hadoop.config.namespace.PigServerParser
-
- defaultId(ParserContext, Element) - Method in class org.springframework.yarn.config.LocalresourcesParser
-
- DefaultLocalResourcesCopyConfigurer - Class in org.springframework.yarn.config.annotation.configurers
-
- DefaultLocalResourcesCopyConfigurer() - Constructor for class org.springframework.yarn.config.annotation.configurers.DefaultLocalResourcesCopyConfigurer
-
- DefaultLocalResourcesCopyConfigurer.ConfiguredCopyEntry - Class in org.springframework.yarn.config.annotation.configurers
-
- DefaultLocalResourcesHdfsConfigurer - Class in org.springframework.yarn.config.annotation.configurers
-
- DefaultLocalResourcesHdfsConfigurer() - Constructor for class org.springframework.yarn.config.annotation.configurers.DefaultLocalResourcesHdfsConfigurer
-
Instantiates a new default local resources hdfs configurer.
- DefaultLocalResourcesHdfsConfigurer(String) - Constructor for class org.springframework.yarn.config.annotation.configurers.DefaultLocalResourcesHdfsConfigurer
-
Instantiates a new default local resources hdfs configurer.
- defaultLocalResourceType(LocalResourceType) - Method in class org.springframework.yarn.config.annotation.builders.YarnResourceLocalizerBuilder
-
- defaultLocalResourceVisibility(LocalResourceVisibility) - Method in class org.springframework.yarn.config.annotation.builders.YarnResourceLocalizerBuilder
-
- DefaultMasterContainerAllocatorConfigurer - Class in org.springframework.yarn.config.annotation.configurers
-
- DefaultMasterContainerAllocatorConfigurer() - Constructor for class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerAllocatorConfigurer
-
- DefaultMasterContainerAllocatorConfigurer.DefaultMasterContainerAllocatorCollectionConfigurer - Class in org.springframework.yarn.config.annotation.configurers
-
- DefaultMasterContainerAllocatorConfigurer.DefaultMasterContainerAllocatorCollectionConfigurer(String) - Constructor for class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerAllocatorConfigurer.DefaultMasterContainerAllocatorCollectionConfigurer
-
- DefaultMasterContainerRunnerConfigurer - Class in org.springframework.yarn.config.annotation.configurers
-
- DefaultMasterContainerRunnerConfigurer() - Constructor for class org.springframework.yarn.config.annotation.configurers.DefaultMasterContainerRunnerConfigurer
-
- 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
-
- DefaultMultiResourceLocalizer - Class in org.springframework.yarn.fs
-
- DefaultMultiResourceLocalizer(ResourceLocalizer, Map<String, ResourceLocalizer>) - Constructor for class org.springframework.yarn.fs.DefaultMultiResourceLocalizer
-
Instantiates a new default multi resource localizer.
- DefaultNamingStrategyConfigurer - Class in org.springframework.data.hadoop.store.config.annotation.configurers
-
- DefaultNamingStrategyConfigurer() - Constructor for class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultNamingStrategyConfigurer
-
- DefaultPartitionKey - Class in org.springframework.data.hadoop.store.partition
-
A default partition key which simply is a Map
.
- DefaultPartitionKey() - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
-
Instantiates a new default partition key.
- DefaultPartitionKey(long) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
-
Instantiates a new default partition key using
a given timestamp.
- DefaultPartitionKey(long, Object) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
-
Instantiates a new default partition key using
a given timestamp and a content object.
- DefaultPartitionKey(Object) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
-
Instantiates a new default partition key using
a content object.
- DefaultPartitionKey(Map<? extends String, ? extends Object>) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
-
Instantiates a new default partition key
with a Map
.
- DefaultPartitionStrategy<T> - Class in org.springframework.data.hadoop.store.partition
-
A
PartitionStrategy
which is used to provide a generic partitioning support using Spring SpEL.
- DefaultPartitionStrategy(Expression) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
Instantiates a new default partition strategy.
- DefaultPartitionStrategy(Expression, StandardEvaluationContext) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
Instantiates a new default partition strategy with
EvaluationContext
.
- DefaultPartitionStrategy(String) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
Instantiates a new default partition strategy.
- DefaultPartitionStrategy(String, StandardEvaluationContext) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
Instantiates a new default partition strategy with
EvaluationContext
.
- DefaultPartitionStrategy(String, StandardEvaluationContext, ExpressionParser) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
Instantiates a new default partition strategy with
EvaluationContext
and ExpressionParser
.
- DefaultPartitionStrategyConfigurer - Class in org.springframework.data.hadoop.store.config.annotation.configurers
-
- DefaultPartitionStrategyConfigurer() - Constructor for class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultPartitionStrategyConfigurer
-
- defaultPortExposingTcpSocketSupport() - Method in class org.springframework.yarn.batch.config.SimpleYarnBatchConfiguration
-
- 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
-
- DefaultProjectedGrid - Class in org.springframework.yarn.am.grid.support
-
- DefaultProjectedGrid(Grid) - Constructor for class org.springframework.yarn.am.grid.support.DefaultProjectedGrid
-
Instantiates a new default projected grid.
- DefaultProjectedGridListener - Class in org.springframework.yarn.am.grid.listener
-
Composite listener for handling container group events.
- DefaultProjectedGridListener() - Constructor for class org.springframework.yarn.am.grid.listener.DefaultProjectedGridListener
-
- DefaultPropertiesConfigurer<O,I,B extends AnnotationBuilder<O>> - Class in org.springframework.data.hadoop.config.common.annotation.configurers
-
- DefaultPropertiesConfigurer() - Constructor for class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultPropertiesConfigurer
-
- DefaultResourceConfigurer<O,I,B extends AnnotationBuilder<O>> - Class in org.springframework.data.hadoop.config.common.annotation.configurers
-
- DefaultResourceConfigurer() - Constructor for class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultResourceConfigurer
-
- 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.
- DefaultRolloverStrategyConfigurer - Class in org.springframework.data.hadoop.store.config.annotation.configurers
-
- DefaultRolloverStrategyConfigurer() - Constructor for class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultRolloverStrategyConfigurer
-
- DefaultSecurityConfigurer<O,I,B extends AnnotationBuilder<O>> - Class in org.springframework.data.hadoop.config.common.annotation.configurers
-
- DefaultSecurityConfigurer() - Constructor for class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultSecurityConfigurer
-
- DefaultStoreEventPublisher - Class in org.springframework.data.hadoop.store.event
-
The default strategy for publishing store events.
- DefaultStoreEventPublisher() - Constructor for class org.springframework.data.hadoop.store.event.DefaultStoreEventPublisher
-
Constructs default strategy without an event publisher.
- DefaultStoreEventPublisher(ApplicationEventPublisher) - Constructor for class org.springframework.data.hadoop.store.event.DefaultStoreEventPublisher
-
Constructs default strategy with an event publisher.
- DefaultYarnContainer - Class in org.springframework.yarn.container
-
- DefaultYarnContainer() - Constructor for class org.springframework.yarn.container.DefaultYarnContainer
-
- 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
-
- delete(String, String, String) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
-
Deletes a single qualifier in the given table and family.
- delete(String, String, String, String) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
-
Deletes a single cell in the given table.
- delete(String, String, String) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
-
- delete(String, String, String, String) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
-
- deleteOnExit(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- deleteOnExit(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- deleteStagingEntries() - Method in class org.springframework.yarn.fs.AbstractResourceLocalizer
-
Delete staging entries.
- DelimitedTextFileReader - Class in org.springframework.data.hadoop.store.input
-
A DelimitedTextFileReader
is a DataStoreReader
implementation
able to read String
s from a raw hdfs files as delimited fields.
- DelimitedTextFileReader(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
-
Instantiates a new delimited text file reader.
- DelimitedTextFileReader(Configuration, Path, CodecInfo, byte[]) - Constructor for class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
-
Instantiates a new delimited text file reader.
- DelimitedTextFileReader(Configuration, Path, CodecInfo, Split, byte[], byte[]) - Constructor for class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
-
Instantiates a new delimited text file reader.
- DelimitedTextFileWriter - Class in org.springframework.data.hadoop.store.output
-
A DelimitedTextFileWriter
is a DataStoreWriter
implementation
able to write String
s into raw hdfs files as delimited fields.
- DelimitedTextFileWriter(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
-
Instantiates a new delimited text file writer.
- DelimitedTextFileWriter(Configuration, Path, CodecInfo, byte[]) - Constructor for class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
-
Instantiates a new delimited text file writer.
- DelimitedTextFileWriter(Configuration, Path, CodecInfo, byte[], byte[]) - Constructor for class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
-
Instantiates a new delimited text file writer.
- delimiter(String) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultEnvironmentClasspathConfigurer
-
- delimiter(String) - Method in interface org.springframework.yarn.config.annotation.configurers.EnvironmentClasspathConfigurer
-
Specify a delimiter used in a classpath.
- DESC_APPLICATION_ID - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_APPLICATION_NAME - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_APPLICATION_TYPE - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_APPLICATION_VERSION - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_CLUSTER_DEF - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_CLUSTER_ID - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_PROJECTION_ANY - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_PROJECTION_DATA - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_PROJECTION_HOSTS - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_PROJECTION_RACKS - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_PROJECTION_TYPE - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- DESC_VERBOSE - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- deserialize(InputStream) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer
-
- destination(String) - Method in class org.springframework.yarn.config.annotation.configurers.DefaultLocalResourcesCopyConfigurer.ConfiguredCopyEntry
-
- 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.HiveClientFactoryBean
-
- 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.data.hadoop.test.support.HadoopClusterDelegatingFactoryBean
-
- destroy() - Method in class org.springframework.data.hadoop.test.support.HadoopClusterFactoryBean
-
- 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
-
- destroyCluster(String) - Method in class org.springframework.yarn.boot.actuate.endpoint.mvc.YarnContainerClusterMvcEndpoint
-
- destroyCluster(String) - Method in class org.springframework.yarn.boot.actuate.endpoint.YarnContainerClusterEndpoint
-
- destroyContainerCluster(String) - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- destroyContainerCluster(String) - Method in interface org.springframework.yarn.am.cluster.ContainerClusterAppmaster
-
- destroyWriter(Path) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
Destroys a writer with a given Path
if exist.
- determineRootDir(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
Determine the root directory for the given location.
- directChannel() - Method in class org.springframework.yarn.batch.config.SimpleYarnBatchConfiguration
-
- directChannel() - Method in class org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration
-
- DistCp - Class in org.springframework.data.hadoop.fs
-
Exposes the Hadoop command-line DistCp functionality as
an embeddable API.
- DistCp(Configuration) - Constructor for class org.springframework.data.hadoop.fs.DistCp
-
Instantiates a new DistCp.
- DistCp(Configuration, String) - Constructor for class org.springframework.data.hadoop.fs.DistCp
-
Instantiates a new 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.AbstractResourceLocalizer
-
- distribute() - Method in interface org.springframework.yarn.fs.SmartResourceLocalizer
-
If underlying implementation needs to do operations
on file system 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.
- doBuild() - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractAnnotationBuilder
-
Subclasses should implement this to perform the build.
- doBuild() - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractConfiguredAnnotationBuilder
-
- doClose() - Method in class org.springframework.data.hadoop.test.support.HadoopClusterManager
-
Bring down and un-register all the running clusters.
- 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
-
- doCreateGrid() - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- doCreateProjectedGrid(Grid) - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- doFileCopy(FileSystem) - Method in class org.springframework.yarn.fs.AbstractResourceLocalizer
-
Do file copy.
- doFileCopy(FileSystem) - Method in class org.springframework.yarn.fs.DefaultResourceLocalizer
-
- doFileTransfer(FileSystem) - Method in class org.springframework.yarn.fs.AbstractResourceLocalizer
-
Do file transfer.
- doFileTransfer(FileSystem) - Method in class org.springframework.yarn.fs.DefaultResourceLocalizer
-
- doFindMatchingFileSystemResources(Path, String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
Find all resources in the file system that match the given location pattern
via the Ant-style PathMatcher.
- doFindPathMatchingFileResources(Resource, String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
Find all resources in the hdfs file system that match the given location pattern
via the Ant-style PathMatcher.
- doInHive(HiveClient) - Method in interface org.springframework.data.hadoop.hive.HiveClientCallback
-
- doInPig(PigServer) - Method in interface org.springframework.data.hadoop.pig.PigCallback
-
- doInRecord(T) - Method in interface org.springframework.data.hadoop.store.dataset.RecordCallback
-
- doInRepository(DatasetRepository) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetRepositoryCallback
-
- doInTable(HTableInterface) - Method in interface org.springframework.data.hadoop.hbase.TableCallback
-
- doInView(Dataset<T>, Class<T>) - Method in interface org.springframework.data.hadoop.store.dataset.ViewCallback
-
- doInYarn(P) - Method in interface org.springframework.yarn.rpc.YarnRpcCallback
-
Execute callback.
- doMain(String[]) - Method in class org.springframework.yarn.boot.cli.AbstractCli
-
Main method which should be called from implementing class.
- 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.namespace.AbstractGenericOptionsParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.namespace.AbstractImprovedSimpleBeanDefinitionParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.namespace.AbstractPropertiesConfiguredBeanDefinitionParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.namespace.HadoopResourceLoaderRegistrarParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.namespace.HiveRunnerParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.namespace.JarRunnerParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.namespace.PigServerParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.namespace.ScriptParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.namespace.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
-
- doPoll() - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
-
Do poll.
- doPoll() - Method in class org.springframework.yarn.support.PollingTaskSupport
-
Do poll.
- doRead(T) - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
-
Do read.
- doRetrieveMatchingFiles(String, Path, Set<Path>) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
Recursively retrieve files that match the given pattern,
adding them to the given result list.
- doStart() - Method in class org.springframework.data.hadoop.store.dataset.DatasetStoreObjectSupport
-
- doStart() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
- doStart() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
-
Subclasses may implement this method with the start behaviour.
- doStart() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
-
- doStart() - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
-
- doStart() - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- 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.data.hadoop.store.dataset.DatasetStoreObjectSupport
-
- doStop() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
- doStop() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
-
Subclasses may implement this method with the stop behaviour.
- doStop() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
-
- 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.cluster.AbstractContainerClusterAppmaster
-
- doStop() - Method in class org.springframework.yarn.am.container.DefaultContainerLauncher
-
- doStop() - Method in class org.springframework.yarn.batch.am.BatchAppmaster
-
- doStop() - Method in class org.springframework.yarn.container.DefaultYarnContainer
-
- 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
-