|
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.
DatasetDefinitions used for this template.
DatasetDescriptor for the given class
DatasetRepository
DatasetDefinition used 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.
Paths resulted as
mapreduce job run.
Paths 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".
Resources configured for this builder.
Resources.
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 | ||||||||