Constructor and Description |
---|
AbstractJobMasterClient(MasterClientContext clientConf)
Creates a new master client base.
|
AbstractJobMasterClient(MasterClientContext clientConf,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier)
Creates a new master client base.
|
AbstractMasterClient(MasterClientContext clientConf)
Creates a new master client base and default the selection policy to primary master.
|
AbstractMasterClient(MasterClientContext clientConf,
MasterSelectionPolicy selectionPolicy)
Creates a new master client base.
|
AbstractMasterClient(MasterClientContext clientConf,
MasterSelectionPolicy selectionPolicy,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier)
Creates a new master client without a specific address.
|
AbstractMasterClient(MasterClientContext clientConf,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier)
Creates a new master client without a specific address.
|
Modifier and Type | Method and Description |
---|---|
static BlockMasterClient |
BlockMasterClient.Factory.create(MasterClientContext conf)
Factory method for
BlockMasterClient . |
Constructor and Description |
---|
BlockMasterClientPool(MasterClientContext ctx)
Creates a new block master client pool.
|
RetryHandlingBlockMasterClient(MasterClientContext conf)
Creates a new block master client.
|
RetryHandlingBlockMasterClient(MasterClientContext conf,
InetSocketAddress address)
Creates a new block master client.
|
RetryHandlingBlockMasterClient(MasterClientContext conf,
InetSocketAddress address,
java.util.function.Supplier<RetryPolicy> retryPolicy)
Creates a new block master client.
|
Modifier and Type | Method and Description |
---|---|
MasterClientContext |
FileSystemContext.getMasterClientContext() |
Modifier and Type | Method and Description |
---|---|
static FileSystemMasterClient |
FileSystemMasterClient.Factory.create(MasterClientContext conf)
Factory method for
FileSystemMasterClient . |
protected RetryHandlingMetaMasterConfigClient |
ConfigHashSync.createMetaMasterConfigClient(MasterClientContext context) |
void |
ConfigHashSync.resetMetaMasterConfigClient(MasterClientContext context)
Resets the internal meta master client based on the new configuration.
|
Constructor and Description |
---|
FileSystemMasterClientPool(MasterClientContext ctx)
Creates a new file system master client pool.
|
RetryHandlingFileSystemMasterClient(MasterClientContext conf)
Creates a new
RetryHandlingFileSystemMasterClient instance. |
Constructor and Description |
---|
RetryHandlingJournalMasterClient(MasterClientContext conf)
Creates a new journal master client.
|
Constructor and Description |
---|
RetryHandlingMetaMasterClient(MasterClientContext conf)
Creates a new meta master client.
|
RetryHandlingMetaMasterConfigClient(MasterClientContext conf)
Creates a new meta master client.
|
Constructor and Description |
---|
RetryHandlingMetricsMasterClient(MasterClientContext conf)
Creates a new metrics master client.
|
Modifier and Type | Method and Description |
---|---|
static TableMasterClient |
TableMasterClient.Factory.create(MasterClientContext conf)
Factory method for
TableMasterClient . |
Constructor and Description |
---|
RetryHandlingTableMasterClient(MasterClientContext conf)
Creates a new block master client.
|
Modifier and Type | Method and Description |
---|---|
MasterClientContext |
MasterClientContextBuilder.build() |
Constructor and Description |
---|
FileSystemMasterClient(MasterClientContext conf)
Creates an instance of
FileSystemMasterClient . |
Constructor and Description |
---|
RetryHandlingMetaMasterMasterClient(MasterClientContext conf)
Creates a instance of
RetryHandlingMetaMasterMasterClient . |
Constructor and Description |
---|
ProxyMasterSync(Address address,
MasterClientContext context,
long startTimeMs)
Creates a new instance of
ProxyMasterSync . |
RetryHandlingMetaMasterProxyClient(Address proxyAddress,
MasterClientContext conf,
long startTimeMs)
Creates a new meta master client.
|
Modifier and Type | Method and Description |
---|---|
protected MasterClientContext |
BlockMasterClientPool.getMasterContext() |
Constructor and Description |
---|
BlockMasterClient(MasterClientContext conf)
Creates a new instance of
BlockMasterClient for the worker. |
BlockMasterClient(MasterClientContext conf,
InetSocketAddress address)
Creates a new instance of
BlockMasterClient for the worker and
connects to a specific master. |
Constructor and Description |
---|
FileSystemMasterClient(MasterClientContext conf)
Creates a instance of
FileSystemMasterClient . |
Modifier and Type | Class and Description |
---|---|
class |
JobMasterClientContext
Extension of MasterClientContext with defaults that make sense for job master clients.
|
Copyright © 2023. All Rights Reserved.