org.apache.lens.client

Class LensMetadataClient

java.lang.Object

org.apache.lens.client.LensMetadataClient

public class LensMetadataClient
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static Unmarshaller	JAXB_UNMARSHALLER

Constructor Summary

Constructors

Constructor and Description
LensMetadataClient(LensConnection connection)

Method Summary

Methods

Modifier and Type	Method and Description
APIResult	addPartitionsToDimensionTable(String dimTblName, String storage, String partitionsSpec)
APIResult	addPartitionsToDimensionTable(String dimTblName, String storage, XPartitionList partitions)
APIResult	addPartitionsToFactTable(String fact, String storage, String partitionsSpec)
APIResult	addPartitionsToFactTable(String fact, String storage, XPartitionList partitions)
APIResult	addPartitionToDimensionTable(String dimTblName, String storage, String partitionSpec)
APIResult	addPartitionToDimensionTable(String dimTblName, String storage, XPartition partition)
APIResult	addPartitionToFactTable(String fact, String storage, String partitionSpec)
APIResult	addPartitionToFactTable(String fact, String storage, XPartition partition)
APIResult	addStorageToDimTable(String dimTblName, String table)
APIResult	addStorageToDimTable(String dimTblName, XStorageTableElement table)
APIResult	addStorageToFactTable(String factname, String storageSpec)
APIResult	addStorageToFactTable(String factname, XStorageTableElement storage)
APIResult	createCube(String cubeSpec)
APIResult	createCube(XCube cube)
APIResult	createDatabase(String database)
APIResult	createDatabase(String database, boolean ignoreIfExists)
APIResult	createDimension(String dimSpec)
APIResult	createDimension(XDimension dimension)
APIResult	createDimensionTable(String tableXml)
APIResult	createDimensionTable(XDimensionTable table)
APIResult	createFactTable(String factSpec)
APIResult	createFactTable(XFactTable f)
APIResult	createNewStorage(String storage)
APIResult	createNewStorage(XStorage storage)
APIResult	deleteAllFactTables(boolean cascade)
APIResult	dropAllCubes()
APIResult	dropAllDimensions()
APIResult	dropAllPartitionsOfDimensionTable(String dimTblName, String storage)
APIResult	dropAllPartitionsOfDimensionTable(String dimTblName, String storage, List<String> vals)
APIResult	dropAllPartitionsOfDimensionTable(String dimTblName, String storage, String filter)
APIResult	dropAllStorages()
APIResult	dropAllStoragesOfDimension(String dimTblName)
APIResult	dropAllStoragesOfFactTable(String factName)
APIResult	dropCube(String cubeName)
APIResult	dropDatabase(String database)
APIResult	dropDatabase(String database, boolean cascade)
APIResult	dropDimension(String dimName)
APIResult	dropDimensionTable(String table)
APIResult	dropDimensionTable(String table, boolean cascade)
APIResult	dropFactTable(String factName)
APIResult	dropFactTable(String factName, boolean cascade)
APIResult	dropPartitionsOfFactTable(String factName, String storage)
APIResult	dropPartitionsOfFactTable(String factName, String storage, List<String> partitions)
APIResult	dropPartitionsOfFactTable(String factName, String storage, String filter)
APIResult	dropStorage(String storageName)
APIResult	dropStorageFromFactTable(String factName, String storageName)
APIResult	dropStoragesOfDimensionTable(String dimTblName, String storage)
List<String>	getAllCubes()
List<String>	getAlldatabases()
List<String>	getAllDimensions()
List<String>	getAllDimensionTables()
List<String>	getAllDimensionTables(String dimensionName)
List<String>	getAllFactTables()
List<String>	getAllFactTables(String cubeName)
List<String>	getAllNativeTables()
List<XPartition>	getAllPartitionsOfDimensionTable(String dimTblName, String storage)
List<XPartition>	getAllPartitionsOfDimensionTable(String dimTblName, String storage, String filter)
List<String>	getAllStorages()
List<String>	getAllStoragesOfDimTable(String dimTblName)
List<String>	getAllStoragesOfFactTable(String factName)
XCube	getCube(String cubeName)
String	getCurrentDatabase()
XDimension	getDimension(String dimName)
XDimensionTable	getDimensionTable(String table)
XFactTable	getFactTable(String factTableName)
XJoinChains	getJoinChains(String tableName)
Date	getLatestDateOfCube(String cubeName, String timePartition)
XNativeTable	getNativeTable(String tblName)
List<XPartition>	getPartitionsOfFactTable(String factName, String storage)
List<XPartition>	getPartitionsOfFactTable(String factName, String storage, String filter)
List<String>	getPartitionTimelines(String factName, String storageName, String updatePeriod, String timeDimension)
XFlattenedColumns	getQueryableFields(String tableName, boolean flattened)
XStorage	getStorage(String storageName)
XStorageTableElement	getStorageOfDimensionTable(String dimTblName, String storage)
XStorageTableElement	getStorageOfFactTable(String factName, String storageName)
APIResult	setDatabase(String database)
APIResult	updateCube(String cubeName, String cubeSpec)
APIResult	updateCube(String cubeName, XCube cube)
APIResult	updateDimension(String dimName, String dimSpec)
APIResult	updateDimension(String dimName, XDimension dimension)
APIResult	updateDimensionTable(String dimTblName, String dimSpec)
APIResult	updateDimensionTable(XDimensionTable table)
APIResult	updateFactTable(String factName, String table)
APIResult	updateFactTable(String factName, XFactTable table)
APIResult	updatePartitionOfDimensionTable(String dimTblName, String storage, String partitionSpec)
APIResult	updatePartitionOfDimensionTable(String dimTblName, String storage, XPartition partition)
APIResult	updatePartitionOfFactTable(String fact, String storage, String partitionSpec)
APIResult	updatePartitionOfFactTable(String fact, String storage, XPartition partition)
APIResult	updatePartitionsOfDimensionTable(String dimTblName, String storage, String partitionsSpec)
APIResult	updatePartitionsOfDimensionTable(String dimTblName, String storage, XPartitionList partitions)
APIResult	updatePartitionsOfFactTable(String fact, String storage, String partitionsSpec)
APIResult	updatePartitionsOfFactTable(String fact, String storage, XPartitionList partitions)
APIResult	updateStorage(String storageName, String storage)
APIResult	updateStorage(String storageName, XStorage storage)

Methods inherited from class java.lang.Object

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

Field Detail

JAXB_UNMARSHALLER

public static final Unmarshaller JAXB_UNMARSHALLER

Constructor Detail

LensMetadataClient

public LensMetadataClient(LensConnection connection)

Method Detail

getAlldatabases

public List<String> getAlldatabases()

getCurrentDatabase

public String getCurrentDatabase()

setDatabase

public APIResult setDatabase(String database)

createDatabase

public APIResult createDatabase(String database,
                       boolean ignoreIfExists)

createDatabase

public APIResult createDatabase(String database)

dropDatabase

public APIResult dropDatabase(String database,
                     boolean cascade)

dropDatabase

public APIResult dropDatabase(String database)

getAllNativeTables

public List<String> getAllNativeTables()

getNativeTable

public XNativeTable getNativeTable(String tblName)

getAllCubes

public List<String> getAllCubes()

dropAllCubes

public APIResult dropAllCubes()

createCube

public APIResult createCube(XCube cube)

createCube

public APIResult createCube(String cubeSpec)

updateCube

public APIResult updateCube(String cubeName,
                   XCube cube)

updateCube

public APIResult updateCube(String cubeName,
                   String cubeSpec)

getCube

public XCube getCube(String cubeName)

getQueryableFields

public XFlattenedColumns getQueryableFields(String tableName,
                                   boolean flattened)

getJoinChains

public XJoinChains getJoinChains(String tableName)

