Package | Description |
---|---|
alluxio.conf | |
alluxio.grpc | |
alluxio.master.block | |
alluxio.master.meta | |
alluxio.master.meta.checkconf | |
alluxio.stress | |
alluxio.stress.cli | |
alluxio.wire | |
alluxio.worker.block |
Modifier and Type | Method and Description |
---|---|
static List<ConfigProperty> |
Configuration.getConfiguration(Scope scope)
Gets all configuration properties filtered by the specified scope.
|
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<ConfigProperty> |
ConfigProperty.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
ConfigProperty |
ConfigProperty.Builder.build() |
ConfigProperty |
ConfigProperty.Builder.buildPartial() |
ConfigProperty |
GetConfigurationPResponseOrBuilder.getClusterConfigs(int index)
repeated .alluxio.grpc.ConfigProperty clusterConfigs = 1; |
ConfigProperty |
GetConfigurationPResponse.getClusterConfigs(int index)
repeated .alluxio.grpc.ConfigProperty clusterConfigs = 1; |
ConfigProperty |
GetConfigurationPResponse.Builder.getClusterConfigs(int index)
repeated .alluxio.grpc.ConfigProperty clusterConfigs = 1; |
ConfigProperty |
RegisterWorkerPOptions.getConfigs(int index)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
ConfigProperty |
RegisterWorkerPOptions.Builder.getConfigs(int index)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
ConfigProperty |
RegisterWorkerPOptionsOrBuilder.getConfigs(int index)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
ConfigProperty |
RegisterMasterPOptionsOrBuilder.getConfigs(int index)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
ConfigProperty |
RegisterMasterPOptions.getConfigs(int index)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
ConfigProperty |
RegisterMasterPOptions.Builder.getConfigs(int index)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
static ConfigProperty |
ConfigProperty.getDefaultInstance() |
ConfigProperty |
ConfigProperty.getDefaultInstanceForType() |
ConfigProperty |
ConfigProperty.Builder.getDefaultInstanceForType() |
ConfigProperty |
ConfigProperties.getProperties(int index)
repeated .alluxio.grpc.ConfigProperty properties = 1; |
ConfigProperty |
ConfigProperties.Builder.getProperties(int index)
repeated .alluxio.grpc.ConfigProperty properties = 1; |
ConfigProperty |
ConfigPropertiesOrBuilder.getProperties(int index)
repeated .alluxio.grpc.ConfigProperty properties = 1; |
static ConfigProperty |
ConfigProperty.parseDelimitedFrom(InputStream input) |
static ConfigProperty |
ConfigProperty.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ConfigProperty |
ConfigProperty.parseFrom(byte[] data) |
static ConfigProperty |
ConfigProperty.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ConfigProperty |
ConfigProperty.parseFrom(ByteBuffer data) |
static ConfigProperty |
ConfigProperty.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ConfigProperty |
ConfigProperty.parseFrom(com.google.protobuf.ByteString data) |
static ConfigProperty |
ConfigProperty.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ConfigProperty |
ConfigProperty.parseFrom(com.google.protobuf.CodedInputStream input) |
static ConfigProperty |
ConfigProperty.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ConfigProperty |
ConfigProperty.parseFrom(InputStream input) |
static ConfigProperty |
ConfigProperty.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<ConfigProperty> |
GetConfigurationPResponseOrBuilder.getClusterConfigsList()
repeated .alluxio.grpc.ConfigProperty clusterConfigs = 1; |
List<ConfigProperty> |
GetConfigurationPResponse.getClusterConfigsList()
repeated .alluxio.grpc.ConfigProperty clusterConfigs = 1; |
List<ConfigProperty> |
GetConfigurationPResponse.Builder.getClusterConfigsList()
repeated .alluxio.grpc.ConfigProperty clusterConfigs = 1; |
List<ConfigProperty> |
RegisterWorkerPOptions.getConfigsList()
repeated .alluxio.grpc.ConfigProperty configs = 1; |
List<ConfigProperty> |
RegisterWorkerPOptions.Builder.getConfigsList()
repeated .alluxio.grpc.ConfigProperty configs = 1; |
List<ConfigProperty> |
RegisterWorkerPOptionsOrBuilder.getConfigsList()
repeated .alluxio.grpc.ConfigProperty configs = 1; |
List<ConfigProperty> |
RegisterMasterPOptionsOrBuilder.getConfigsList()
repeated .alluxio.grpc.ConfigProperty configs = 1; |
List<ConfigProperty> |
RegisterMasterPOptions.getConfigsList()
repeated .alluxio.grpc.ConfigProperty configs = 1; |
List<ConfigProperty> |
RegisterMasterPOptions.Builder.getConfigsList()
repeated .alluxio.grpc.ConfigProperty configs = 1; |
com.google.protobuf.Parser<ConfigProperty> |
ConfigProperty.getParserForType() |
List<ConfigProperty> |
ConfigProperties.getPropertiesList()
repeated .alluxio.grpc.ConfigProperty properties = 1; |
List<ConfigProperty> |
ConfigProperties.Builder.getPropertiesList()
repeated .alluxio.grpc.ConfigProperty properties = 1; |
List<ConfigProperty> |
ConfigPropertiesOrBuilder.getPropertiesList()
repeated .alluxio.grpc.ConfigProperty properties = 1; |
static com.google.protobuf.Parser<ConfigProperty> |
ConfigProperty.parser() |
Modifier and Type | Method and Description |
---|---|
GetConfigurationPResponse.Builder |
GetConfigurationPResponse.Builder.addClusterConfigs(ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty clusterConfigs = 1; |
GetConfigurationPResponse.Builder |
GetConfigurationPResponse.Builder.addClusterConfigs(int index,
ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty clusterConfigs = 1; |
RegisterWorkerPOptions.Builder |
RegisterWorkerPOptions.Builder.addConfigs(ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
RegisterMasterPOptions.Builder |
RegisterMasterPOptions.Builder.addConfigs(ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
RegisterWorkerPOptions.Builder |
RegisterWorkerPOptions.Builder.addConfigs(int index,
ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
RegisterMasterPOptions.Builder |
RegisterMasterPOptions.Builder.addConfigs(int index,
ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
ConfigProperties.Builder |
ConfigProperties.Builder.addProperties(ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty properties = 1; |
ConfigProperties.Builder |
ConfigProperties.Builder.addProperties(int index,
ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty properties = 1; |
ConfigProperty.Builder |
ConfigProperty.Builder.mergeFrom(ConfigProperty other) |
static ConfigProperty.Builder |
ConfigProperty.newBuilder(ConfigProperty prototype) |
GetConfigurationPResponse.Builder |
GetConfigurationPResponse.Builder.setClusterConfigs(int index,
ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty clusterConfigs = 1; |
RegisterWorkerPOptions.Builder |
RegisterWorkerPOptions.Builder.setConfigs(int index,
ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
RegisterMasterPOptions.Builder |
RegisterMasterPOptions.Builder.setConfigs(int index,
ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
ConfigProperties.Builder |
ConfigProperties.Builder.setProperties(int index,
ConfigProperty value)
repeated .alluxio.grpc.ConfigProperty properties = 1; |
Modifier and Type | Method and Description |
---|---|
GetConfigurationPResponse.Builder |
GetConfigurationPResponse.Builder.addAllClusterConfigs(Iterable<? extends ConfigProperty> values)
repeated .alluxio.grpc.ConfigProperty clusterConfigs = 1; |
RegisterWorkerPOptions.Builder |
RegisterWorkerPOptions.Builder.addAllConfigs(Iterable<? extends ConfigProperty> values)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
RegisterMasterPOptions.Builder |
RegisterMasterPOptions.Builder.addAllConfigs(Iterable<? extends ConfigProperty> values)
repeated .alluxio.grpc.ConfigProperty configs = 1; |
ConfigProperties.Builder |
ConfigProperties.Builder.addAllProperties(Iterable<? extends ConfigProperty> values)
repeated .alluxio.grpc.ConfigProperty properties = 1; |
Modifier and Type | Method and Description |
---|---|
void |
BlockMaster.registerNewWorkerConfListener(java.util.function.BiConsumer<Address,List<ConfigProperty>> function)
Registers callback functions to use when workers register with configuration.
|
void |
DefaultBlockMaster.registerNewWorkerConfListener(java.util.function.BiConsumer<Address,List<ConfigProperty>> function) |
Modifier and Type | Method and Description |
---|---|
void |
RetryHandlingMetaMasterMasterClient.register(long masterId,
List<ConfigProperty> configList)
Registers with the leader master.
|
Modifier and Type | Method and Description |
---|---|
void |
ConfigurationStore.registerNewConf(Address address,
List<ConfigProperty> configList)
Registers new configuration information.
|
Modifier and Type | Method and Description |
---|---|
void |
CachingBlockMasterClient.registerWithStream(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) |
Modifier and Type | Field and Description |
---|---|
static List<ConfigProperty> |
RpcBenchPreparationUtils.EMPTY_CONFIG |
Modifier and Type | Method and Description |
---|---|
ConfigProperty |
Property.toProto() |
Modifier and Type | Method and Description |
---|---|
static Property |
Property.fromProto(ConfigProperty property) |
Modifier and Type | Method and Description |
---|---|
void |
BlockMasterClient.register(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)
The method the worker should execute to register with the block master.
|
void |
BlockMasterClient.registerWithStream(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)
Registers with the master in a stream.
|
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)
Constructor.
|
RegisterStreamer(BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub asyncClient,
long workerId,
List<String> storageTierAliases,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<String>> lostStorage,
List<ConfigProperty> configList,
BlockMapIterator blockListIterator)
Constructor.
|
Copyright © 2023. All Rights Reserved.