org.apache.lens.server.metastore

Class CubeMetastoreServiceImpl

java.lang.Object

org.apache.hive.service.AbstractService

org.apache.hive.service.CompositeService

org.apache.lens.server.BaseLensService

org.apache.lens.server.metastore.CubeMetastoreServiceImpl

All Implemented Interfaces:

Externalizable, Serializable, org.apache.hive.service.Service, HealthCheckable, LensService, CubeMetastoreService, SessionValidator

public class CubeMetastoreServiceImpl
extends BaseLensService
implements CubeMetastoreService

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.lens.server.BaseLensService

BaseLensService.SessionContext

Nested classes/interfaces inherited from class org.apache.hive.service.CompositeService

org.apache.hive.service.CompositeService.CompositeServiceShutdownHook

Nested classes/interfaces inherited from interface org.apache.hive.service.Service

org.apache.hive.service.Service.STATE

Field Summary

Fields inherited from interface org.apache.lens.server.api.metastore.CubeMetastoreService

NAME

Constructor Summary

Constructors

Constructor and Description
CubeMetastoreServiceImpl(org.apache.hive.service.cli.CLIService cliService)

Method Summary

Modifier and Type	Method and Description
void	addDimTableStorage(LensSessionHandle sessionid, String dimTblName, XStorageTableElement storageTable) Add a storage to dimension table
int	addPartitionsToDimStorage(LensSessionHandle sessionid, String dimTblName, String storageName, XPartitionList partitions) Add partitions to dimension table on a storage.
int	addPartitionsToFactStorage(LensSessionHandle sessionid, String fact, String storageName, XPartitionList partitions) Add partitions to fact on a storage
int	addPartitionToDimStorage(LensSessionHandle sessionid, String dimTblName, String storageName, XPartition partition) Add partition to dimension table on a storage.
int	addPartitionToFactStorage(LensSessionHandle sessionid, String fact, String storageName, XPartition partition) Add partition to fact on a storage
void	addStorageToFact(LensSessionHandle sessionid, String fact, XStorageTableElement storageTable) Add storage to fact table
void	alterStorage(LensSessionHandle sessionid, String storageName, XStorage storage) Alter storage specified by name, with new definition
void	createCube(LensSessionHandle sessionid, XCube cube) Create cube based on the JAXB cube object
void	createDatabase(LensSessionHandle sessionid, String database, boolean ignore) Create a database in Hive metastore
void	createDimension(LensSessionHandle sessionid, XDimension dimension) Create a dimension based on JAXB Dimension object
void	createDimensionTable(LensSessionHandle sessionid, XDimensionTable xDimTable) Create a cube dimension table based on JAXB object
void	createFactTable(LensSessionHandle sessionid, XFact fact) Create fact table
void	createSegmentation(LensSessionHandle sessionid, XSegmentation cubeSeg)
void	createStorage(LensSessionHandle sessionid, XStorage storage) Create a storage
void	dropAllStoragesOfDimTable(LensSessionHandle sessionid, String dimTblName) Drop all storages of dimension table.
void	dropAllStoragesOfFact(LensSessionHandle sessionid, String factName) Drop all storages of fact
void	dropCube(LensSessionHandle sessionid, String cubeName) Drop a cube from the metastore in the currently deleted database
void	dropDatabase(LensSessionHandle sessionid, String database, boolean cascade) Drop a database from cube metastore
void	dropDimension(LensSessionHandle sessionid, String dimName) Drop a dimension from the metastore in the currently deleted database.
void	dropDimensionTable(LensSessionHandle sessionid, String dimTblName, boolean cascade) Drop a dimension table from the cube metastore
void	dropFactTable(LensSessionHandle sessionid, String fact, boolean cascade) Drop fact table.
void	dropPartitionFromStorageByFilter(LensSessionHandle sessionid, String cubeTableName, String storageName, String filter) Drop partition from storage with spec specified by filter
void	dropPartitionFromStorageByValues(LensSessionHandle sessionid, String cubeTableName, String storageName, String values) Drop partition from storage with spec specified as comma separated string
void	dropSegmentation(LensSessionHandle sessionid, String cubeSegName) Update segmentation
void	dropStorage(LensSessionHandle sessionid, String storageName) Drop a storage specified by name
void	dropStorageOfDimTable(LensSessionHandle sessionid, String dimTblName, String storage) Drop storage of dimension table specified by name.
void	dropStorageOfFact(LensSessionHandle sessionid, String fact, String storage) Drop storage of fact specified by fact name, storage name
List<String>	getAllBaseCubeNames(LensSessionHandle sessionid) Get names of all base cube names in the current database
List<String>	getAllCubeNames(LensSessionHandle sessionid) Get list of all cubes names in the current database
List<String>	getAllDatabases(LensSessionHandle sessionid) Get names of all databases in this metastore
List<String>	getAllDerivedCubeNames(LensSessionHandle sessionid) Get names of all derived cubes in the current database
List<String>	getAllDimensionNames(LensSessionHandle sessionid) Get all dimension names in the current session
List<String>	getAllDimTableNames(LensSessionHandle sessionid, String dimensionName) Get all dimension tables.
List<String>	getAllFactNames(LensSessionHandle sessionid, String cubeName) Get all fact names
XJoinChains	getAllJoinChains(LensSessionHandle sessionHandle, String tableName)
List<String>	getAllNativeTableNames(LensSessionHandle sessionid, String dbOption, String dbName) Get names of all native tables
XPartitionList	getAllPartitionsOfDimTableStorage(LensSessionHandle sessionid, String dimTable, String storageName, String filter) Get all partitions of a dimension table in a storage
XPartitionList	getAllPartitionsOfFactStorage(LensSessionHandle sessionid, String fact, String storageName, String filter) Get all partitions of fact on a storage
List<String>	getAllQueryableCubeNames(LensSessionHandle sessionid) Get names of all cubes, which can be queried in the current database
List<String>	getAllSegmentations(LensSessionHandle sessionid, String cubeName) Get all segmentations belong to Cube
List<String>	getAllStorageNames(LensSessionHandle sessionid) Get all storage names in current database
XCube	getCube(LensSessionHandle sessionid, String cubeName) Get a cube from the metastore
String	getCurrentDatabase(LensSessionHandle sessionid) Get current database used by the CubeMetastoreClient
XDimension	getDimension(LensSessionHandle sessionid, String dimName) Get a dimension from the metastore
XDimensionTable	getDimensionTable(LensSessionHandle sessionid, String dimTblName) Get the dimension table from metastore
List<String>	getDimTableStorages(LensSessionHandle sessionid, String dimension) Get all storages of dimension table
XFact	getFactTable(LensSessionHandle sessionid, String fact) Get fact table given by name
XFlattenedColumns	getFlattenedColumns(LensSessionHandle sessionHandle, String tableName, boolean addChains) Get flattened columns - all columns of table + all reachable columns
HealthStatus	getHealthStatus() Returns the health status of the service.
Date	getLatestDateOfCube(LensSessionHandle sessionid, String cubeName, String timeDimension) Get the latest available date upto which data is available for the base cubes, for the time dimension
XNativeTable	getNativeTable(LensSessionHandle sessionid, String name) Get native table for the given name
List<String>	getPartitionTimelines(LensSessionHandle sessionid, String factName, String storage, String updatePeriod, String timeDimension)
XSegmentation	getSegmentation(LensSessionHandle sessionid, String cubeSegName) Create segmentation
XStorage	getStorage(LensSessionHandle sessionid, String storageName) Get Storage specified by name
XStorageTableElement	getStorageOfDim(LensSessionHandle sessionid, String dimTblName, String storageName) Get storage table element associated with dimension table for storage name specified
XStorageTableElement	getStorageOfFact(LensSessionHandle sessionid, String fact, String storageName) Get storage table of fact specifed by fact name, storage name
List<String>	getStoragesOfFact(LensSessionHandle sessionid, String fact) Get all storages of fact
void	setCurrentDatabase(LensSessionHandle sessionid, String database) Change the current database used by the CubeMetastoreClient
void	updateCube(LensSessionHandle sessionid, XCube cube) Update cube
void	updateDimension(LensSessionHandle sessionid, String dimName, XDimension dimension) Update an existing dimension
void	updateDimensionTable(LensSessionHandle sessionid, XDimensionTable dimensionTable) Update/Alter the dimension table
void	updateFactTable(LensSessionHandle sessionid, XFact fact) Update/Alter fact table
void	updatePartition(LensSessionHandle sessionid, String tblName, String storageName, XPartition xPartition)
void	updatePartitions(LensSessionHandle sessionid, String tblName, String storageName, XPartitionList xPartitions)
void	updateSegmentation(LensSessionHandle sessionid, XSegmentation cubeSeg) Get segmentation given by name

