Package | Description |
---|---|
org.apache.lens.cube.metadata | |
org.apache.lens.cube.metadata.timeline | |
org.apache.lens.cube.parse | |
org.apache.lens.server.metastore |
Modifier and Type | Method and Description |
---|---|
static UpdatePeriod |
UpdatePeriod.fromUnitName(String unitName) |
UpdatePeriod |
FactPartition.getPeriod() |
UpdatePeriod |
TimePartition.getUpdatePeriod() |
UpdatePeriod |
StoragePartitionDesc.getUpdatePeriod() |
static UpdatePeriod |
CubeFactTable.maxIntervalInRange(Date from,
Date to,
Set<UpdatePeriod> updatePeriods)
Get the max update period for the given range and available update periods
|
static UpdatePeriod |
UpdatePeriod.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static UpdatePeriod[] |
UpdatePeriod.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
Map<String,UpdatePeriod> |
CubeDimensionTable.getSnapshotDumpPeriods() |
Map<String,Set<UpdatePeriod>> |
CubeFactTable.getUpdatePeriods() |
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)
Add given partitions in the underlying hive table and update latest partition links
|
void |
CubeMetastoreClient.addStorage(CubeDimensionTable dim,
String storage,
UpdatePeriod dumpPeriod,
StorageTableDesc storageTableDesc)
Adds storage to dimension and creates corresponding storage table
|
void |
CubeFactTable.addUpdatePeriod(String storage,
UpdatePeriod period)
Add update period to storage
|
void |
CubeDimensionTable.alterSnapshotDumpPeriod(String storage,
UpdatePeriod period)
Alter snapshot dump period of a storage
|
static TimePartitionRange |
TimePartitionRange.between(Date from,
Date to,
UpdatePeriod period) |
int |
UpdatePeriod.UpdatePeriodComparator.compare(UpdatePeriod o1,
UpdatePeriod o2) |
void |
CubeMetastoreClient.dropPartition(String cubeTableName,
String storageName,
Map<String,Date> timePartSpec,
Map<String,String> nonTimePartSpec,
UpdatePeriod updatePeriod)
Add a partition specified by the storage partition desc on the storage passed.
|
boolean |
CubeMetastoreClient.factPartitionExists(String factName,
String storageName,
UpdatePeriod updatePeriod,
Map<String,Date> partitionTimestamp,
Map<String,String> partSpec) |
static void |
MetastoreUtil.filterPartitionsByUpdatePeriod(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions,
UpdatePeriod updatePeriod) |
static Date |
DateUtil.getCeilDate(Date date,
UpdatePeriod interval) |
static Date |
DateUtil.getFloorDate(Date date,
UpdatePeriod interval) |
static String |
MetastoreUtil.getPartitionInfoKeyPrefix(UpdatePeriod updatePeriod,
String partCol) |
List<String> |
CubeFactTable.getPartitions(Date fromDate,
Date toDate,
UpdatePeriod interval)
Get partition value strings for given range, for the specified updateInterval
|
static String |
MetastoreUtil.getPartitionTimelineStorageClassKey(UpdatePeriod updatePeriod,
String partCol) |
static int |
DateUtil.getTimeDiff(Date fromDate,
Date toDate,
UpdatePeriod updatePeriod) |
static TimeRange.Iterable |
TimeRange.iterable(Date fromDate,
Date toDate,
UpdatePeriod updatePeriod,
int increment)
iterable from fromDate(including) to toDate(excluding) incrementing increment units of updatePeriod
|
static TimeRange.Iterable |
TimeRange.iterable(Date fromDate,
int numIters,
UpdatePeriod updatePeriod,
int increment)
iterable from fromDate(including) incrementing increment units of updatePeriod.
|
TimeRange.Iterable |
TimeRange.iterable(UpdatePeriod updatePeriod,
int increment) |
static TimePartition |
TimePartition.of(UpdatePeriod updatePeriod,
Date date) |
static TimePartition |
TimePartition.of(UpdatePeriod updatePeriod,
String dateString) |
static TimePartitionRange |
TimePartitionRange.parseFrom(UpdatePeriod updatePeriod,
String from,
String to) |
boolean |
CubeMetastoreClient.partitionExists(String storageTableName,
UpdatePeriod updatePeriod,
Map<String,Date> partitionTimestamps) |
void |
CubeFactTable.removeUpdatePeriod(String storage,
UpdatePeriod period)
Remove update period from storage
|
void |
StoragePartitionDesc.setUpdatePeriod(UpdatePeriod updatePeriod) |
TimePartition |
TimePartition.withUpdatePeriod(UpdatePeriod period) |
Modifier and Type | Method and Description |
---|---|
void |
CubeMetastoreClient.addStorage(CubeFactTable fact,
String storage,
Set<UpdatePeriod> updatePeriods,
StorageTableDesc storageTableDesc)
Adds storage to fact and creates corresponding storage table
|
void |
CubeFactTable.alterStorage(String storage,
Set<UpdatePeriod> updatePeriods)
Alter a storage with specified update periods
|
void |
CubeMetastoreClient.createCubeDimensionTable(String dimName,
String dimTblName,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> columns,
double weight,
Map<String,UpdatePeriod> dumpPeriods,
Map<String,String> properties,
Map<String,StorageTableDesc> storageTableDescs)
Create a cube dimension table
|
void |
CubeMetastoreClient.createCubeFactTable(String cubeName,
String factName,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> columns,
Map<String,Set<UpdatePeriod>> storageAggregatePeriods,
double weight,
Map<String,String> properties,
Map<String,StorageTableDesc> storageTableDescs)
Create a cube fact table
|
boolean |
TimeRange.isCoverableBy(TreeSet<UpdatePeriod> updatePeriods) |
static UpdatePeriod |
CubeFactTable.maxIntervalInRange(Date from,
Date to,
Set<UpdatePeriod> updatePeriods)
Get the max update period for the given range and available update periods
|
Constructor and Description |
---|
FactPartition(String partCol,
Date partSpec,
UpdatePeriod period,
FactPartition containingPart,
DateFormat partFormat) |
FactPartition(String partCol,
Date partSpec,
UpdatePeriod period,
FactPartition containingPart,
DateFormat partFormat,
Set<String> storageTables) |
StoragePartitionDesc(String cubeTableName,
Map<String,Date> timePartSpec,
Map<String,String> nonTimePartSpec,
UpdatePeriod updatePeriod) |
TimeRange.Iterable(UpdatePeriod updatePeriod,
long numIters,
int increment) |
Constructor and Description |
---|
CubeDimensionTable(String dimName,
String dimTblName,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> columns,
double weight,
Map<String,UpdatePeriod> snapshotDumpPeriods) |
CubeDimensionTable(String dimName,
String dimTblName,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> columns,
double weight,
Map<String,UpdatePeriod> snapshotDumpPeriods,
Map<String,String> properties) |
CubeFactTable(String cubeName,
String factName,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> columns,
Map<String,Set<UpdatePeriod>> storageUpdatePeriods) |
CubeFactTable(String cubeName,
String factName,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> columns,
Map<String,Set<UpdatePeriod>> storageUpdatePeriods,
double weight) |
CubeFactTable(String cubeName,
String factName,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> columns,
Map<String,Set<UpdatePeriod>> storageUpdatePeriods,
double weight,
Map<String,String> properties) |
Modifier and Type | Method and Description |
---|---|
UpdatePeriod |
PartitionTimeline.getUpdatePeriod() |
Modifier and Type | Method and Description |
---|---|
static PartitionTimeline |
PartitionTimelineFactory.get(CubeMetastoreClient client,
String storageTable,
UpdatePeriod updatePeriod,
String partitionColumn)
Checks in table params if desired implementing class is given.
|
Constructor and Description |
---|
EndsAndHolesPartitionTimeline(String storageTableName,
UpdatePeriod updatePeriod,
String partCol) |
PartitionTimeline(String storageTableName,
UpdatePeriod updatePeriod,
String partCol) |
RangesPartitionTimeline(String storageTableName,
UpdatePeriod updatePeriod,
String partCol) |
StoreAllPartitionTimeline(String storageTableName,
UpdatePeriod updatePeriod,
String partCol) |
Modifier and Type | Method and Description |
---|---|
static String |
CubeQueryConfUtil.getLookAheadPTPartsKey(UpdatePeriod interval) |
Modifier and Type | Method and Description |
---|---|
static Map<String,UpdatePeriod> |
JAXBUtils.dumpPeriodsFromStorageTables(XStorageTables storageTables) |
static Map<String,Set<UpdatePeriod>> |
JAXBUtils.getFactUpdatePeriodsFromStorageTables(XStorageTables storageTables) |
Copyright © 2014–2016 Apache Software Foundation. All rights reserved.