dropCube

public APIResult dropCube(String cubeName)

getAllDimensions

public List<String> getAllDimensions()

dropAllDimensions

public APIResult dropAllDimensions()

createDimension

public APIResult createDimension(XDimension dimension)

createDimension

public APIResult createDimension(String dimSpec)

updateDimension

public APIResult updateDimension(String dimName,
                        XDimension dimension)

updateDimension

public APIResult updateDimension(String dimName,
                        String dimSpec)

getDimension

public XDimension getDimension(String dimName)

dropDimension

public APIResult dropDimension(String dimName)

getAllStorages

public List<String> getAllStorages()

createNewStorage

public APIResult createNewStorage(XStorage storage)

createNewStorage

public APIResult createNewStorage(String storage)

dropAllStorages

public APIResult dropAllStorages()

updateStorage

public APIResult updateStorage(String storageName,
                      XStorage storage)

updateStorage

public APIResult updateStorage(String storageName,
                      String storage)

getStorage

public XStorage getStorage(String storageName)

dropStorage

public APIResult dropStorage(String storageName)

getAllFactTables

public List<String> getAllFactTables(String cubeName)

getAllFactTables

public List<String> getAllFactTables()

deleteAllFactTables

public APIResult deleteAllFactTables(boolean cascade)

getFactTable

public XFactTable getFactTable(String factTableName)

createFactTable

public APIResult createFactTable(XFactTable f)

createFactTable

public APIResult createFactTable(String factSpec)

updateFactTable

public APIResult updateFactTable(String factName,
                        XFactTable table)

updateFactTable

public APIResult updateFactTable(String factName,
                        String table)

dropFactTable

public APIResult dropFactTable(String factName,
                      boolean cascade)

dropFactTable

public APIResult dropFactTable(String factName)

getAllStoragesOfFactTable

public List<String> getAllStoragesOfFactTable(String factName)

dropAllStoragesOfFactTable

public APIResult dropAllStoragesOfFactTable(String factName)

addStorageToFactTable

public APIResult addStorageToFactTable(String factname,
                              XStorageTableElement storage)

addStorageToFactTable

public APIResult addStorageToFactTable(String factname,
                              String storageSpec)

dropStorageFromFactTable

public APIResult dropStorageFromFactTable(String factName,
                                 String storageName)

getStorageOfFactTable

public XStorageTableElement getStorageOfFactTable(String factName,
                                         String storageName)

getPartitionsOfFactTable

public List<XPartition> getPartitionsOfFactTable(String factName,
                                        String storage,
                                        String filter)

getPartitionsOfFactTable

public List<XPartition> getPartitionsOfFactTable(String factName,
                                        String storage)

dropPartitionsOfFactTable

public APIResult dropPartitionsOfFactTable(String factName,
                                  String storage,
                                  String filter)

dropPartitionsOfFactTable

public APIResult dropPartitionsOfFactTable(String factName,
                                  String storage)

dropPartitionsOfFactTable

public APIResult dropPartitionsOfFactTable(String factName,
                                  String storage,
                                  List<String> partitions)

getAllDimensionTables

public List<String> getAllDimensionTables(String dimensionName)

getAllDimensionTables

public List<String> getAllDimensionTables()

createDimensionTable

public APIResult createDimensionTable(XDimensionTable table)

createDimensionTable

public APIResult createDimensionTable(String tableXml)

updateDimensionTable

public APIResult updateDimensionTable(XDimensionTable table)

updateDimensionTable

public APIResult updateDimensionTable(String dimTblName,
                             String dimSpec)

dropDimensionTable

public APIResult dropDimensionTable(String table,
                           boolean cascade)

dropDimensionTable

public APIResult dropDimensionTable(String table)

getDimensionTable

public XDimensionTable getDimensionTable(String table)

getAllStoragesOfDimTable

public List<String> getAllStoragesOfDimTable(String dimTblName)

addStorageToDimTable

public APIResult addStorageToDimTable(String dimTblName,
                             XStorageTableElement table)

addStorageToDimTable

public APIResult addStorageToDimTable(String dimTblName,
                             String table)

getStorageOfDimensionTable

public XStorageTableElement getStorageOfDimensionTable(String dimTblName,
                                              String storage)

dropAllStoragesOfDimension

public APIResult dropAllStoragesOfDimension(String dimTblName)

dropStoragesOfDimensionTable

public APIResult dropStoragesOfDimensionTable(String dimTblName,
                                     String storage)

getAllPartitionsOfDimensionTable

public List<XPartition> getAllPartitionsOfDimensionTable(String dimTblName,
                                                String storage,
                                                String filter)

getAllPartitionsOfDimensionTable

public List<XPartition> getAllPartitionsOfDimensionTable(String dimTblName,
                                                String storage)

dropAllPartitionsOfDimensionTable

public APIResult dropAllPartitionsOfDimensionTable(String dimTblName,
                                          String storage,
                                          String filter)

dropAllPartitionsOfDimensionTable

public APIResult dropAllPartitionsOfDimensionTable(String dimTblName,
                                          String storage)

dropAllPartitionsOfDimensionTable

public APIResult dropAllPartitionsOfDimensionTable(String dimTblName,
                                          String storage,
                                          List<String> vals)

addPartitionToDimensionTable

public APIResult addPartitionToDimensionTable(String dimTblName,
                                     String storage,
                                     XPartition partition)

addPartitionToDimensionTable

public APIResult addPartitionToDimensionTable(String dimTblName,
                                     String storage,
                                     String partitionSpec)

addPartitionsToDimensionTable

public APIResult addPartitionsToDimensionTable(String dimTblName,
                                      String storage,
                                      XPartitionList partitions)

addPartitionsToDimensionTable

public APIResult addPartitionsToDimensionTable(String dimTblName,
                                      String storage,
                                      String partitionsSpec)

addPartitionToFactTable

public APIResult addPartitionToFactTable(String fact,
                                String storage,
                                XPartition partition)

addPartitionToFactTable

public APIResult addPartitionToFactTable(String fact,
                                String storage,
                                String partitionSpec)

addPartitionsToFactTable

public APIResult addPartitionsToFactTable(String fact,
                                 String storage,
                                 XPartitionList partitions)

addPartitionsToFactTable

public APIResult addPartitionsToFactTable(String fact,
                                 String storage,
                                 String partitionsSpec)

updatePartitionOfDimensionTable

public APIResult updatePartitionOfDimensionTable(String dimTblName,
                                        String storage,
                                        XPartition partition)

updatePartitionOfDimensionTable

public APIResult updatePartitionOfDimensionTable(String dimTblName,
                                        String storage,
                                        String partitionSpec)

updatePartitionsOfDimensionTable

public APIResult updatePartitionsOfDimensionTable(String dimTblName,
                                         String storage,
                                         XPartitionList partitions)

updatePartitionsOfDimensionTable

public APIResult updatePartitionsOfDimensionTable(String dimTblName,
                                         String storage,
                                         String partitionsSpec)

updatePartitionOfFactTable

public APIResult updatePartitionOfFactTable(String fact,
                                   String storage,
                                   XPartition partition)

updatePartitionOfFactTable

public APIResult updatePartitionOfFactTable(String fact,
                                   String storage,
                                   String partitionSpec)

updatePartitionsOfFactTable

public APIResult updatePartitionsOfFactTable(String fact,
                                    String storage,
                                    XPartitionList partitions)

updatePartitionsOfFactTable

public APIResult updatePartitionsOfFactTable(String fact,
                                    String storage,
                                    String partitionsSpec)

getLatestDateOfCube

public Date getLatestDateOfCube(String cubeName,
                       String timePartition)

getPartitionTimelines

public List<String> getPartitionTimelines(String factName,
                                 String storageName,
                                 String updatePeriod,
                                 String timeDimension)