Methods inherited from class org.apache.lens.server.BaseLensService

acquire, acquire, closeSession, getCliService, getHiveSessionHandle, getLensConf, getLensConf, getNumberOfSessions, getServerDomain, getSession, getSessionInfo, getSessionManager, getValidPath, openSession, openSession, prepareStopping, readExternal, release, release, removePrefixBeforeURI, restoreSession, validateSession, writeExternal

Methods inherited from class org.apache.hive.service.CompositeService

getServices, init, start, stop

Methods inherited from class org.apache.hive.service.AbstractService

getHiveConf, getName, getServiceState, getStartTime, register, unregister

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.lens.server.api.SessionValidator

validateSession

Constructor Detail

CubeMetastoreServiceImpl

public CubeMetastoreServiceImpl(org.apache.hive.service.cli.CLIService cliService)

Method Detail

getCurrentDatabase

public String getCurrentDatabase(LensSessionHandle sessionid)
                          throws LensException

Get current database used by the CubeMetastoreClient

Specified by:

getCurrentDatabase in interface CubeMetastoreService

Returns:

database name

Throws:

LensException

setCurrentDatabase

public void setCurrentDatabase(LensSessionHandle sessionid,
                               String database)
                        throws LensException

Change the current database used by the CubeMetastoreClient

