Package | Description |
---|---|
org.apache.lens.cube.metadata | |
org.apache.lens.storage.db |
Modifier and Type | Method and Description |
---|---|
static StoragePartitionDesc |
JAXBUtils.storagePartSpecFromXPartition(XPartition xpart) |
Modifier and Type | Method and Description |
---|---|
static List<StoragePartitionDesc> |
JAXBUtils.storagePartSpecListFromXPartitionList(XPartitionList xpartList) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.hive.ql.metadata.Partition> |
CubeMetastoreClient.addPartition(StoragePartitionDesc partSpec,
String storageName,
CubeTableType type)
Add a partition specified by the storage partition desc on the storage passed.
|
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.hive.ql.metadata.Partition> |
Storage.addPartitions(org.apache.hadoop.hive.ql.metadata.Hive client,
String factOrDimTable,
UpdatePeriod updatePeriod,
List<StoragePartitionDesc> storagePartitionDescs,
Map<Map<String,String>,Storage.LatestInfo> latestInfos,
String tableName)
Add given partitions in the underlying hive table and update latest partition links
|
List<org.apache.hadoop.hive.ql.metadata.Partition> |
CubeMetastoreClient.addPartitions(List<StoragePartitionDesc> storagePartitionDescs,
String storageName,
CubeTableType type)
batch addition
|
void |
PartitionMetahook.commitAddPartitions(List<StoragePartitionDesc> storagePartitionDesc)
Called after successfully adding the partition(s)
|
void |
HDFSStorage.commitAddPartitions(List<StoragePartitionDesc> addPartitionDesc) |
void |
PartitionMetahook.preAddPartitions(List<StoragePartitionDesc> storagePartitionDesc)
Called before calling add partition(s)
|
void |
HDFSStorage.preAddPartitions(List<StoragePartitionDesc> addPartitionDesc) |
void |
PartitionMetahook.rollbackAddPartitions(List<StoragePartitionDesc> storagePartitionDesc)
Called if add partition fails.
|
void |
HDFSStorage.rollbackAddPartitions(List<StoragePartitionDesc> addPartitionDesc) |
Modifier and Type | Method and Description |
---|---|
void |
DBStorage.commitAddPartitions(List<StoragePartitionDesc> arg0) |
void |
DBStorage.preAddPartitions(List<StoragePartitionDesc> arg0) |
void |
DBStorage.rollbackAddPartitions(List<StoragePartitionDesc> arg0) |
Copyright © 2014–2018 Apache Software Foundation. All rights reserved.