- obj - Variable in class org.springframework.yarn.batch.repository.bindings.ExecutionContextType.ObjectEntry
-
- objectMapper() - Method in class org.springframework.yarn.batch.config.SimpleYarnBatchConfiguration
-
- objectMapper() - Method in class org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration
-
- objectPostProcessor(ObjectPostProcessor<Object>) - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractConfiguredAnnotationBuilder
-
- ObjectPostProcessor<T> - Interface in org.springframework.data.hadoop.config.common.annotation
-
Allows initialization of Objects.
- ObjectPostProcessorConfiguration - Class in org.springframework.data.hadoop.config.common.annotation.configuration
-
- ObjectPostProcessorConfiguration() - Constructor for class org.springframework.data.hadoop.config.common.annotation.configuration.ObjectPostProcessorConfiguration
-
- OK - Static variable in class org.springframework.yarn.launch.ExitStatus
-
Convenient constant value representing finished processing.
- onApplicationEvent(AbstractStoreEvent) - Method in class org.springframework.data.hadoop.store.event.LoggingListener
-
- onApplicationEvent(AbstractYarnEvent) - Method in class org.springframework.yarn.am.AbstractEventingAppmaster
-
- onApplicationEvent(AbstractYarnEvent) - Method in class org.springframework.yarn.batch.am.BatchAppmaster
-
- onApplicationEvent(ApplicationEvent) - Method in class org.springframework.yarn.boot.support.BootApplicationEventTransformer
-
- onApplicationEvent(EmbeddedServletContainerInitializedEvent) - Method in class org.springframework.yarn.boot.support.ContainerRegistrar
-
- onApplicationEvent(ApplicationEvent) - Method in class org.springframework.yarn.boot.support.EmbeddedAppmasterTrackService
-
- onApplicationEvent(ApplicationEnvironmentPreparedEvent) - Method in class org.springframework.yarn.boot.support.YarnBootClientApplicationListener
-
- onApplicationEvent(ApplicationEvent) - Method in class org.springframework.yarn.config.annotation.SpringYarnAnnotationPostProcessor
-
- onApplicationEvent(ContextClosedEvent) - Method in class org.springframework.yarn.container.DefaultYarnContainer
-
- onApplicationEvent(AbstractYarnEvent) - Method in class org.springframework.yarn.event.LoggingListener
-
- onConfigurers(List<AnnotationConfigurer<SpringHadoopConfigs, SpringHadoopConfigBuilder>>) - Method in class org.springframework.data.hadoop.config.annotation.configuration.SpringHadoopConfiguration
-
- onConfigurers(List<AnnotationConfigurer<O, B>>) - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractAnnotationConfiguration
-
- onConfigurers(List<AnnotationConfigurer<SpringYarnConfigs, SpringYarnConfigBuilder>>) - Method in class org.springframework.yarn.config.annotation.configuration.SpringYarnConfiguration
-
- onContainer(List<Container>) - Method in interface org.springframework.yarn.am.monitor.ContainerAware
-
Called when we potentially have new information
about a Container
s.
- onContainer(List<Container>) - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
-
- onContainerAllocated(Container) - Method in class org.springframework.yarn.am.AbstractEventingAppmaster
-
- onContainerAllocated(Container) - Method in class org.springframework.yarn.am.AbstractProcessingAppmaster
-
Called when container has been allocated.
- onContainerAllocated(Container) - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- onContainerAllocated(Container) - Method in class org.springframework.yarn.am.StaticEventingAppmaster
-
- onContainerAllocated(Container) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
-
- onContainerCompleted(ContainerStatus) - Method in class org.springframework.yarn.am.AbstractEventingAppmaster
-
- onContainerCompleted(ContainerStatus) - Method in class org.springframework.yarn.am.AbstractProcessingAppmaster
-
Called when container has been completed.
- onContainerCompleted(ContainerStatus) - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- onContainerCompleted(ContainerStatus) - Method in class org.springframework.yarn.am.StaticEventingAppmaster
-
- onContainerCompleted(ContainerStatus) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
-
- onContainerFailed(ContainerStatus) - Method in class org.springframework.yarn.am.StaticEventingAppmaster
-
Called if completed container has failed.
- onContainerLaunchCommands(Container, ContainerCluster, List<String>) - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
Called when a container is launched for sub classes to do
a final modifications in these commands.
- onContainerLaunched(Container) - Method in class org.springframework.yarn.am.AbstractEventingAppmaster
-
- onContainerLaunched(Container) - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- onContainerLaunched(Container) - Method in class org.springframework.yarn.am.StaticEventingAppmaster
-
- onContainerLaunched(Container) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
-
- onContainerLaunchRequestFailed(Container) - Method in class org.springframework.yarn.am.AbstractEventingAppmaster
-
- OnContainerStart - Annotation Type in org.springframework.yarn.annotation
-
Indicates that a method is capable of handling an operation on Yarn Container
when something needs to be executed.
- onContainerStatus(List<ContainerStatus>) - Method in interface org.springframework.yarn.am.monitor.ContainerAware
-
Called when we potentially have new information
about a ContainerStatus
s.
- onContainerStatus(List<ContainerStatus>) - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
-
- onInit() - Method in class org.springframework.data.hadoop.store.dataset.DatasetStoreObjectSupport
-
- onInit() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
- onInit() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
-
Subclasses may implement this for initialization logic.
- onInit() - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
-
- onInit() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
-
- onInit() - Method in class org.springframework.yarn.am.AbstractAppmaster
-
Global application master instance specific ApplicationAttemptId
is build during this init method.
- onInit() - Method in class org.springframework.yarn.am.AbstractEventingAppmaster
-
- onInit() - Method in class org.springframework.yarn.am.AbstractProcessingAppmaster
-
- onInit() - Method in class org.springframework.yarn.am.allocate.AbstractAllocator
-
- onInit() - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
-
- onInit() - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
-
- onInit() - Method in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
-
- onInit() - Method in class org.springframework.yarn.am.container.AbstractLauncher
-
- onInit() - Method in class org.springframework.yarn.am.container.DefaultContainerLauncher
-
- onInit() - Method in class org.springframework.yarn.am.StaticAppmaster
-
- onInit() - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
-
- onInit() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
-
Subclasses may implement this for initialization logic.
- onPollResult(T) - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
-
Callback on poll result.
- onPollResult(T) - Method in class org.springframework.yarn.support.PollingTaskSupport
-
Callback on poll result.
- open(ExecutionContext) - Method in class org.springframework.data.hadoop.batch.item.HdfsItemWriter
-
- open(String, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- open(Path, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- open(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- open(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- open(ExecutionContext) - Method in class org.springframework.yarn.batch.item.DataStoreItemReader
-
- OPT_KILL - Static variable in class org.springframework.yarn.client.CommandLineClientRunner
-
- OPT_LIST - Static variable in class org.springframework.yarn.client.CommandLineClientRunner
-
- OPT_SUBMIT - Static variable in class org.springframework.yarn.client.CommandLineClientRunner
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnClusterCreateCommand.ClusterCreateOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnClusterDestroyCommand.ClusterDestroyOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnClusterInfoCommand.ClusterInfoOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnClusterModifyCommand.ClusterModifyOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnClustersInfoCommand.ClustersInfoOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnClusterStartCommand.ClusterStartOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnClusterStopCommand.ClusterStopOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnKillCommand.KillOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnPushCommand.PushOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnShutdownCommand.ShutdownOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnSubmitCommand.SubmitOptionHandler
-
- options() - Method in class org.springframework.yarn.boot.cli.YarnSubmittedCommand.SubmittedOptionHandler
-
- OPTIONS_APPLICATION_ID - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_APPLICATION_NAME - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_APPLICATION_TYPE - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_APPLICATION_VERSION - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_CLUSTER_DEF - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_CLUSTER_ID - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_PROJECTION_ANY - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_PROJECTION_DATA - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_PROJECTION_HOSTS - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_PROJECTION_RACKS - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_PROJECTION_TYPE - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OPTIONS_VERBOSE - Static variable in class org.springframework.yarn.boot.cli.CliSystemConstants
-
- OrderedComposite<S> - Class in org.springframework.data.hadoop.store.support
-
Composite item which can be used in other components which may want to allow automatic
and annotation based ordering.
- OrderedComposite() - Constructor for class org.springframework.data.hadoop.store.support.OrderedComposite
-
- OrderedComposite<S> - Class in org.springframework.yarn.listener
-
Composite item which can be used in other components which
may want to allow automatic and annotation based ordering.
- OrderedComposite() - Constructor for class org.springframework.yarn.listener.OrderedComposite
-
- org.springframework.data.hadoop - package org.springframework.data.hadoop
-
Package providing integration of
Hadoop (and related) technologies
with Spring concepts.
- org.springframework.data.hadoop.batch.hive - package org.springframework.data.hadoop.batch.hive
-
Hadoop Batch Hive supporting classes.
- org.springframework.data.hadoop.batch.item - package org.springframework.data.hadoop.batch.item
-
Hadoop Batch Item supporting classes.
- org.springframework.data.hadoop.batch.mapreduce - package org.springframework.data.hadoop.batch.mapreduce
-
Hadoop Batch Mapreduce supporting classes.
- org.springframework.data.hadoop.batch.pig - package org.springframework.data.hadoop.batch.pig
-
Hadoop Batch Pig supporting classes.
- org.springframework.data.hadoop.batch.scripting - package org.springframework.data.hadoop.batch.scripting
-
Hadoop Batch Scripting supporting classes.
- org.springframework.data.hadoop.batch.spark - package org.springframework.data.hadoop.batch.spark
-
Hadoop Batch Spark supporting classes.
- org.springframework.data.hadoop.batch.sqoop2 - package org.springframework.data.hadoop.batch.sqoop2
-
Hadoop Batch Sqoop2 supporting classes.
- org.springframework.data.hadoop.boot - package org.springframework.data.hadoop.boot
-
- org.springframework.data.hadoop.boot.properties - package org.springframework.data.hadoop.boot.properties
-
- org.springframework.data.hadoop.config.annotation - package org.springframework.data.hadoop.config.annotation
-
- org.springframework.data.hadoop.config.annotation.builders - package org.springframework.data.hadoop.config.annotation.builders
-
- org.springframework.data.hadoop.config.annotation.configuration - package org.springframework.data.hadoop.config.annotation.configuration
-
- org.springframework.data.hadoop.config.common.annotation - package org.springframework.data.hadoop.config.common.annotation
-
- org.springframework.data.hadoop.config.common.annotation.configuration - package org.springframework.data.hadoop.config.common.annotation.configuration
-
- org.springframework.data.hadoop.config.common.annotation.configurers - package org.springframework.data.hadoop.config.common.annotation.configurers
-
- org.springframework.data.hadoop.config.namespace - package org.springframework.data.hadoop.config.namespace
-
- org.springframework.data.hadoop.configuration - package org.springframework.data.hadoop.configuration
-
Support classes for configuring Hadoop.
- org.springframework.data.hadoop.fs - package org.springframework.data.hadoop.fs
-
Hadoop FileSystem supporting classes.
- org.springframework.data.hadoop.hbase - package org.springframework.data.hadoop.hbase
-
- org.springframework.data.hadoop.hive - package org.springframework.data.hadoop.hive
-
- org.springframework.data.hadoop.mapreduce - package org.springframework.data.hadoop.mapreduce
-
Support classes for Hadoop core Map Reduce functionality such
as job (whether vanilla Map-Reduce or streaming).
- org.springframework.data.hadoop.pig - package org.springframework.data.hadoop.pig
-
- org.springframework.data.hadoop.scripting - package org.springframework.data.hadoop.scripting
-
Support classes for scripting Hadoop.
- org.springframework.data.hadoop.security - package org.springframework.data.hadoop.security
-
- org.springframework.data.hadoop.store - package org.springframework.data.hadoop.store
-
- org.springframework.data.hadoop.store.codec - package org.springframework.data.hadoop.store.codec
-
- org.springframework.data.hadoop.store.config.annotation - package org.springframework.data.hadoop.store.config.annotation
-
- org.springframework.data.hadoop.store.config.annotation.builders - package org.springframework.data.hadoop.store.config.annotation.builders
-
- org.springframework.data.hadoop.store.config.annotation.configuration - package org.springframework.data.hadoop.store.config.annotation.configuration
-
- org.springframework.data.hadoop.store.config.annotation.configurers - package org.springframework.data.hadoop.store.config.annotation.configurers
-
- org.springframework.data.hadoop.store.dataset - package org.springframework.data.hadoop.store.dataset
-
- org.springframework.data.hadoop.store.event - package org.springframework.data.hadoop.store.event
-
- org.springframework.data.hadoop.store.expression - package org.springframework.data.hadoop.store.expression
-
- org.springframework.data.hadoop.store.input - package org.springframework.data.hadoop.store.input
-
- org.springframework.data.hadoop.store.output - package org.springframework.data.hadoop.store.output
-
- org.springframework.data.hadoop.store.partition - package org.springframework.data.hadoop.store.partition
-
- org.springframework.data.hadoop.store.split - package org.springframework.data.hadoop.store.split
-
- org.springframework.data.hadoop.store.strategy.naming - package org.springframework.data.hadoop.store.strategy.naming
-
- org.springframework.data.hadoop.store.strategy.rollover - package org.springframework.data.hadoop.store.strategy.rollover
-
- org.springframework.data.hadoop.store.support - package org.springframework.data.hadoop.store.support
-
- org.springframework.data.hadoop.test - package org.springframework.data.hadoop.test
-
- org.springframework.data.hadoop.test.context - package org.springframework.data.hadoop.test.context
-
- org.springframework.data.hadoop.test.junit - package org.springframework.data.hadoop.test.junit
-
- org.springframework.data.hadoop.test.support - package org.springframework.data.hadoop.test.support
-
- org.springframework.data.hadoop.test.support.compat - package org.springframework.data.hadoop.test.support.compat
-
- org.springframework.data.hadoop.util - package org.springframework.data.hadoop.util
-
Helper classes
- org.springframework.data.hadoop.util.net - package org.springframework.data.hadoop.util.net
-
- org.springframework.yarn - package org.springframework.yarn
-
- org.springframework.yarn.am - package org.springframework.yarn.am
-
- org.springframework.yarn.am.allocate - package org.springframework.yarn.am.allocate
-
- org.springframework.yarn.am.assign - package org.springframework.yarn.am.assign
-
- org.springframework.yarn.am.cluster - package org.springframework.yarn.am.cluster
-
- org.springframework.yarn.am.container - package org.springframework.yarn.am.container
-
- org.springframework.yarn.am.grid - package org.springframework.yarn.am.grid
-
- org.springframework.yarn.am.grid.listener - package org.springframework.yarn.am.grid.listener
-
- org.springframework.yarn.am.grid.support - package org.springframework.yarn.am.grid.support
-
- org.springframework.yarn.am.monitor - package org.springframework.yarn.am.monitor
-
- org.springframework.yarn.am.track - package org.springframework.yarn.am.track
-
- org.springframework.yarn.annotation - package org.springframework.yarn.annotation
-
- org.springframework.yarn.batch - package org.springframework.yarn.batch
-
- org.springframework.yarn.batch.am - package org.springframework.yarn.batch.am
-
- org.springframework.yarn.batch.config - package org.springframework.yarn.batch.config
-
- org.springframework.yarn.batch.container - package org.springframework.yarn.batch.container
-
- org.springframework.yarn.batch.event - package org.springframework.yarn.batch.event
-
- org.springframework.yarn.batch.item - package org.springframework.yarn.batch.item
-
- org.springframework.yarn.batch.listener - package org.springframework.yarn.batch.listener
-
- org.springframework.yarn.batch.partition - package org.springframework.yarn.batch.partition
-
- org.springframework.yarn.batch.repository - package org.springframework.yarn.batch.repository
-
- org.springframework.yarn.batch.repository.bindings - package org.springframework.yarn.batch.repository.bindings
-
- org.springframework.yarn.batch.repository.bindings.exp - package org.springframework.yarn.batch.repository.bindings.exp
-
- org.springframework.yarn.batch.repository.bindings.repo - package org.springframework.yarn.batch.repository.bindings.repo
-
- org.springframework.yarn.batch.support - package org.springframework.yarn.batch.support
-
- org.springframework.yarn.boot - package org.springframework.yarn.boot
-
- org.springframework.yarn.boot.actuate.endpoint - package org.springframework.yarn.boot.actuate.endpoint
-
- org.springframework.yarn.boot.actuate.endpoint.mvc - package org.springframework.yarn.boot.actuate.endpoint.mvc
-
- org.springframework.yarn.boot.actuate.endpoint.mvc.domain - package org.springframework.yarn.boot.actuate.endpoint.mvc.domain
-
- org.springframework.yarn.boot.app - package org.springframework.yarn.boot.app
-
- org.springframework.yarn.boot.cli - package org.springframework.yarn.boot.cli
-
- org.springframework.yarn.boot.cli.shell - package org.springframework.yarn.boot.cli.shell
-
- org.springframework.yarn.boot.condition - package org.springframework.yarn.boot.condition
-
- org.springframework.yarn.boot.properties - package org.springframework.yarn.boot.properties
-
- org.springframework.yarn.boot.support - package org.springframework.yarn.boot.support
-
- org.springframework.yarn.boot.test.junit - package org.springframework.yarn.boot.test.junit
-
- org.springframework.yarn.client - package org.springframework.yarn.client
-
- org.springframework.yarn.config - package org.springframework.yarn.config
-
- org.springframework.yarn.config.annotation - package org.springframework.yarn.config.annotation
-
- org.springframework.yarn.config.annotation.builders - package org.springframework.yarn.config.annotation.builders
-
- org.springframework.yarn.config.annotation.configuration - package org.springframework.yarn.config.annotation.configuration
-
- org.springframework.yarn.config.annotation.configurers - package org.springframework.yarn.config.annotation.configurers
-
- org.springframework.yarn.configuration - package org.springframework.yarn.configuration
-
- org.springframework.yarn.container - package org.springframework.yarn.container
-
- org.springframework.yarn.event - package org.springframework.yarn.event
-
- org.springframework.yarn.fs - package org.springframework.yarn.fs
-
- org.springframework.yarn.integration - package org.springframework.yarn.integration
-
- org.springframework.yarn.integration.config - package org.springframework.yarn.integration.config
-
- org.springframework.yarn.integration.container - package org.springframework.yarn.integration.container
-
- org.springframework.yarn.integration.convert - package org.springframework.yarn.integration.convert
-
- org.springframework.yarn.integration.ip.mind - package org.springframework.yarn.integration.ip.mind
-
- org.springframework.yarn.integration.ip.mind.binding - package org.springframework.yarn.integration.ip.mind.binding
-
- org.springframework.yarn.integration.support - package org.springframework.yarn.integration.support
-
- org.springframework.yarn.launch - package org.springframework.yarn.launch
-
- org.springframework.yarn.listener - package org.springframework.yarn.listener
-
- org.springframework.yarn.rpc - package org.springframework.yarn.rpc
-
- org.springframework.yarn.support - package org.springframework.yarn.support
-
- org.springframework.yarn.support.compat - package org.springframework.yarn.support.compat
-
- org.springframework.yarn.support.console - package org.springframework.yarn.support.console
-
- org.springframework.yarn.test - package org.springframework.yarn.test
-
- org.springframework.yarn.test.context - package org.springframework.yarn.test.context
-
- org.springframework.yarn.test.junit - package org.springframework.yarn.test.junit
-
- org.springframework.yarn.test.support - package org.springframework.yarn.test.support
-
- OutputContext - Class in org.springframework.data.hadoop.store.support
-
Context strategy keeping output state.
- OutputContext() - Constructor for class org.springframework.data.hadoop.store.support.OutputContext
-
Instantiates a new strategy context.
- OutputStoreObjectSupport - Class in org.springframework.data.hadoop.store.support
-
A OutputStoreObjectSupport
is meant to be used from a store
DataWriter
implementations by keeping current writing state.
- OutputStoreObjectSupport(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
-
Instantiates a new abstract output store support.
- OutputStreamWriter - Class in org.springframework.data.hadoop.store.output
-
A OutputStreamWriter
is a DataStoreWriter
implementation
able to write byte[]
s into raw hdfs files.
- OutputStreamWriter(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.output.OutputStreamWriter
-
Instantiates a new output stream writer.
- overwrite(boolean) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- overwrite(boolean) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify if writer is allowed to overwrite files.