Specified by:

setCurrentDatabase in interface CubeMetastoreService

Parameters:

database - current database to set

Throws:

LensException

dropDatabase

public void dropDatabase(LensSessionHandle sessionid,
                         String database,
                         boolean cascade)
                  throws LensException

Drop a database from cube metastore

Specified by:

dropDatabase in interface CubeMetastoreService

Parameters:

database - database name

cascade - flag indicating if the tables in the database should be dropped as well

Throws:

LensException

createDatabase

public void createDatabase(LensSessionHandle sessionid,
                           String database,
                           boolean ignore)
                    throws LensException

Create a database in Hive metastore

Specified by:

createDatabase in interface CubeMetastoreService

Parameters:

database - database name

ignore - ignore if database already exists

Throws:

LensException

getAllDatabases

public List<String> getAllDatabases(LensSessionHandle sessionid)
                             throws LensException

Description copied from interface: CubeMetastoreService

Get names of all databases in this metastore

Specified by:

getAllDatabases in interface CubeMetastoreService

Returns:

get all database names

Throws:

LensException

getAllCubeNames

public List<String> getAllCubeNames(LensSessionHandle sessionid)
                             throws LensException

Get list of all cubes names in the current database

Specified by:

getAllCubeNames in interface CubeMetastoreService

Returns:

List of cube names

Throws:

LensException

createCube

public void createCube(LensSessionHandle sessionid,
                       XCube cube)
                throws LensException

Create cube based on the JAXB cube object

Specified by:

createCube in interface CubeMetastoreService

Parameters:

cube - cube spec

Throws:

LensException

getCube

public XCube getCube(LensSessionHandle sessionid,
                     String cubeName)
              throws LensException

Get a cube from the metastore

Specified by:

getCube in interface CubeMetastoreService

Parameters:

cubeName - cube name

Returns:

The cube object as XCube

Throws:

LensException

dropCube

public void dropCube(LensSessionHandle sessionid,
                     String cubeName)
              throws LensException

Drop a cube from the metastore in the currently deleted database

Specified by:

dropCube in interface CubeMetastoreService

