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:

FactTable, Named

public class CubeFactTable
extends AbstractCubeTable
implements FactTable

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(String cubeName, String factName, List<org.apache.hadoop.hive.metastore.api.FieldSchema> columns, Map<String,Set<UpdatePeriod>> storageUpdatePeriods, double weight, Map<String,String> properties, Map<String,Map<UpdatePeriod,String>> storagePrefixUpdatePeriodMap)
CubeFactTable(org.apache.hadoop.hive.ql.metadata.Table hiveTable)

Method Summary

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() Absolute end time of the fact
Date	getAbsoluteStartTime() Absolute start time of the fact
String	getCubeName() Cube to which this fact belongs to
String	getDataCompletenessTag() tag for checking data completeness
Date	getEndTime() End time of the fact
List<String>	getPartitions(Date fromDate, Date toDate, UpdatePeriod interval) Get partition value strings for given range, for the specified updateInterval
Date	getRelativeEndTime() Relative End time of the Fact
Date	getRelativeStartTime() Relative start time of the fact
String	getSourceFactName() Storage name of the fact
Date	getStartTime() Start time of the fact
Map<String,Map<UpdatePeriod,String>>	getStoragePrefixUpdatePeriodMap()
Set<String>	getStorages() The set of Storage names
String	getTablePrefix(String storage, UpdatePeriod updatePeriod)
CubeTableType	getTableType() The type of the fact
Map<String,Set<UpdatePeriod>>	getUpdatePeriods() Get map of storage to update period mapping
Set<String>	getValidColumns() Return valid columns of the fact, which can be specified by property MetastoreUtil.getValidColumnsKey(getName())
boolean	hasColumn(String column)
int	hashCode()
boolean	isAggregated() Is Aggregated Fact
boolean	isVirtualFact() Is Virtual Fact
static UpdatePeriod	maxIntervalInRange(Date from, Date to, Set<UpdatePeriod> updatePeriods) Get the max update period for the given range and available update periods
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, now, removeProperty, toString, weight

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.lens.cube.metadata.FactTable

getAllFieldNames, getColumns, getProperties, weight

Methods inherited from interface org.apache.lens.cube.metadata.Named

getName

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)

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,
                     Map<String,Map<UpdatePeriod,String>> storagePrefixUpdatePeriodMap)

Method Detail

hasColumn

public boolean hasColumn(String column)

getUpdatePeriods

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

Description copied from interface: FactTable

Get map of storage to update period mapping

Specified by:

getUpdatePeriods in interface FactTable

Returns:

Map of storage to set of update periods

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractCubeTable

equals

public boolean equals(Object obj)

Overrides:

equals in class AbstractCubeTable

getTableType

public CubeTableType getTableType()

Description copied from interface: FactTable

The type of the fact

Specified by:

getTableType in interface FactTable

Specified by:

getTableType in class AbstractCubeTable

Returns:

table type CubeTableType

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

Description copied from interface: FactTable

The set of Storage names

Specified by:

getStorages in interface FactTable

Specified by:

getStorages in class AbstractCubeTable

Returns:

set of strings

getCubeName

public String getCubeName()

Description copied from interface: FactTable

Cube to which this fact belongs to

Specified by:

getCubeName in interface FactTable

Returns:

the cube string

getValidColumns

public Set<String> getValidColumns()

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

Specified by:

getValidColumns in interface FactTable

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 -

getDataCompletenessTag

public String getDataCompletenessTag()

Description copied from interface: FactTable

tag for checking data completeness

Specified by:

getDataCompletenessTag in interface FactTable

Returns:

Tag String

isAggregated

public boolean isAggregated()

Description copied from interface: FactTable

Is Aggregated Fact

Specified by:

isAggregated in interface FactTable

Returns:

true if fact is Aggregated , false otherwise

setAggregated

public void setAggregated(boolean isAggregated)

isVirtualFact

public boolean isVirtualFact()

Description copied from interface: FactTable

Is Virtual Fact

Specified by:

isVirtualFact in interface FactTable

Returns:

true if fact is a virtual fact, false otherwise

getSourceFactName

public String getSourceFactName()

Description copied from interface: FactTable

Storage name of the fact

Specified by:

getSourceFactName in interface FactTable

Returns:

Storage name of the fact

getTablePrefix

public String getTablePrefix(String storage,
                             UpdatePeriod updatePeriod)

getAbsoluteStartTime

public Date getAbsoluteStartTime()

Description copied from interface: FactTable

Absolute start time of the fact

Specified by:

getAbsoluteStartTime in interface FactTable

Returns:

Absolute Start time of the fact Date

getRelativeStartTime

public Date getRelativeStartTime()

Description copied from interface: FactTable

Relative start time of the fact

Specified by:

getRelativeStartTime in interface FactTable

Returns:

Relative Start time of the fact Date

getStartTime

public Date getStartTime()

Description copied from interface: FactTable

Start time of the fact

Specified by:

getStartTime in interface FactTable

Returns:

Start time of the fact Date

getAbsoluteEndTime

public Date getAbsoluteEndTime()

Description copied from interface: FactTable

Absolute end time of the fact

Specified by:

getAbsoluteEndTime in interface FactTable

Returns:

Absolute End time of the fact Date

getRelativeEndTime

public Date getRelativeEndTime()

Description copied from interface: FactTable

Relative End time of the Fact

Specified by:

getRelativeEndTime in interface FactTable

Returns:

Relative end time of the fact Date

getEndTime

public Date getEndTime()

Description copied from interface: FactTable

End time of the fact

Specified by:

getEndTime in interface FactTable

Returns:

End time of the fact Date

getStoragePrefixUpdatePeriodMap

@Generated(value="lombok")
public Map<String,Map<UpdatePeriod,String>> getStoragePrefixUpdatePeriodMap()