Package | Description |
---|---|
alluxio | |
alluxio.grpc | |
alluxio.job | |
alluxio.job.wire | |
alluxio.master.block.meta | |
alluxio.master.job | |
alluxio.master.meta | |
alluxio.worker.block |
Modifier and Type | Field and Description |
---|---|
static BuildVersion |
RuntimeConstants.CURRENT_VERSION_INFO |
static BuildVersion |
RuntimeConstants.UNKNOWN_VERSION_INFO |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<BuildVersion> |
BuildVersion.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
BuildVersion |
BuildVersion.Builder.build() |
BuildVersion |
BuildVersion.Builder.buildPartial() |
BuildVersion |
WorkerInfoOrBuilder.getBuildVersion()
optional .alluxio.grpc.BuildVersion buildVersion = 10; |
BuildVersion |
WorkerInfo.getBuildVersion()
optional .alluxio.grpc.BuildVersion buildVersion = 10; |
BuildVersion |
WorkerInfo.Builder.getBuildVersion()
optional .alluxio.grpc.BuildVersion buildVersion = 10; |
BuildVersion |
RegisterWorkerPOptionsOrBuilder.getBuildVersion()
the worker version to display in info pages (useful for rolling upgrades)
|
BuildVersion |
RegisterWorkerPOptions.getBuildVersion()
the worker version to display in info pages (useful for rolling upgrades)
|
BuildVersion |
RegisterWorkerPOptions.Builder.getBuildVersion()
the worker version to display in info pages (useful for rolling upgrades)
|
static BuildVersion |
BuildVersion.getDefaultInstance() |
BuildVersion |
BuildVersion.getDefaultInstanceForType() |
BuildVersion |
BuildVersion.Builder.getDefaultInstanceForType() |
BuildVersion |
RegisterJobMasterPOptions.getVersion()
optional .alluxio.grpc.BuildVersion version = 4; |
BuildVersion |
RegisterJobMasterPOptions.Builder.getVersion()
optional .alluxio.grpc.BuildVersion version = 4; |
BuildVersion |
RegisterJobWorkerPRequest.getVersion()
optional .alluxio.grpc.BuildVersion version = 3; |
BuildVersion |
RegisterJobWorkerPRequest.Builder.getVersion()
optional .alluxio.grpc.BuildVersion version = 3; |
BuildVersion |
ProxyHeartbeatPOptionsOrBuilder.getVersion()
optional .alluxio.grpc.BuildVersion version = 3; |
BuildVersion |
ProxyHeartbeatPOptions.getVersion()
optional .alluxio.grpc.BuildVersion version = 3; |
BuildVersion |
ProxyHeartbeatPOptions.Builder.getVersion()
optional .alluxio.grpc.BuildVersion version = 3; |
BuildVersion |
JobMasterStatusOrBuilder.getVersion()
optional .alluxio.grpc.BuildVersion version = 4; |
BuildVersion |
JobMasterStatus.getVersion()
optional .alluxio.grpc.BuildVersion version = 4; |
BuildVersion |
JobMasterStatus.Builder.getVersion()
optional .alluxio.grpc.BuildVersion version = 4; |
BuildVersion |
RegisterJobWorkerPRequestOrBuilder.getVersion()
optional .alluxio.grpc.BuildVersion version = 3; |
BuildVersion |
JobWorkerHealthOrBuilder.getVersion()
optional .alluxio.grpc.BuildVersion version = 8; |
BuildVersion |
JobWorkerHealth.getVersion()
optional .alluxio.grpc.BuildVersion version = 8; |
BuildVersion |
JobWorkerHealth.Builder.getVersion()
optional .alluxio.grpc.BuildVersion version = 8; |
BuildVersion |
ProxyStatusOrBuilder.getVersion()
optional .alluxio.grpc.BuildVersion version = 5; |
BuildVersion |
ProxyStatus.getVersion()
optional .alluxio.grpc.BuildVersion version = 5; |
BuildVersion |
ProxyStatus.Builder.getVersion()
optional .alluxio.grpc.BuildVersion version = 5; |
BuildVersion |
RegisterJobMasterPOptionsOrBuilder.getVersion()
optional .alluxio.grpc.BuildVersion version = 4; |
static BuildVersion |
BuildVersion.parseDelimitedFrom(InputStream input) |
static BuildVersion |
BuildVersion.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BuildVersion |
BuildVersion.parseFrom(byte[] data) |
static BuildVersion |
BuildVersion.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BuildVersion |
BuildVersion.parseFrom(ByteBuffer data) |
static BuildVersion |
BuildVersion.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BuildVersion |
BuildVersion.parseFrom(com.google.protobuf.ByteString data) |
static BuildVersion |
BuildVersion.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BuildVersion |
BuildVersion.parseFrom(com.google.protobuf.CodedInputStream input) |
static BuildVersion |
BuildVersion.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static BuildVersion |
BuildVersion.parseFrom(InputStream input) |
static BuildVersion |
BuildVersion.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<BuildVersion> |
BuildVersion.getParserForType() |
static com.google.protobuf.Parser<BuildVersion> |
BuildVersion.parser() |
Modifier and Type | Method and Description |
---|---|
WorkerInfo.Builder |
WorkerInfo.Builder.mergeBuildVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion buildVersion = 10; |
RegisterWorkerPOptions.Builder |
RegisterWorkerPOptions.Builder.mergeBuildVersion(BuildVersion value)
the worker version to display in info pages (useful for rolling upgrades)
|
BuildVersion.Builder |
BuildVersion.Builder.mergeFrom(BuildVersion other) |
RegisterJobMasterPOptions.Builder |
RegisterJobMasterPOptions.Builder.mergeVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 4; |
RegisterJobWorkerPRequest.Builder |
RegisterJobWorkerPRequest.Builder.mergeVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 3; |
ProxyHeartbeatPOptions.Builder |
ProxyHeartbeatPOptions.Builder.mergeVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 3; |
JobMasterStatus.Builder |
JobMasterStatus.Builder.mergeVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 4; |
JobWorkerHealth.Builder |
JobWorkerHealth.Builder.mergeVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 8; |
ProxyStatus.Builder |
ProxyStatus.Builder.mergeVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 5; |
static BuildVersion.Builder |
BuildVersion.newBuilder(BuildVersion prototype) |
WorkerInfo.Builder |
WorkerInfo.Builder.setBuildVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion buildVersion = 10; |
RegisterWorkerPOptions.Builder |
RegisterWorkerPOptions.Builder.setBuildVersion(BuildVersion value)
the worker version to display in info pages (useful for rolling upgrades)
|
RegisterJobMasterPOptions.Builder |
RegisterJobMasterPOptions.Builder.setVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 4; |
RegisterJobWorkerPRequest.Builder |
RegisterJobWorkerPRequest.Builder.setVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 3; |
ProxyHeartbeatPOptions.Builder |
ProxyHeartbeatPOptions.Builder.setVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 3; |
JobMasterStatus.Builder |
JobMasterStatus.Builder.setVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 4; |
JobWorkerHealth.Builder |
JobWorkerHealth.Builder.setVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 8; |
ProxyStatus.Builder |
ProxyStatus.Builder.setVersion(BuildVersion value)
optional .alluxio.grpc.BuildVersion version = 5; |
Modifier and Type | Method and Description |
---|---|
BuildVersion |
MasterWorkerInfo.getVersion() |
Constructor and Description |
---|
MasterWorkerInfo(long id,
WorkerNetAddress address,
BuildVersion version)
Creates a new instance of
MasterWorkerInfo . |
Modifier and Type | Method and Description |
---|---|
BuildVersion |
JobWorkerHealth.getVersion() |
Constructor and Description |
---|
JobWorkerHealth(long workerId,
List<Double> loadAverage,
int taskPoolSize,
int numActiveTasks,
int unfinishedTasks,
String hostname,
BuildVersion version)
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
BuildVersion |
MasterWorkerInfo.getBuildVersion()
Get the build version of the worker.
|
Modifier and Type | Method and Description |
---|---|
void |
MasterWorkerInfo.setBuildVersion(BuildVersion buildVersion)
Sets the build version of the worker.
|
Modifier and Type | Method and Description |
---|---|
long |
JobMaster.registerWorker(WorkerNetAddress workerNetAddress,
BuildVersion version)
Returns a worker id for the given worker.
|
Modifier and Type | Method and Description |
---|---|
BuildVersion |
JobMasterInfo.getVersion() |
Modifier and Type | Method and Description |
---|---|
void |
JobMasterInfo.setVersion(BuildVersion version) |
Constructor and Description |
---|
RegisterStreamer(BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub asyncClient,
long workerId,
List<String> storageTierAliases,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<BlockStoreLocation,List<Long>> currentBlocksOnLocation,
Map<String,List<String>> lostStorage,
List<ConfigProperty> configList,
BuildVersion version)
Constructor.
|
Copyright © 2023. All Rights Reserved.