Parameters:

cubeName - cube name

Throws:

LensException

updateCube

public void updateCube(LensSessionHandle sessionid,
                       XCube cube)
                throws LensException

Update cube

Specified by:

updateCube in interface CubeMetastoreService

Parameters:

cube - JAXB Cube object

Throws:

LensException

createDimensionTable

public void createDimensionTable(LensSessionHandle sessionid,
                                 XDimensionTable xDimTable)
                          throws LensException

Create a cube dimension table based on JAXB object

Specified by:

createDimensionTable in interface CubeMetastoreService

Parameters:

xDimTable - dim table spec

sessionid - The sessionid

Throws:

LensException

dropDimensionTable

public void dropDimensionTable(LensSessionHandle sessionid,
                               String dimTblName,
                               boolean cascade)
                        throws LensException

Description copied from interface: CubeMetastoreService

Drop a dimension table from the cube metastore

Specified by:

dropDimensionTable in interface CubeMetastoreService

Throws:

LensException

getDimensionTable

public XDimensionTable getDimensionTable(LensSessionHandle sessionid,
                                         String dimTblName)
                                  throws LensException

Description copied from interface: CubeMetastoreService

Get the dimension table from metastore

Specified by:

getDimensionTable in interface CubeMetastoreService

Returns:

The XDimensionTable

Throws:

LensException

updateDimensionTable

public void updateDimensionTable(LensSessionHandle sessionid,
                                 XDimensionTable dimensionTable)
                          throws LensException

Description copied from interface: CubeMetastoreService

Update/Alter the dimension table

Specified by:

updateDimensionTable in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

dimensionTable - The new definition of dimension table

Throws:

LensException

getDimTableStorages

public List<String> getDimTableStorages(LensSessionHandle sessionid,
                                        String dimension)
                                 throws LensException

Description copied from interface: CubeMetastoreService

Get all storages of dimension table

Specified by:

getDimTableStorages in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

dimension - The dimension table name

Returns:

list of storage names

Throws:

LensException

addDimTableStorage

public void addDimTableStorage(LensSessionHandle sessionid,
                               String dimTblName,
                               XStorageTableElement storageTable)
                        throws LensException

Description copied from interface: CubeMetastoreService

Add a storage to dimension table

Specified by:

addDimTableStorage in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

dimTblName - The dimension table name

storageTable - XStorageTableElement with storage name, table desc and dump period, if any.

Throws:

LensException

dropAllStoragesOfDimTable

public void dropAllStoragesOfDimTable(LensSessionHandle sessionid,
                                      String dimTblName)
                               throws LensException

Description copied from interface: CubeMetastoreService

Drop all storages of dimension table. Will drop underlying tables as well.

Specified by:

dropAllStoragesOfDimTable in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

dimTblName - The dimension table name

Throws:

LensException

getAllDimTableNames

public List<String> getAllDimTableNames(LensSessionHandle sessionid,
                                        String dimensionName)
                                 throws LensException

Description copied from interface: CubeMetastoreService

Get all dimension tables. dimensionName is an optional filter of dimension name. If provided, only the dimension tables belonging to given dimension will be returned

Specified by:

getAllDimTableNames in interface CubeMetastoreService

dimensionName - dimension name to be filtered with. Optional

Returns:

Throws:

LensException

dropAllStoragesOfFact

public void dropAllStoragesOfFact(LensSessionHandle sessionid,
                                  String factName)
                           throws LensException

Description copied from interface: CubeMetastoreService

Drop all storages of fact

Specified by:

dropAllStoragesOfFact in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

factName - The fact table name

Throws:

LensException

dropStorageOfDimTable

public void dropStorageOfDimTable(LensSessionHandle sessionid,
                                  String dimTblName,
                                  String storage)
                           throws LensException

Description copied from interface: CubeMetastoreService

Drop storage of dimension table specified by name.

Specified by:

dropStorageOfDimTable in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

dimTblName - The dimension table name

storage - The storage name

Throws:

LensException

getFactTable

public XFact getFactTable(LensSessionHandle sessionid,
                          String fact)
                   throws LensException

