Modifier and Type | Field and Description |
---|---|
protected JobMasterClient |
AbstractDistributedJobCommand.mClient |
Modifier and Type | Field and Description |
---|---|
protected JobMasterClient |
JobAttempt.mClient |
Constructor and Description |
---|
JobAttempt(JobMasterClient client,
RetryPolicy retryPolicy) |
Modifier and Type | Field and Description |
---|---|
protected JobMasterClient |
AbstractFsAdminCommand.mJobMasterClient |
Modifier and Type | Method and Description |
---|---|
JobMasterClient |
Context.getJobMasterClient() |
Constructor and Description |
---|
Context(FileSystemMasterClient fsClient,
BlockMasterClient blockClient,
MetaMasterClient metaClient,
MetaMasterConfigClient metaConfigClient,
MetricsMasterClient metricsClient,
JournalMasterClient masterJournalMasterClient,
JournalMasterClient jobMasterJournalMasterClient,
JobMasterClient jobMasterClient,
PrintStream printStream) |
Constructor and Description |
---|
JobServiceMetricsCommand(JobMasterClient JobMasterClient,
PrintStream printStream,
String dateFormatPattern)
Creates a new instance of
JobServiceMetricsCommand . |
Modifier and Type | Class and Description |
---|---|
class |
RetryHandlingJobMasterClient
A wrapper for the gRPC client to interact with the job service master, used by job service
clients.
|
Modifier and Type | Method and Description |
---|---|
JobMasterClient |
JobContext.acquireMasterClient()
Acquires a job master client from the job master client pool.
|
static JobMasterClient |
JobMasterClient.Factory.create(JobMasterClientContext conf)
Factory method for
JobMasterClient . |
JobMasterClient |
JobMasterClientPool.createNewResource() |
Modifier and Type | Method and Description |
---|---|
CloseableResource<JobMasterClient> |
JobContext.acquireMasterClientResource()
Acquires a job master client from the job master client pool.
|
Modifier and Type | Method and Description |
---|---|
void |
JobContext.releaseMasterClient(JobMasterClient masterClient)
Releases a job master client into the job master client pool.
|
Constructor and Description |
---|
DefaultTableMaster(CoreMasterContext context,
JobMasterClient jobMasterClient)
Constructor for DefaultTableMaster.
|
Constructor and Description |
---|
TransformManager(TransformManager.ThrowingSupplier<JournalContext,UnavailableException> createJournalContext,
AlluxioCatalog catalog,
JobMasterClient jobMasterClient)
An internal job master client will be created.
|
Copyright © 2023. All Rights Reserved.