|
Spring for Apache Hadoop | ||||||||
PREV LETTER NEXT LETTER | FRAMES NO FRAMES |
RpcMessage
implementation.GenericRpcMessage
with a given body.
GenericSplit
is simple implementation of
Split
and SplitLocation
storing needed
information as it is.Codecs
by its abbreviation.
RpcMessage
and
receives response similarly wrapped in RpcMessage
.
ContainerAllocator
for this class.
ApplicationAttemptId
from environment variables.
ApplicationContext
for tests.
ApplicationContext
for tests.
AppmasterService
set to this instance.
AppmasterService
bean whose name is "yarnClientAmservice" if
available.
AppmasterMindScOperations
for this implementation.
AppmasterService
set to this instance.
AppmasterService
bean whose name is "yarnAmservice" if
available.
AppmasterTrackService
set to this instance.
AppmasterTrackService
bean whose name is "yarnAmTrackservice" if
available.
MindAppmasterServiceClient.doMindRequest(BaseObject)
to convert
the response content back to mind BaseResponseObject
.
BeanFactory
for this instance.
BeanFactory
for this instance.
AnnotationBuilder
.
AppmasterCmOperations
template.
CodecInfo
by Codecs
abbreviation.
Configuration
for the cluster.
Configuration
for tests.
Configuration
from a cluster.
Configuration
of this client.
Configuration
for the cluster.
Configuration
for tests.
AnnotationConfigurer
by its class name or
null
if not found.
AnnotationConfigurer
instances by its class name or an
empty List if not found.
InputContext
.
ConversionService
bean whose name is
"integrationConversionService" if available.
ConversionService
bean whose name is
"yarnConversionService" if available.
DatasetRepository
DatasetDefinition
to use for this template.
StandardEvaluationContext
bean whose name is
"yarnEvaluationContext" if available.
StoreEventPublisher
bean whose name is "storeEventPublisher" if available.
YarnEventPublisher
bean whose name is "yarnEventPublisher" if
available.
FileSystem
managed
by HadoopCluster
.
FileSystem
instance for
test cases to read and write files to it.
SHDP_HD_FS
.
HadoopCluster
for tests.
StreamsHolder
for wrapped
input stream.
HadoopClusterManager
.
HadoopClusterManager
.
YarnClusterManager
.
YarnClusterManager
.
JobExplorer.getJobExecution(Long)
.JobExplorer.getJobExecution(Long)
.JobExplorer.getJobExecutions(JobInstance)
.JobExplorer.getJobExecutions(JobInstance)
.JobExplorer.getJobInstanceCount(String)
.JobExplorer.getJobInstanceCount(String)
.JobExplorer.getJobInstance(Long)
.JobExplorer.getJobInstance(Long)
.JobExplorer.getJobInstances(String, int, int)
.JobExplorer.getJobInstances(String, int, int)
.JobExplorer.getJobNames()
.JobExplorer.getJobNames()
.JobRepository.getLastJobExecution(String, JobParameters)
.JobRepository.getLastJobExecution(String, JobParameters)
.JobRepository.getLastStepExecution(JobInstance, String)
.JobRepository.getLastStepExecution(JobInstance, String)
.ContainerLauncher
for this class.
ContainerMonitor
for this class.
NMTokenCache
.
AbstractConfiguredAnnotationBuilder.apply(AnnotationConfigurer)
but checks the state
to determine if AbstractConfiguredAnnotationBuilder.apply(AnnotationConfigurer)
needs to be called first.
AbstractAnnotationBuilder.build()
and AbstractAnnotationBuilder.getObject()
but checks the state
to determine if AbstractAnnotationBuilder.build()
needs to be called first.
Path
s resulted as
mapreduce job run.
Path
s resulted as
mapreduce job run.
IntegrationAppmasterServiceClient.get(RpcMessage)
to
resolve the actual payload sent to Sprint Int Tcp channel.
Properties
configured for this builder.
Properties
.
AbstractDataStreamReader.ReaderHelper.createReader(InputStream)
.
TaskScheduler
bean whose name is "taskScheduler".
Resource
s configured for this builder.
Resource
s.
LocalResource
instances.
SHDP_HD_RM
.
InetSocketAddress
where this accessor should connect.
SHDP_HD_SCHEDULER
.
Path
.
Step
.
JobRepository.getStepExecutionCount(JobInstance, String)
.JobRepository.getStepExecutionCount(JobInstance, String)
.JobExplorer.getStepExecution(Long, Long)
.JobExplorer.getStepExecution(Long, Long)
.Step
.
TaskExecutor
.
TaskScheduler
bean whose name is "taskExecutor" if available.
TaskExecutor
.
TaskScheduler
bean whose name is "taskExecutor" if
available.
TaskScheduler
.
TaskScheduler
bean whose name is "taskScheduler" if available.
TaskScheduler
bean whose name is "taskScheduler" if
available.
TaskScheduler
.
TaskScheduler
bean whose name is "taskScheduler" if
available.
AppmasterRmOperations
template.
LocalResourceType
.
user
used to
create the proxy.
YarnClient
.
YarnCluster
for tests.
|
Spring for Apache Hadoop | ||||||||
PREV LETTER NEXT LETTER | FRAMES NO FRAMES |