Description copied from interface: CubeMetastoreService

Get fact table given by name

Specified by:

getFactTable in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table name

Returns:

XFact

Throws:

LensException

getSegmentation

public XSegmentation getSegmentation(LensSessionHandle sessionid,
                                     String cubeSegName)
                              throws LensException

Description copied from interface: CubeMetastoreService

Create segmentation

Specified by:

getSegmentation in interface CubeMetastoreService

Parameters:

sessionid - The session id

cubeSegName - Ssegmentation name

Returns:

XSegmentation

Throws:

LensException

createFactTable

public void createFactTable(LensSessionHandle sessionid,
                            XFact fact)
                     throws LensException

Description copied from interface: CubeMetastoreService

Create fact table

Specified by:

createFactTable in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table definition

Throws:

LensException

updateFactTable

public void updateFactTable(LensSessionHandle sessionid,
                            XFact fact)
                     throws LensException

Description copied from interface: CubeMetastoreService

Update/Alter fact table

Specified by:

updateFactTable in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table's new definition

Throws:

LensException

createSegmentation

public void createSegmentation(LensSessionHandle sessionid,
                               XSegmentation cubeSeg)
                        throws LensException

Specified by:

createSegmentation in interface CubeMetastoreService

Parameters:

sessionid - The session id

cubeSeg - The segmentation

Throws:

LensException

updateSegmentation

public void updateSegmentation(LensSessionHandle sessionid,
                               XSegmentation cubeSeg)
                        throws LensException

Description copied from interface: CubeMetastoreService

Get segmentation given by name

Specified by:

updateSegmentation in interface CubeMetastoreService

Parameters:

sessionid - The session id

cubeSeg - The segmentation

Throws:

LensException

dropFactTable

public void dropFactTable(LensSessionHandle sessionid,
                          String fact,
                          boolean cascade)
                   throws LensException

Description copied from interface: CubeMetastoreService

Drop fact table.

Specified by:

dropFactTable in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table name

cascade - If true, underlying storage tables will also be dropped.

Throws:

LensException

dropSegmentation

public void dropSegmentation(LensSessionHandle sessionid,
                             String cubeSegName)
                      throws LensException

Description copied from interface: CubeMetastoreService

Update segmentation

Specified by:

dropSegmentation in interface CubeMetastoreService

Parameters:

sessionid - The session id

cubeSegName - Segmentation name

Throws:

LensException

getAllFactNames

public List<String> getAllFactNames(LensSessionHandle sessionid,
                                    String cubeName)
                             throws LensException

Description copied from interface: CubeMetastoreService

Get all fact names

Specified by:

getAllFactNames in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

cubeName - optional filter filter facts by cube name.

Returns:

List of fact table names

Throws:

LensException

getAllSegmentations

public List<String> getAllSegmentations(LensSessionHandle sessionid,
                                        String cubeName)
                                 throws LensException

Description copied from interface: CubeMetastoreService

Get all segmentations belong to Cube

Specified by:

getAllSegmentations in interface CubeMetastoreService

Parameters:

sessionid - The session id

cubeName - The cube Name

Returns:

Throws:

LensException

getStoragesOfFact

public List<String> getStoragesOfFact(LensSessionHandle sessionid,
                                      String fact)
                               throws LensException

Description copied from interface: CubeMetastoreService

Get all storages of fact

Specified by:

getStoragesOfFact in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table name

Returns:

List of all storage names on which fact is present

Throws:

LensException

getStorageOfFact

public XStorageTableElement getStorageOfFact(LensSessionHandle sessionid,
                                             String fact,
                                             String storageName)
                                      throws LensException

Description copied from interface: CubeMetastoreService

Get storage table of fact specifed by fact name, storage name

Specified by:

getStorageOfFact in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table name

storageName - The storage name

Returns:

Throws:

LensException

getStorageOfDim

public XStorageTableElement getStorageOfDim(LensSessionHandle sessionid,
                                            String dimTblName,
                                            String storageName)
                                     throws LensException

Description copied from interface: CubeMetastoreService

