Package | Description |
---|---|
alluxio.client.keyvalue | |
alluxio.master.keyvalue | |
alluxio.thrift |
Modifier and Type | Method and Description |
---|---|
List<PartitionInfo> |
KeyValueMasterClient.getPartitionInfo(AlluxioURI path)
Gets a list of partitions of a given key-value store.
|
Modifier and Type | Method and Description |
---|---|
void |
KeyValueMasterClient.completePartition(AlluxioURI path,
PartitionInfo info)
Marks a partition complete and adds it to an incomplete key-value store.
|
Constructor and Description |
---|
KeyValueStoreIterator(List<PartitionInfo> partitions) |
Modifier and Type | Method and Description |
---|---|
List<PartitionInfo> |
DefaultKeyValueMaster.getPartitionInfo(AlluxioURI path) |
List<PartitionInfo> |
KeyValueMaster.getPartitionInfo(AlluxioURI path)
Gets a list of partitions of a given key-value store.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultKeyValueMaster.completePartition(AlluxioURI path,
PartitionInfo info) |
void |
KeyValueMaster.completePartition(AlluxioURI path,
PartitionInfo info)
Marks a partition complete and adds it to an incomplete key-value store.
|
CompletePartitionTResponse |
KeyValueMasterClientServiceHandler.completePartition(String path,
PartitionInfo info,
CompletePartitionTOptions options) |
Modifier and Type | Method and Description |
---|---|
PartitionInfo |
PartitionInfo.deepCopy() |
PartitionInfo |
KeyValueMasterClientService.completePartition_args.getInfo()
information about the partition to mark complete
|
PartitionInfo |
PartitionInfo.setBlockId(long blockId) |
PartitionInfo |
PartitionInfo.setKeyCount(int keyCount) |
PartitionInfo |
PartitionInfo.setKeyLimit(byte[] keyLimit) |
PartitionInfo |
PartitionInfo.setKeyLimit(ByteBuffer keyLimit) |
PartitionInfo |
PartitionInfo.setKeyStart(byte[] keyStart) |
PartitionInfo |
PartitionInfo.setKeyStart(ByteBuffer keyStart) |
Modifier and Type | Method and Description |
---|---|
List<PartitionInfo> |
GetPartitionInfoTResponse.getPartitionInfo() |
Iterator<PartitionInfo> |
GetPartitionInfoTResponse.getPartitionInfoIterator() |
Modifier and Type | Method and Description |
---|---|
void |
GetPartitionInfoTResponse.addToPartitionInfo(PartitionInfo elem) |
int |
PartitionInfo.compareTo(PartitionInfo other) |
CompletePartitionTResponse |
KeyValueMasterClientService.Iface.completePartition(String path,
PartitionInfo info,
CompletePartitionTOptions options)
Marks a partition complete and adds it to the store.
|
CompletePartitionTResponse |
KeyValueMasterClientService.Client.completePartition(String path,
PartitionInfo info,
CompletePartitionTOptions options) |
void |
KeyValueMasterClientService.AsyncIface.completePartition(String path,
PartitionInfo info,
CompletePartitionTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
KeyValueMasterClientService.AsyncClient.completePartition(String path,
PartitionInfo info,
CompletePartitionTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
boolean |
PartitionInfo.equals(PartitionInfo that) |
void |
KeyValueMasterClientService.Client.send_completePartition(String path,
PartitionInfo info,
CompletePartitionTOptions options) |
KeyValueMasterClientService.completePartition_args |
KeyValueMasterClientService.completePartition_args.setInfo(PartitionInfo info)
information about the partition to mark complete
|
Modifier and Type | Method and Description |
---|---|
GetPartitionInfoTResponse |
GetPartitionInfoTResponse.setPartitionInfo(List<PartitionInfo> partitionInfo) |
Constructor and Description |
---|
completePartition_args(String path,
PartitionInfo info,
CompletePartitionTOptions options) |
completePartition_call(String path,
PartitionInfo info,
CompletePartitionTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport) |
PartitionInfo(PartitionInfo other)
Performs a deep copy on other.
|
Constructor and Description |
---|
GetPartitionInfoTResponse(List<PartitionInfo> partitionInfo) |
Copyright © 2023. All Rights Reserved.