org.apache.lens.cube.metadata

Class CubeFactTable

java.lang.Object

org.apache.lens.cube.metadata.AbstractCubeTable

org.apache.lens.cube.metadata.CubeFactTable

All Implemented Interfaces:

Named

public class CubeFactTable
extends AbstractCubeTable

Constructor Summary

Constructors

Constructor and Description
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)
CubeFactTable(org.apache.hadoop.hive.ql.metadata.Table hiveTable)

Method Summary

Methods

Modifier and Type	Method and Description
void	addColumns(Collection<org.apache.hadoop.hive.metastore.api.FieldSchema> columns) Adds or alters the columns passed
void	addUpdatePeriod(String storage, UpdatePeriod period) Add update period to storage
void	alterColumn(org.apache.hadoop.hive.metastore.api.FieldSchema column) Alters the column if already existing or just adds it if it is new column
void	alterCubeName(String cubeName) Alter the cubeName to which this fact belongs
void	alterStorage(String storage, Set<UpdatePeriod> updatePeriods) Alter a storage with specified update periods
boolean	equals(Object obj)
Date	getAbsoluteEndTime()
Date	getAbsoluteStartTime()
String	getCubeName()
Date	getDateFromProperty(String propKey, boolean relative, boolean start)
Date	getEndTime()
List<String>	getPartitions(Date fromDate, Date toDate, UpdatePeriod interval) Get partition value strings for given range, for the specified updateInterval
Date	getRelativeEndTime()
Date	getRelativeStartTime()
Date	getStartTime()
Set<String>	getStorages()
CubeTableType	getTableType()
Map<String,Set<UpdatePeriod>>	getUpdatePeriods()
List<String>	getValidColumns() Return valid columns of the fact, which can be specified by property MetastoreUtil.getValidColumnsKey(getName())
int	hashCode()
boolean	isAggregated()
static UpdatePeriod	maxIntervalInRange(Date from, Date to, Set<UpdatePeriod> updatePeriods) Get the max update period for the given range and available update periods
Date	now()
void	removeUpdatePeriod(String storage, UpdatePeriod period) Remove update period from storage
void	setAggregated(boolean isAggregated)

Methods inherited from class org.apache.lens.cube.metadata.AbstractCubeTable

addProperties, alterWeight, getAllFieldNames, getColumns, getName, getProperties, getWeight, removeProperty, toString, weight

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

CubeFactTable

public CubeFactTable(org.apache.hadoop.hive.ql.metadata.Table hiveTable)

CubeFactTable

public CubeFactTable(String cubeName,
             String factName,
             List<org.apache.hadoop.hive.metastore.api.FieldSchema> columns,
             Map<String,Set<UpdatePeriod>> storageUpdatePeriods)

CubeFactTable

public CubeFactTable(String cubeName,
             String factName,
             List<org.apache.hadoop.hive.metastore.api.FieldSchema> columns,
             Map<String,Set<UpdatePeriod>> storageUpdatePeriods,
             double weight)

CubeFactTable

public 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)

Method Detail

getUpdatePeriods

public Map<String,Set<UpdatePeriod>> getUpdatePeriods()

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractCubeTable

equals

public boolean equals(Object obj)

Overrides:

equals in class AbstractCubeTable

getTableType

public CubeTableType getTableType()

Specified by:

getTableType in class AbstractCubeTable

getPartitions

public List<String> getPartitions(Date fromDate,
                         Date toDate,
                         UpdatePeriod interval)

Get partition value strings for given range, for the specified updateInterval

Parameters:

fromDate -

toDate -

interval -

Returns:

maxIntervalInRange

public static UpdatePeriod maxIntervalInRange(Date from,
                              Date to,
                              Set<UpdatePeriod> updatePeriods)

Get the max update period for the given range and available update periods

Parameters:

from -

to -

updatePeriods -

Returns:

getStorages

public Set<String> getStorages()

Specified by:

getStorages in class AbstractCubeTable

getCubeName

public String getCubeName()

getValidColumns

public List<String> getValidColumns()

Return valid columns of the fact, which can be specified by property MetastoreUtil.getValidColumnsKey(getName())

Returns:

addUpdatePeriod

public void addUpdatePeriod(String storage,
                   UpdatePeriod period)

Add update period to storage

Parameters:

storage -

period -

removeUpdatePeriod

public void removeUpdatePeriod(String storage,
                      UpdatePeriod period)

Remove update period from storage

Parameters:

storage -

period -

alterStorage

public void alterStorage(String storage,
                Set<UpdatePeriod> updatePeriods)
                  throws LensException

Alter a storage with specified update periods

Parameters:

storage -

updatePeriods -

Throws:

LensException

alterColumn

public void alterColumn(org.apache.hadoop.hive.metastore.api.FieldSchema column)

Description copied from class: AbstractCubeTable

Alters the column if already existing or just adds it if it is new column

Parameters:

column - The column spec as FieldSchema - name, type and a comment

addColumns

public void addColumns(Collection<org.apache.hadoop.hive.metastore.api.FieldSchema> columns)

Description copied from class: AbstractCubeTable

Adds or alters the columns passed

Parameters:

columns - The collection of columns

alterCubeName

public void alterCubeName(String cubeName)

Alter the cubeName to which this fact belongs

Parameters:

cubeName -

isAggregated

public boolean isAggregated()

setAggregated

public void setAggregated(boolean isAggregated)

getDateFromProperty

public Date getDateFromProperty(String propKey,
                       boolean relative,
                       boolean start)

getAbsoluteStartTime

public Date getAbsoluteStartTime()

getRelativeStartTime

public Date getRelativeStartTime()

getStartTime

public Date getStartTime()

getAbsoluteEndTime

public Date getAbsoluteEndTime()

getRelativeEndTime

public Date getRelativeEndTime()

getEndTime

public Date getEndTime()

now

public Date now()