Get storage table element associated with dimension table for storage name specified

Specified by:

getStorageOfDim in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

dimTblName - The dimension table name

storageName - The storage name

Returns:

XStorageTableElement

Throws:

LensException

addStorageToFact

public void addStorageToFact(LensSessionHandle sessionid,
                             String fact,
                             XStorageTableElement storageTable)
                      throws LensException

Description copied from interface: CubeMetastoreService

Add storage to fact table

Specified by:

addStorageToFact in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table name

storageTable - XStorageTableElement containing storage name, update periods and table description

Throws:

LensException

dropStorageOfFact

public void dropStorageOfFact(LensSessionHandle sessionid,
                              String fact,
                              String storage)
                       throws LensException

Description copied from interface: CubeMetastoreService

Drop storage of fact specified by fact name, storage name

Specified by:

dropStorageOfFact in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table name

storage - The storage name

Throws:

LensException

getAllPartitionsOfFactStorage

public XPartitionList getAllPartitionsOfFactStorage(LensSessionHandle sessionid,
                                                    String fact,
                                                    String storageName,
                                                    String filter)
                                             throws LensException

Description copied from interface: CubeMetastoreService

Get all partitions of fact on a storage

Specified by:

getAllPartitionsOfFactStorage in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table name

storageName - The storage name

filter - The filter for partition listing

Returns:

List of XPartition

Throws:

LensException

addPartitionToFactStorage

public int addPartitionToFactStorage(LensSessionHandle sessionid,
                                     String fact,
                                     String storageName,
                                     XPartition partition)
                              throws LensException

Description copied from interface: CubeMetastoreService

Add partition to fact on a storage

Specified by:

addPartitionToFactStorage in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table name

storageName - The storage name

partition - XPartition

Returns:

number of partitions added. Either 0 or 1

Throws:

LensException

addPartitionsToFactStorage

public int addPartitionsToFactStorage(LensSessionHandle sessionid,
                                      String fact,
                                      String storageName,
                                      XPartitionList partitions)
                               throws LensException

Description copied from interface: CubeMetastoreService

Add partitions to fact on a storage

Specified by:

addPartitionsToFactStorage in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

fact - The fact table name

storageName - The storage name

partitions - XPartitionList

Returns:

Number of partitions added

Throws:

LensException

getAllPartitionsOfDimTableStorage

public XPartitionList getAllPartitionsOfDimTableStorage(LensSessionHandle sessionid,
                                                        String dimTable,
                                                        String storageName,
                                                        String filter)
                                                 throws LensException

Description copied from interface: CubeMetastoreService

Get all partitions of a dimension table in a storage

Specified by:

getAllPartitionsOfDimTableStorage in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

dimTable - The dimension table name

storageName - The storage name

filter - The filter for the list of partitions

Returns:

list of XPartition

Throws:

LensException

addPartitionToDimStorage

public int addPartitionToDimStorage(LensSessionHandle sessionid,
                                    String dimTblName,
                                    String storageName,
                                    XPartition partition)
                             throws LensException

Description copied from interface: CubeMetastoreService

Add partition to dimension table on a storage.

Specified by:

addPartitionToDimStorage in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

dimTblName - The dimension table name

storageName - The storage name

partition - XPartition

Returns:

number of partitions added. Either 0 or 1

Throws:

LensException

updatePartition

public void updatePartition(LensSessionHandle sessionid,
                            String tblName,
                            String storageName,
                            XPartition xPartition)
                     throws LensException

Specified by:

updatePartition in interface CubeMetastoreService

Throws:

LensException

updatePartitions

public void updatePartitions(LensSessionHandle sessionid,
                             String tblName,
                             String storageName,
                             XPartitionList xPartitions)
                      throws LensException

Specified by:

updatePartitions in interface CubeMetastoreService

Throws:

LensException

addPartitionsToDimStorage

public int addPartitionsToDimStorage(LensSessionHandle sessionid,
                                     String dimTblName,
                                     String storageName,
                                     XPartitionList partitions)
                              throws LensException

Description copied from interface: CubeMetastoreService

Add partitions to dimension table on a storage.

Specified by:

addPartitionsToDimStorage in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

dimTblName - The dimension table name

storageName - The storage name

partitions - XPartitionList

Returns:

Number of partitions added

Throws:

LensException

dropPartitionFromStorageByValues

public void dropPartitionFromStorageByValues(LensSessionHandle sessionid,
                                             String cubeTableName,
                                             String storageName,
                                             String values)
                                      throws LensException

Description copied from interface: CubeMetastoreService

Drop partition from storage with spec specified as comma separated string

Specified by:

dropPartitionFromStorageByValues in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

cubeTableName - The cube table name - fact/dimension table name

storageName - The storage name

values - The comma separated values for all partition columns

Throws:

LensException

dropPartitionFromStorageByFilter

public void dropPartitionFromStorageByFilter(LensSessionHandle sessionid,
                                             String cubeTableName,
                                             String storageName,
                                             String filter)
                                      throws LensException

Description copied from interface: CubeMetastoreService

Drop partition from storage with spec specified by filter

Specified by:

dropPartitionFromStorageByFilter in interface CubeMetastoreService

Parameters:

sessionid - The sessionid

cubeTableName - The cube table name - fact/dimension table name

storageName - The storage name

filter - The partition filter - all partitions which obey the filter will be dropped

Throws:

LensException

createStorage

public void createStorage(LensSessionHandle sessionid,
                          XStorage storage)
                   throws LensException

Description copied from interface: CubeMetastoreService

Create a storage

Specified by:

createStorage in interface CubeMetastoreService

Throws:

LensException

dropStorage

public void dropStorage(LensSessionHandle sessionid,
                        String storageName)
                 throws LensException

Description copied from interface: CubeMetastoreService

Drop a storage specified by name

Specified by:

dropStorage in interface CubeMetastoreService

Throws:

LensException

alterStorage

public void alterStorage(LensSessionHandle sessionid,
                         String storageName,
                         XStorage storage)
                  throws LensException

Description copied from interface: CubeMetastoreService

Alter storage specified by name, with new definition

Specified by:

alterStorage in interface CubeMetastoreService

Throws:

LensException

getStorage

public XStorage getStorage(LensSessionHandle sessionid,
                           String storageName)
                    throws LensException

Description copied from interface: CubeMetastoreService

Get Storage specified by name

Specified by:

getStorage in interface CubeMetastoreService

Throws:

LensException

getAllStorageNames

public List<String> getAllStorageNames(LensSessionHandle sessionid)
                                throws LensException

Description copied from interface: CubeMetastoreService

Get all storage names in current database

Specified by:

getAllStorageNames in interface CubeMetastoreService

Returns:

returns list of the storage names

Throws:

LensException

getAllBaseCubeNames

public List<String> getAllBaseCubeNames(LensSessionHandle sessionid)
                                 throws LensException

Description copied from interface: CubeMetastoreService

Get names of all base cube names in the current database

Specified by:

getAllBaseCubeNames in interface CubeMetastoreService

Returns:

list of cube names

Throws:

LensException

getAllDerivedCubeNames

public List<String> getAllDerivedCubeNames(LensSessionHandle sessionid)
                                    throws LensException

Description copied from interface: CubeMetastoreService

Get names of all derived cubes in the current database

Specified by:

getAllDerivedCubeNames in interface CubeMetastoreService

Returns:

list of cube names

Throws:

LensException

getAllQueryableCubeNames

public List<String> getAllQueryableCubeNames(LensSessionHandle sessionid)
                                      throws LensException

Description copied from interface: CubeMetastoreService

Get names of all cubes, which can be queried in the current database

Specified by:

getAllQueryableCubeNames in interface CubeMetastoreService

Parameters:

sessionid - session id

Returns:

list of cube names

Throws:

LensException

createDimension

public void createDimension(LensSessionHandle sessionid,
                            XDimension dimension)
                     throws LensException

Description copied from interface: CubeMetastoreService

Create a dimension based on JAXB Dimension object

Specified by:

createDimension in interface CubeMetastoreService

Throws:

LensException

getDimension

public XDimension getDimension(LensSessionHandle sessionid,
                               String dimName)
                        throws LensException

Description copied from interface: CubeMetastoreService

Get a dimension from the metastore

Specified by:

getDimension in interface CubeMetastoreService

Returns:

JAXB Dimension object

Throws:

LensException

dropDimension

public void dropDimension(LensSessionHandle sessionid,
                          String dimName)
                   throws LensException

Description copied from interface: CubeMetastoreService

Drop a dimension from the metastore in the currently deleted database.

Specified by:

dropDimension in interface CubeMetastoreService

Throws:

LensException

updateDimension

public void updateDimension(LensSessionHandle sessionid,
                            String dimName,
                            XDimension dimension)
                     throws LensException

Description copied from interface: CubeMetastoreService

Update an existing dimension

Specified by:

updateDimension in interface CubeMetastoreService

Parameters:

sessionid - dimName JAXB Dimension object

Throws:

LensException

getAllDimensionNames

public List<String> getAllDimensionNames(LensSessionHandle sessionid)
                                  throws LensException

Description copied from interface: CubeMetastoreService

Get all dimension names in the current session

Specified by:

getAllDimensionNames in interface CubeMetastoreService

Returns:

List of dimension names as List of string objects

Throws:

LensException

getNativeTable

public XNativeTable getNativeTable(LensSessionHandle sessionid,
                                   String name)
                            throws LensException

Description copied from interface: CubeMetastoreService

Get native table for the given name

Specified by:

getNativeTable in interface CubeMetastoreService

Parameters:

sessionid - session id

name - The table name

Returns:

XNativeTable object

Throws:

LensException

getAllNativeTableNames

public List<String> getAllNativeTableNames(LensSessionHandle sessionid,
                                           String dbOption,
                                           String dbName)
                                    throws LensException

Description copied from interface: CubeMetastoreService

Get names of all native tables

Specified by:

getAllNativeTableNames in interface CubeMetastoreService

Parameters:

sessionid - session id

dbOption - To get from current or all, the option is ignored if dbname is passed

dbName - The db name

Returns:

list of table names

Throws:

LensException

getFlattenedColumns

public XFlattenedColumns getFlattenedColumns(LensSessionHandle sessionHandle,
                                             String tableName,
                                             boolean addChains)
                                      throws LensException

Description copied from interface: CubeMetastoreService

Get flattened columns - all columns of table + all reachable columns

Specified by:

getFlattenedColumns in interface CubeMetastoreService

Parameters:

sessionHandle - The session handle

tableName - The table name - cube name or dimension name

Returns:

XFlattenedColumns

Throws:

LensException

getLatestDateOfCube

public Date getLatestDateOfCube(LensSessionHandle sessionid,
                                String cubeName,
                                String timeDimension)
                         throws LensException,
                                org.apache.hadoop.hive.ql.metadata.HiveException

Description copied from interface: CubeMetastoreService

Get the latest available date upto which data is available for the base cubes, for the time dimension

Specified by:

getLatestDateOfCube in interface CubeMetastoreService

Parameters:

sessionid - The session id

cubeName - The base cube name

timeDimension - time dimension name

Returns:

Date

Throws:

LensException

org.apache.hadoop.hive.ql.metadata.HiveException

getPartitionTimelines

public List<String> getPartitionTimelines(LensSessionHandle sessionid,
                                          String factName,
                                          String storage,
                                          String updatePeriod,
                                          String timeDimension)
                                   throws LensException,
                                          org.apache.hadoop.hive.ql.metadata.HiveException

Specified by:

getPartitionTimelines in interface CubeMetastoreService

Throws:

LensException

org.apache.hadoop.hive.ql.metadata.HiveException

getAllJoinChains

public XJoinChains getAllJoinChains(LensSessionHandle sessionHandle,
                                    String tableName)
                             throws LensException

Specified by:

getAllJoinChains in interface CubeMetastoreService

Throws:

LensException

getHealthStatus

public HealthStatus getHealthStatus()

Returns the health status of the service.

Specified by:

getHealthStatus in interface HealthCheckable

Returns: