public class KettleDatabaseRepositoryMetaStoreDelegate extends KettleDatabaseRepositoryBaseDelegate
Constructor and Description |
---|
KettleDatabaseRepositoryMetaStoreDelegate(KettleDatabaseRepository repository) |
Modifier and Type | Method and Description |
---|---|
void |
deleteElement(org.pentaho.di.repository.ObjectId elementId) |
void |
deleteElementType(org.pentaho.di.repository.ObjectId elementTypeId) |
void |
deleteNamespace(org.pentaho.di.repository.ObjectId namespaceId) |
String |
encodeAttributeValue(Object object) |
org.pentaho.di.core.RowMetaAndData |
getElement(org.pentaho.di.repository.LongObjectId elementId) |
org.pentaho.di.core.RowMetaAndData |
getElementAttribute(org.pentaho.di.repository.LongObjectId elementAttributeId) |
Collection<org.pentaho.di.core.RowMetaAndData> |
getElementAttributes(org.pentaho.di.repository.ObjectId elementId,
org.pentaho.di.repository.ObjectId parentAttributeId) |
org.pentaho.di.repository.LongObjectId |
getElementId(org.pentaho.di.repository.LongObjectId elementTypeId,
String elementName) |
Collection<org.pentaho.di.core.RowMetaAndData> |
getElements(org.pentaho.di.repository.LongObjectId elementTypeId) |
org.pentaho.di.core.RowMetaAndData |
getElementType(org.pentaho.di.repository.LongObjectId elementTypeId) |
org.pentaho.di.repository.LongObjectId |
getElementTypeId(org.pentaho.di.repository.LongObjectId namespaceId,
String elementTypeName) |
Collection<org.pentaho.di.core.RowMetaAndData> |
getElementTypes(org.pentaho.di.repository.LongObjectId namespaceId) |
org.pentaho.di.repository.LongObjectId |
getNamespaceId(String namespace)
Retrieve the ID for a namespace
|
Collection<org.pentaho.di.core.RowMetaAndData> |
getNamespaces() |
org.pentaho.di.repository.ObjectId |
insertElement(org.pentaho.metastore.api.IMetaStoreElementType elementType,
org.pentaho.metastore.api.IMetaStoreElement element) |
org.pentaho.di.repository.ObjectId |
insertElementType(KDBRMetaStoreElementType type) |
org.pentaho.di.repository.ObjectId |
insertNamespace(String namespace) |
Object |
parseAttributeValue(String value)
supported types:
|
KDBRMetaStoreElement |
parseElement(org.pentaho.metastore.api.IMetaStoreElementType elementType,
org.pentaho.di.core.RowMetaAndData elementRow) |
KDBRMetaStoreElementType |
parseElementType(String namespace,
org.pentaho.di.repository.ObjectId namespaceId,
org.pentaho.di.core.RowMetaAndData elementTypeRow) |
org.pentaho.di.repository.ObjectId |
updateElementType(org.pentaho.di.repository.ObjectId namespaceId,
org.pentaho.di.repository.ObjectId elementTypeId,
org.pentaho.metastore.api.IMetaStoreElementType type) |
org.pentaho.di.repository.ObjectId |
verifyNamespace(String namespace) |
quote, quoteTable
public KettleDatabaseRepositoryMetaStoreDelegate(KettleDatabaseRepository repository)
public org.pentaho.di.repository.LongObjectId getNamespaceId(String namespace) throws org.pentaho.di.core.exception.KettleException
namespace
- The namespace to look uporg.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId verifyNamespace(String namespace) throws org.pentaho.metastore.api.exceptions.MetaStoreException
org.pentaho.metastore.api.exceptions.MetaStoreException
public org.pentaho.di.repository.LongObjectId getElementTypeId(org.pentaho.di.repository.LongObjectId namespaceId, String elementTypeName) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.LongObjectId getElementId(org.pentaho.di.repository.LongObjectId elementTypeId, String elementName) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getElementType(org.pentaho.di.repository.LongObjectId elementTypeId) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getElement(org.pentaho.di.repository.LongObjectId elementId) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getElementAttribute(org.pentaho.di.repository.LongObjectId elementAttributeId) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public Collection<org.pentaho.di.core.RowMetaAndData> getNamespaces() throws org.pentaho.di.core.exception.KettleDatabaseException, org.pentaho.di.core.exception.KettleValueException
org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleValueException
public Collection<org.pentaho.di.core.RowMetaAndData> getElementTypes(org.pentaho.di.repository.LongObjectId namespaceId) throws org.pentaho.di.core.exception.KettleDatabaseException, org.pentaho.di.core.exception.KettleValueException
org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleValueException
public Collection<org.pentaho.di.core.RowMetaAndData> getElements(org.pentaho.di.repository.LongObjectId elementTypeId) throws org.pentaho.di.core.exception.KettleDatabaseException, org.pentaho.di.core.exception.KettleValueException
org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleValueException
public Collection<org.pentaho.di.core.RowMetaAndData> getElementAttributes(org.pentaho.di.repository.ObjectId elementId, org.pentaho.di.repository.ObjectId parentAttributeId) throws org.pentaho.di.core.exception.KettleDatabaseException, org.pentaho.di.core.exception.KettleValueException
org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleValueException
public org.pentaho.di.repository.ObjectId insertNamespace(String namespace) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId insertElementType(KDBRMetaStoreElementType type) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId updateElementType(org.pentaho.di.repository.ObjectId namespaceId, org.pentaho.di.repository.ObjectId elementTypeId, org.pentaho.metastore.api.IMetaStoreElementType type) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public KDBRMetaStoreElementType parseElementType(String namespace, org.pentaho.di.repository.ObjectId namespaceId, org.pentaho.di.core.RowMetaAndData elementTypeRow) throws org.pentaho.di.core.exception.KettleValueException
org.pentaho.di.core.exception.KettleValueException
public void deleteElementType(org.pentaho.di.repository.ObjectId elementTypeId) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void deleteNamespace(org.pentaho.di.repository.ObjectId namespaceId) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public KDBRMetaStoreElement parseElement(org.pentaho.metastore.api.IMetaStoreElementType elementType, org.pentaho.di.core.RowMetaAndData elementRow) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public Object parseAttributeValue(String value) throws Exception
S : String (java.lang.String) D : Date (java.util.Date) N : Number (Double) I : Integer (Long) B : Boolean (Boolean) Examples S:Pentaho Data Integration D:2013/08/23 17:25:00 N:1039348.9347 I:12345678 B:true
value
- Exception
- in case of conversion troublepublic String encodeAttributeValue(Object object) throws Exception
Exception
public org.pentaho.di.repository.ObjectId insertElement(org.pentaho.metastore.api.IMetaStoreElementType elementType, org.pentaho.metastore.api.IMetaStoreElement element) throws org.pentaho.metastore.api.exceptions.MetaStoreException
org.pentaho.metastore.api.exceptions.MetaStoreException
public void deleteElement(org.pentaho.di.repository.ObjectId elementId) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException