org.apache.lens.server.metastore

Class MetastoreResource

java.lang.Object

org.apache.lens.server.metastore.MetastoreResource

public class MetastoreResource
extends Object

metastore resource api

This provides api for all things metastore.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MetastoreResource.Entity

Field Summary

Fields

Modifier and Type	Field and Description
static ObjectFactory	X_CUBE_OBJECT_FACTORY

Constructor Summary

Constructors

Constructor and Description
MetastoreResource()

Method Summary

Methods

Modifier and Type	Method and Description
APIResult	addPartitionsToDimStorage(LensSessionHandle sessionid, String dimTableName, String storage, XPartitionList partitions) Add new partitions for a storage of dimension
APIResult	addPartitionsToFactStorage(LensSessionHandle sessionid, String factName, String storage, XPartitionList partitions) Batch Add partitions for a storage of fact
APIResult	addPartitionToDimStorage(LensSessionHandle sessionid, String dimTableName, String storage, XPartition partition) Add a new partition for a storage of dimension
APIResult	addPartitionToFactStorage(LensSessionHandle sessionid, String factName, String storage, XPartition partition) Add a new partition for a storage of fact
APIResult	addStorageToFact(LensSessionHandle sessionid, String factName, XStorageTableElement storageTable) Add storage to fact table
APIResult	createDatabase(LensSessionHandle sessionid, boolean ignoreIfExisting, String dbName) Create a new database
APIResult	createDimension(LensSessionHandle sessionid, XDimension dimension) Create new dimension
APIResult	createDimensionStorage(LensSessionHandle sessionid, String dimTableName, XStorageTableElement storageTbl) Add storage to dimension table
APIResult	createDimensionTable(LensSessionHandle sessionid, XDimensionTable dimensionTable) Create a new dimension table
APIResult	createFactTable(LensSessionHandle sessionid, XFactTable fact) Create a new fact tabble
APIResult	createNewCube(LensSessionHandle sessionid, XCube cube) Create a new cube
APIResult	createNewStorage(LensSessionHandle sessionid, XStorage storage) Create new storage
APIResult	deleteAllCubes(LensSessionHandle sessionid) Delete all cubes
APIResult	deleteAllDimensions(LensSessionHandle sessionid) Delete all dimensions in metastore
APIResult	deleteAllFacts(LensSessionHandle sessionid, boolean cascade) Delete all fact tables
APIResult	deleteAllStorages(LensSessionHandle sessionid) Delete all storages in metastore
APIResult	dropAllStoragesOfDim(LensSessionHandle sessionid, String dimTableName) Drop all the storage tables of a dimension table
APIResult	dropAllStoragesOfFact(LensSessionHandle sessionid, String factName) Drop all the storage tables of a fact table
APIResult	dropCube(LensSessionHandle sessionid, String cubeName) Drop the cube, specified by name
APIResult	dropDatabase(LensSessionHandle sessionid, String dbName, boolean cascade) Delete the db specified by name.
APIResult	dropDimension(LensSessionHandle sessionid, String dimName) Drop the dimension, specified by name
APIResult	dropDimensionTable(LensSessionHandle sessionid, String dimension, boolean cascade) Drop the dimension table, specified by name
APIResult	dropFactTable(LensSessionHandle sessionid, String factName, boolean cascade) Drop the fact table, specified by name
APIResult	dropPartitionOfFactStorageByValues(LensSessionHandle sessionid, String factName, String storage, String values) Drop the partitions in the storage of a fact table, specified by exact values
APIResult	dropPartitionsOfDimStorageByFilter(LensSessionHandle sessionid, String dimTableName, String storage, String filter) Drop the partitions in the storage of a dimension table; can specified filter as well
APIResult	dropPartitionsOfDimStorageByValue(LensSessionHandle sessionid, String dimTableName, String storage, String values) Drop the partitions in the storage of a dimension table, specified by exact values
APIResult	dropPartitionsOfFactStorageByFilter(LensSessionHandle sessionid, String factName, String storage, String filter) Drop the partitions in the storage of a fact; can specified filter as well
APIResult	dropStorage(LensSessionHandle sessionid, String storageName) Drop the storage, specified by name
APIResult	dropStorageFromFact(LensSessionHandle sessionid, String factName, String storage) Drop the storage of a fact, specified by name
APIResult	dropStorageOfDim(LensSessionHandle sessionid, String dimTableName, String storage) Drop the storage of a dimension table, specified by name
StringList	getAllCubes(LensSessionHandle sessionid, String cubeTypes) Get all cubes in the metastores, of the specified type
StringList	getAllDatabases(LensSessionHandle sessionid) Get all databases in the metastore
StringList	getAllDimensionNames(LensSessionHandle sessionid) Get all dimensions in the metastore
StringList	getAllDimensionTablesOfDimension(LensSessionHandle sessionid, String dimensionName) Get all dimtables that belong to a dimension in the metastore
StringList	getAllDims(LensSessionHandle sessionid) Get all dimension tables in the metastore
StringList	getAllFacts(LensSessionHandle sessionid) Get all fact tables in the metastore in the current database
StringList	getAllFactsOfCube(LensSessionHandle sessionid, String cubeName) Get all facts that belong to a cube in the metastore
JAXBElement<XJoinChains>	getAllJoinChains(LensSessionHandle sessionid, String tableName) Get all chains that belong to a table(cube or dimension) in the metastore
StringList	getAllNativeTables(LensSessionHandle sessionid, String dbOption, String dbName) Get all native tables.
JAXBElement<XPartitionList>	getAllPartitionsOfDimStorage(LensSessionHandle sessionid, String dimension, String storage, String filter) Get all partition of the dimension table in the specified storage; can be filtered
JAXBElement<XPartitionList>	getAllPartitionsOfFactStorageByFilter(LensSessionHandle sessionid, String factName, String storage, String filter) Get all partitions of the fact table in the specified storage; can be filtered as well.
StringList	getAllStorages(LensSessionHandle sessionid) Get all storages in the metastore
JAXBElement<XCube>	getCube(LensSessionHandle sessionid, String cubeName) Get the cube specified by name
String	getDatabase(LensSessionHandle sessionid) Get the current database
JAXBElement<XDimension>	getDimension(LensSessionHandle sessionid, String dimName) Get the dimension specified by name
StringList	getDimensionStorages(LensSessionHandle sessionid, String dimension) Get all storages of the dimension table in the metastore
JAXBElement<XDimensionTable>	getDimensionTable(LensSessionHandle sessionid, String dimTableName) Get the dimension table specified by name
JAXBElement<XFactTable>	getFactTable(LensSessionHandle sessionid, String factName) Get the fact table specified by name
JAXBElement<XFlattenedColumns>	getFlattenedColumns(LensSessionHandle sessionid, String tableName, boolean addChains) Get flattened list of columns reachable from a cube or a dimension
DateTime	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.
String	getMessage() API to know if metastore service is up and running
JAXBElement<XNativeTable>	getNativeTable(LensSessionHandle sessionid, String tableName) Get the native table passed in name
StringList	getPartitionTimelines(LensSessionHandle sessionid, String factName, String storage, String updatePeriod, String timeDimension) Get the partition timelines.
JAXBElement<XStorage>	getStorage(LensSessionHandle sessionid, String storageName) Get the storage specified by name
JAXBElement<XStorageTableElement>	getStorageOfDim(LensSessionHandle sessionid, String dimTableName, String storage) Get the dim storage table
JAXBElement<XStorageTableElement>	getStorageOfFact(LensSessionHandle sessionid, String factName, String storage) Get the fact storage table
StringList	getStoragesOfFact(LensSessionHandle sessionid, String factName) Get all storages of the fact table in the metastore
static CubeMetastoreService	getSvc()
APIResult	setDatabase(LensSessionHandle sessionid, String dbName) Set the current db
APIResult	updateCube(LensSessionHandle sessionid, String cubeName, XCube cube) Update cube definition
APIResult	updateCubeDimension(LensSessionHandle sessionid, String dimTableName, XDimensionTable dimensionTable) Update dimension table definition
APIResult	updateDimension(LensSessionHandle sessionid, String dimName, XDimension dimension) Update dimension definition
APIResult	updateFactTable(LensSessionHandle sessionid, String factName, XFactTable fact) Update fact table definition
APIResult	updatePartitionOfDimStorage(LensSessionHandle sessionid, String dimTableName, String storage, XPartition partition) Updates an existing partition for a storage of dimension
APIResult	updatePartitionOfFactStorage(LensSessionHandle sessionid, String factName, String storage, XPartition partition) updates an existing partition for a storage of fact
APIResult	updatePartitionsOfDimStorage(LensSessionHandle sessionid, String dimTableName, String storage, XPartitionList partitions) Add new partitions for a storage of dimension
APIResult	updatePartitionsOfFactStorage(LensSessionHandle sessionid, String factName, String storage, XPartitionList partitions) Batch Update partitions for a storage of fact
APIResult	updateStorage(LensSessionHandle sessionid, String storageName, XStorage storage) Update storage definition

Methods inherited from class java.lang.Object

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

Field Detail

X_CUBE_OBJECT_FACTORY

public static final ObjectFactory X_CUBE_OBJECT_FACTORY

Constructor Detail

MetastoreResource

public MetastoreResource()

Method Detail

getSvc

public static CubeMetastoreService getSvc()

getMessage

public String getMessage()

API to know if metastore service is up and running

Returns:

Simple text saying it up

getAllDatabases

public StringList getAllDatabases(LensSessionHandle sessionid)

Get all databases in the metastore

Parameters:

sessionid - The sessionid in which user is working

Returns:

StringList consisting of all database names.

Throws:

javax.ws.rs.WebApplicationException

getDatabase

public String getDatabase(LensSessionHandle sessionid)

Get the current database

Parameters:

sessionid - The sessionid in which user is working

Returns:

The current db name

setDatabase

public APIResult setDatabase(LensSessionHandle sessionid,
                    String dbName)

Set the current db

Parameters:

sessionid - The sessionid in which user is working

dbName - The db name

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if set was successful. APIResult with state APIResult.Status.FAILED, if set has failed

dropDatabase

public APIResult dropDatabase(LensSessionHandle sessionid,
                     String dbName,
                     boolean cascade)

Delete the db specified by name. Deleting underlying tables is optional. If db does not exist, delete is ignored.

Parameters:

sessionid - The sessionid in which user is working

dbName - The db name

cascade - if true, all the tables inside the db will also be dropped.

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if delete was successful. APIResult with state APIResult.Status.FAILED, if delete has failed

createDatabase

public APIResult createDatabase(LensSessionHandle sessionid,
                       boolean ignoreIfExisting,
                       String dbName)

Create a new database

Parameters:

sessionid - The sessionid in which user is working

ignoreIfExisting - If true, create will be ignored if db already exists, otherwise it fails.

dbName - The db name

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if create was successful. APIResult with state APIResult.Status.FAILED, if create has failed

getAllNativeTables

public StringList getAllNativeTables(LensSessionHandle sessionid,
                            String dbOption,
                            String dbName)

Get all native tables.

Parameters:

sessionid - The sessionid in which user is working

dbOption - The options available are 'current' and 'all'. If option is current, gives all tables from current db. If option is all, gives all tables from all databases. If dbname is passed, dbOption is ignored. If no dbOption or dbname are passed, then default is to get tables from current db.

dbName - The db name. If not empty, the tables in the db will be returned

Returns:

StringList consisting of all table names.

Throws:

javax.ws.rs.WebApplicationException

getNativeTable

public JAXBElement<XNativeTable> getNativeTable(LensSessionHandle sessionid,
                                       String tableName)

Get the native table passed in name

Parameters:

sessionid - The sessionid in which user is working

tableName - The native table name

Returns:

JAXB representation of XNativeTable

Throws:

javax.ws.rs.WebApplicationException

getAllCubes

public StringList getAllCubes(LensSessionHandle sessionid,
                     String cubeTypes)

Get all cubes in the metastores, of the specified type

Parameters:

sessionid - The sessionid in which user is working

cubeTypes - The type of cubes. Accepted values are 'all' or 'base' or 'derived' or 'queryable'

Returns:

StringList consisting of all cubes names

deleteAllCubes

public APIResult deleteAllCubes(LensSessionHandle sessionid)

Delete all cubes

Parameters:

sessionid - The sessionid in which user is working

Returns:

APIResult with state APIResult.Status.SUCCEEDED in case of successful delete. APIResult with state APIResult.Status.FAILED in case of delete failure. APIResult with state APIResult.Status.PARTIAL in case of partial delete.

createNewCube

public APIResult createNewCube(LensSessionHandle sessionid,
                      XCube cube)

Create a new cube

Parameters:

sessionid - The sessionid in which user is working

cube - The XCube representation of the cube definition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if create was successful. APIResult with state APIResult.Status.FAILED, if create has failed

updateCube

public APIResult updateCube(LensSessionHandle sessionid,
                   String cubeName,
                   XCube cube)

Update cube definition

Parameters:

sessionid - The sessionid in which user is working

cubeName - The cube name

cube - The XCube representation of the updated cube definition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if update was successful. APIResult with state APIResult.Status.FAILED, if update has failed

getCube

public JAXBElement<XCube> getCube(LensSessionHandle sessionid,
                         String cubeName)

Get the cube specified by name

Parameters:

sessionid - The sessionid in which user is working

cubeName - The cube name

Returns:

JAXB representation of XCube

dropCube

public APIResult dropCube(LensSessionHandle sessionid,
                 String cubeName)

Drop the cube, specified by name

Parameters:

sessionid - The sessionid in which user is working

cubeName - The cube name

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

getAllStorages

public StringList getAllStorages(LensSessionHandle sessionid)

Get all storages in the metastore

Parameters:

sessionid - The sessionid in which user is working

Returns:

StringList consisting of all the storage names

Throws:

javax.ws.rs.WebApplicationException - Wraps LensException

createNewStorage

public APIResult createNewStorage(LensSessionHandle sessionid,
                         XStorage storage)

Create new storage

Parameters:

sessionid - The sessionid in which user is working

storage - The XStorage representation of storage

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if create was successful. APIResult with state APIResult.Status.FAILED, if create has failed

deleteAllStorages

public APIResult deleteAllStorages(LensSessionHandle sessionid)

Delete all storages in metastore

Parameters:

sessionid - The sessionid in which user is working

Returns:

APIResult with state APIResult.Status.SUCCEEDED in case of successful delete. APIResult with state APIResult.Status.FAILED in case of delete failure. APIResult with state APIResult.Status.PARTIAL in case of partial delete.

updateStorage

public APIResult updateStorage(LensSessionHandle sessionid,
                      String storageName,
                      XStorage storage)

Update storage definition

Parameters:

sessionid - The sessionid in which user is working

storageName - The storage name

storage - The XStorage representation of the updated storage definition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if update was successful. APIResult with state APIResult.Status.FAILED, if update has failed

getStorage

public JAXBElement<XStorage> getStorage(LensSessionHandle sessionid,
                               String storageName)
                                 throws Exception

Get the storage specified by name

Parameters:

sessionid - The sessionid in which user is working

storageName - The storage name

Returns:

JAXB representation of XStorage

Throws:

Exception

dropStorage

public APIResult dropStorage(LensSessionHandle sessionid,
                    String storageName)

Drop the storage, specified by name

Parameters:

sessionid - The sessionid in which user is working

storageName - The storage name

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

getAllDimensionNames

public StringList getAllDimensionNames(LensSessionHandle sessionid)

Get all dimensions in the metastore

Parameters:

sessionid - The sessionid in which user is working

Returns:

StringList consisting of all the dimension names

Throws:

javax.ws.rs.WebApplicationException - wraps lensException

createDimension

public APIResult createDimension(LensSessionHandle sessionid,
                        XDimension dimension)

Create new dimension

Parameters:

sessionid - The sessionid in which user is working

dimension - The XDimension representation of dimension

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if create was successful. APIResult with state APIResult.Status.FAILED, if create has failed

deleteAllDimensions

public APIResult deleteAllDimensions(LensSessionHandle sessionid)

Delete all dimensions in metastore

Parameters:

sessionid - The sessionid in which user is working

Returns:

APIResult with state APIResult.Status.SUCCEEDED in case of successful delete. APIResult with state APIResult.Status.FAILED in case of delete failure. APIResult with state APIResult.Status.PARTIAL in case of partial delete.

updateDimension

public APIResult updateDimension(LensSessionHandle sessionid,
                        String dimName,
                        XDimension dimension)

Update dimension definition

Parameters:

sessionid - The sessionid in which user is working

dimName - The dimension name

dimension - The XDimension representation of the updated dimension definition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if update was successful. APIResult with state APIResult.Status.FAILED, if update has failed

getDimension

public JAXBElement<XDimension> getDimension(LensSessionHandle sessionid,
                                   String dimName)
                                     throws Exception

Get the dimension specified by name

Parameters:

sessionid - The sessionid in which user is working

dimName - The dimension name

Returns:

JAXB representation of XDimension

Throws:

Exception

dropDimension

public APIResult dropDimension(LensSessionHandle sessionid,
                      String dimName)

Drop the dimension, specified by name

Parameters:

sessionid - The sessionid in which user is working

dimName - The dimension name

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

getAllDimensionTablesOfDimension

public StringList getAllDimensionTablesOfDimension(LensSessionHandle sessionid,
                                          String dimensionName)
                                            throws LensException

Get all dimtables that belong to a dimension in the metastore

Parameters:

sessionid - The sessionid in which user is working

dimensionName - name of the dimension

Returns:

List of XDimensionTable objects

Throws:

LensException

getAllFactsOfCube

public StringList getAllFactsOfCube(LensSessionHandle sessionid,
                           String cubeName)
                             throws LensException

Get all facts that belong to a cube in the metastore

Parameters:

sessionid - The sessionid in which user is working

cubeName - name of the base cube or derived cube

Returns:

List of XFactTable objects

Throws:

LensException

getAllFacts

public StringList getAllFacts(LensSessionHandle sessionid)
                       throws LensException

Get all fact tables in the metastore in the current database

Parameters:

sessionid - The sessionid in which user is working

Returns:

StringList consisting of all fact table names

Throws:

LensException

deleteAllFacts

public APIResult deleteAllFacts(LensSessionHandle sessionid,
                       boolean cascade)

Delete all fact tables

Parameters:

sessionid - The sessionid in which user is working

cascade - if set to true, all the underlying tables will be dropped, if set to false, only the fact table will be dropped

Returns:

APIResult with state APIResult.Status.SUCCEEDED in case of successful delete. APIResult with state APIResult.Status.FAILED in case of delete failure. APIResult with state APIResult.Status.PARTIAL in case of partial delete.

getFactTable

public JAXBElement<XFactTable> getFactTable(LensSessionHandle sessionid,
                                   String factName)
                                     throws LensException

Get the fact table specified by name

Parameters:

sessionid - The sessionid in which user is working

factName - The fact table name

Returns:

JAXB representation of XFactTable

Throws:

LensException

createFactTable

public APIResult createFactTable(LensSessionHandle sessionid,
                        XFactTable fact)
                          throws LensException

Create a new fact tabble

Parameters:

sessionid - The sessionid in which user is working

fact - The XFactTable representation of the fact table definition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if create was successful. APIResult with state APIResult.Status.FAILED, if create has failed

Throws:

LensException

updateFactTable

public APIResult updateFactTable(LensSessionHandle sessionid,
                        String factName,
                        XFactTable fact)
                          throws LensException

Update fact table definition

Parameters:

sessionid - The sessionid in which user is working

factName - name of the fact table

fact - The XFactTable representation of the updated fact table definition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if update was successful. APIResult with state APIResult.Status.FAILED, if update has failed

Throws:

LensException

dropFactTable

public APIResult dropFactTable(LensSessionHandle sessionid,
                      String factName,
                      boolean cascade)
                        throws LensException

Drop the fact table, specified by name

Parameters:

sessionid - The sessionid in which user is working

factName - The fact table name

cascade - If true, all the storage tables of the fact will also be dropped

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

Throws:

LensException

getStoragesOfFact

public StringList getStoragesOfFact(LensSessionHandle sessionid,
                           String factName)
                             throws LensException

Get all storages of the fact table in the metastore

Parameters:

sessionid - The sessionid in which user is working

factName - The fact table name

Returns:

StringList consisting of all the storage names

Throws:

LensException

dropAllStoragesOfFact

public APIResult dropAllStoragesOfFact(LensSessionHandle sessionid,
                              String factName)

Drop all the storage tables of a fact table

Parameters:

sessionid - The sessionid in which user is working

factName - The fact table name

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

addStorageToFact

public APIResult addStorageToFact(LensSessionHandle sessionid,
                         String factName,
                         XStorageTableElement storageTable)

Add storage to fact table

Parameters:

sessionid - The sessionid in which user is working

factName - The fact table name

storageTable - The storage table description

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if add was successful. APIResult with state APIResult.Status.FAILED, if add has failed

dropStorageFromFact

public APIResult dropStorageFromFact(LensSessionHandle sessionid,
                            String factName,
                            String storage)

Drop the storage of a fact, specified by name

Parameters:

sessionid - The sessionid in which user is working

factName - The fact table name

storage - The storage name

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

getStorageOfFact

public JAXBElement<XStorageTableElement> getStorageOfFact(LensSessionHandle sessionid,
                                                 String factName,
                                                 String storage)
                                                   throws LensException

Get the fact storage table

Parameters:

sessionid - The sessionid in which user is working

factName - The fact table name

storage - The storage name

Returns:

JAXB representation of XStorageTableElement

Throws:

LensException

getAllPartitionsOfFactStorageByFilter

public JAXBElement<XPartitionList> getAllPartitionsOfFactStorageByFilter(LensSessionHandle sessionid,
                                                                String factName,
                                                                String storage,
                                                                String filter)
                                                                  throws LensException

Get all partitions of the fact table in the specified storage; can be filtered as well.

Parameters:

sessionid - The sessionid in which user is working

factName - The fact table name

storage - The storage name

filter - The filter for partitions, string representation of the filter for ex: x < "xxx" and y > "yyy"

Returns:

JAXB representation of XPartitionList containing XPartition objects

Throws:

LensException

dropPartitionsOfFactStorageByFilter

public APIResult dropPartitionsOfFactStorageByFilter(LensSessionHandle sessionid,
                                            String factName,
                                            String storage,
                                            String filter)

Drop the partitions in the storage of a fact; can specified filter as well

Parameters:

sessionid - The sessionid in which user is working

factName - The fact table name

storage - The storage name

filter - The filter for partitions, string representation of the filter for ex: x < "xxx" and y > "yyy"

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

addPartitionToFactStorage

public APIResult addPartitionToFactStorage(LensSessionHandle sessionid,
                                  String factName,
                                  String storage,
                                  XPartition partition)

Add a new partition for a storage of fact

Parameters:

sessionid - The sessionid in which user is working

factName - fact table name

storage - storage name

partition - XPartition representation of partition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if add was successful. APIResult with state APIResult.Status.FAILED, if add has failed

updatePartitionOfFactStorage

public APIResult updatePartitionOfFactStorage(LensSessionHandle sessionid,
                                     String factName,
                                     String storage,
                                     XPartition partition)

updates an existing partition for a storage of fact

Parameters:

sessionid - The sessionid in which user is working

factName - fact table name

storage - storage name

partition - XPartition representation of partition.

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if update was successful. APIResult with state APIResult.Status.FAILED, if update has failed

addPartitionsToFactStorage

public APIResult addPartitionsToFactStorage(LensSessionHandle sessionid,
                                   String factName,
                                   String storage,
                                   XPartitionList partitions)

Batch Add partitions for a storage of fact

Parameters:

sessionid - The sessionid in which user is working

factName - fact table name

storage - storage name

partitions - XPartitionList representation of partitions

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if add was successful. APIResult with state APIResult.Status.FAILED, if add has failed

updatePartitionsOfFactStorage

public APIResult updatePartitionsOfFactStorage(LensSessionHandle sessionid,
                                      String factName,
                                      String storage,
                                      XPartitionList partitions)

Batch Update partitions for a storage of fact

Parameters:

sessionid - The sessionid in which user is working

factName - fact table name

storage - storage name

partitions - XPartitionList representation of partitions

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if update was successful. APIResult with state APIResult.Status.FAILED, if update has failed

dropPartitionOfFactStorageByValues

public APIResult dropPartitionOfFactStorageByValues(LensSessionHandle sessionid,
                                           String factName,
                                           String storage,
                                           String values)

Drop the partitions in the storage of a fact table, specified by exact values

Parameters:

sessionid - The sessionid in which user is working

factName - The fact table name

storage - The storage name

values - Comma separated values

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

getAllDims

public StringList getAllDims(LensSessionHandle sessionid)
                      throws LensException

Get all dimension tables in the metastore

Parameters:

sessionid - The sessionid in which user is working

Returns:

StringList consisting of all dimension table names

Throws:

LensException

createDimensionTable

public APIResult createDimensionTable(LensSessionHandle sessionid,
                             XDimensionTable dimensionTable)

Create a new dimension table

Parameters:

sessionid - The sessionid in which user is working

dimensionTable - The XDimensionTable representation of the dimension table definition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if create was successful. APIResult with state APIResult.Status.FAILED, if create has failed

updateCubeDimension

public APIResult updateCubeDimension(LensSessionHandle sessionid,
                            String dimTableName,
                            XDimensionTable dimensionTable)

Update dimension table definition

Parameters:

sessionid - The sessionid in which user is working

dimensionTable - The XDimensionTable representation of the updated dim table definition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if update was successful. APIResult with state APIResult.Status.FAILED, if update has failed

dropDimensionTable

public APIResult dropDimensionTable(LensSessionHandle sessionid,
                           String dimension,
                           boolean cascade)

Drop the dimension table, specified by name

Parameters:

sessionid - The sessionid in which user is working

dimension - The dimension table name

cascade - if true, all the storage tables of dimension table will also be dropped

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

getDimensionTable

public JAXBElement<XDimensionTable> getDimensionTable(LensSessionHandle sessionid,
                                             String dimTableName)
                                               throws LensException

Get the dimension table specified by name

Parameters:

sessionid - The sessionid in which user is working

dimTableName - The cube name

Returns:

JAXB representation of XDimensionTable

Throws:

LensException

getDimensionStorages

public StringList getDimensionStorages(LensSessionHandle sessionid,
                              String dimension)
                                throws LensException

Get all storages of the dimension table in the metastore

Parameters:

sessionid - The sessionid in which user is working

dimension - The dimension table name

Returns:

StringList consisting of all the storage names

Throws:

LensException

createDimensionStorage

public APIResult createDimensionStorage(LensSessionHandle sessionid,
                               String dimTableName,
                               XStorageTableElement storageTbl)

Add storage to dimension table

Parameters:

sessionid - The sessionid in which user is working

dimTableName - The dimension table name

storageTbl - The Storage table description

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if add was successful. APIResult with state APIResult.Status.FAILED, if add has failed

getStorageOfDim

public JAXBElement<XStorageTableElement> getStorageOfDim(LensSessionHandle sessionid,
                                                String dimTableName,
                                                String storage)
                                                  throws LensException

Get the dim storage table

Parameters:

sessionid - The sessionid in which user is working

dimTableName - The fact table name

storage - The storage name

Returns:

JAXB representation of XStorageTableElement

Throws:

LensException

dropAllStoragesOfDim

public APIResult dropAllStoragesOfDim(LensSessionHandle sessionid,
                             String dimTableName)

Drop all the storage tables of a dimension table

Parameters:

sessionid - The sessionid in which user is working

dimTableName - The dimension table name

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

dropStorageOfDim

public APIResult dropStorageOfDim(LensSessionHandle sessionid,
                         String dimTableName,
                         String storage)

Drop the storage of a dimension table, specified by name

Parameters:

sessionid - The sessionid in which user is working

dimTableName - The dimension table name

storage - The storage name

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

getAllPartitionsOfDimStorage

public JAXBElement<XPartitionList> getAllPartitionsOfDimStorage(LensSessionHandle sessionid,
                                                       String dimension,
                                                       String storage,
                                                       String filter)
                                                         throws LensException

Get all partition of the dimension table in the specified storage; can be filtered

Parameters:

sessionid - The sessionid in which user is working

dimension - The dimension table name

storage - The storage name

filter - The filter for partitions, string representation of the filter for ex: x < "xxx" and y > "yyy"

Returns:

JAXB representation of XPartitionList containing XPartition objects

Throws:

LensException

dropPartitionsOfDimStorageByFilter

public APIResult dropPartitionsOfDimStorageByFilter(LensSessionHandle sessionid,
                                           String dimTableName,
                                           String storage,
                                           String filter)

Drop the partitions in the storage of a dimension table; can specified filter as well

Parameters:

sessionid - The sessionid in which user is working

dimTableName - The dimension table name

storage - The storage name

filter - The filter for partitions, string representation of the filter for ex: x < 'xxx' and y > 'yyy'

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

dropPartitionsOfDimStorageByValue

public APIResult dropPartitionsOfDimStorageByValue(LensSessionHandle sessionid,
                                          String dimTableName,
                                          String storage,
                                          String values)

Drop the partitions in the storage of a dimension table, specified by exact values

Parameters:

sessionid - The sessionid in which user is working

dimTableName - The dimension table name

storage - The storage name

values - Comma separated values

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if drop was successful. APIResult with state APIResult.Status.FAILED, if drop has failed

addPartitionToDimStorage

public APIResult addPartitionToDimStorage(LensSessionHandle sessionid,
                                 String dimTableName,
                                 String storage,
                                 XPartition partition)

Add a new partition for a storage of dimension

Parameters:

sessionid - The sessionid in which user is working

dimTableName - dimension table name

storage - storage name

partition - XPartition representation of partition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if add was successful. APIResult with state APIResult.Status.FAILED, if add has failed

updatePartitionOfDimStorage

public APIResult updatePartitionOfDimStorage(LensSessionHandle sessionid,
                                    String dimTableName,
                                    String storage,
                                    XPartition partition)

Updates an existing partition for a storage of dimension

Parameters:

sessionid - The sessionid in which user is working

dimTableName - dimension table name

storage - storage name

partition - XPartition representation of partition

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if update was successful. APIResult with state APIResult.Status.FAILED, if update has failed

addPartitionsToDimStorage

public APIResult addPartitionsToDimStorage(LensSessionHandle sessionid,
                                  String dimTableName,
                                  String storage,
                                  XPartitionList partitions)

Add new partitions for a storage of dimension

Parameters:

sessionid - The sessionid in which user is working

dimTableName - dimension table name

storage - storage name

partitions - XPartitionList representation of list of partitions

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if add was successful. APIResult with state APIResult.Status.FAILED, if add has failed

updatePartitionsOfDimStorage

public APIResult updatePartitionsOfDimStorage(LensSessionHandle sessionid,
                                     String dimTableName,
                                     String storage,
                                     XPartitionList partitions)

Add new partitions for a storage of dimension

Parameters:

sessionid - The sessionid in which user is working

dimTableName - dimension table name

storage - storage name

partitions - XPartitionList representation of list of partitions

Returns:

APIResult with state APIResult.Status.SUCCEEDED, if update was successful. APIResult with state APIResult.Status.FAILED, if update has failed

getFlattenedColumns

public JAXBElement<XFlattenedColumns> getFlattenedColumns(LensSessionHandle sessionid,
                                                 String tableName,
                                                 boolean addChains)

Get flattened list of columns reachable from a cube or a dimension

Parameters:

sessionid - session id

tableName - name of the table

addChains - whether columns accessed via chains should also be returned

Returns:

list of measures, expressions or dimension attributes

getAllJoinChains

public JAXBElement<XJoinChains> getAllJoinChains(LensSessionHandle sessionid,
                                        String tableName)
                                          throws LensException

Get all chains that belong to a table(cube or dimension) in the metastore

Parameters:

sessionid - The sessionid in which user is working

tableName - name of the table. can be either cube or dimension

Returns:

XJoinChains object

Throws:

LensException

getLatestDateOfCube

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

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

Parameters:

sessionid - The sessionid in which user is working

timeDimension - time dimension name

cubeName - name of the base cube

Returns:

DateTime object which has Date in it.

Throws:

LensException

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

getPartitionTimelines

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

Get the partition timelines.

Parameters:

sessionid - The sessionid in which user is working

factName - name of the fact

storage - storage Name

updatePeriod - update period

timeDimension - time dimension name

Returns:

List os partition timelines.

Throws:

LensException

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