public abstract class AbstractMeta extends Object implements ChangedFlagInterface, UndoInterface, HasDatabasesInterface, VariableSpace, EngineMetaInterface, NamedParams, HasSlaveServersInterface, AttributesInterface, HasRepositoryInterface, LoggingObjectInterface
| Constructor and Description |
|---|
AbstractMeta() |
| Modifier and Type | Method and Description |
|---|---|
void |
activateParameters() |
void |
addContentChangedListener(ContentChangedListener listener)
Adds the passed ContentChangedListener to the list of listeners.
|
void |
addCurrentDirectoryChangedListener(CurrentDirectoryChangedListener listener)
Remove listener
|
void |
addDatabase(DatabaseMeta ci)
Add a database connection to the transformation.
|
protected void |
addDatabase(DatabaseMeta databaseMeta,
boolean replace) |
void |
addDatabase(int p,
DatabaseMeta ci)
Add a database connection to the transformation on a certain location.
|
void |
addFilenameChangedListener(FilenameChangedListener listener)
Adds the filename changed listener.
|
void |
addNameChangedListener(NameChangedListener listener)
Adds the name changed listener.
|
void |
addNote(int p,
NotePadMeta ni)
Add a new note at a certain location (i.e.
|
void |
addNote(NotePadMeta ni)
Add a new note.
|
void |
addObserver(PDIObserver o) |
void |
addOrReplaceDatabase(DatabaseMeta databaseMeta)
Add a database connection to the transformation if that connection didn't exists yet.
|
void |
addOrReplaceSlaveServer(SlaveServer slaveServer)
Add a new slave server to the transformation if that didn't exist yet.
|
void |
addParameterDefinition(String key,
String defValue,
String description) |
void |
addUndo(Object[] from,
Object[] to,
int[] pos,
Point[] prev,
Point[] curr,
int type_of_change,
boolean nextAlso)
Add an undo operation to the undo list
|
boolean |
canSave()
Checks whether the job can be saved.
|
void |
clear() |
void |
clearChanged()
Clears the changed flag of this.
|
void |
clearChangedDatabases()
Clears the flags for whether the transformation's databases have changed.
|
void |
clearNameChangedListeners()
Removes all the name changed listeners
|
void |
clearParameters() |
void |
clearUndo()
Clear undo.
|
protected int |
compare(AbstractMeta meta1,
AbstractMeta meta2) |
void |
copyParametersFrom(NamedParams params) |
void |
copyVariablesFrom(VariableSpace space) |
void |
deleteObserver(PDIObserver o) |
void |
disposeEmbeddedMetastoreProvider() |
String |
environmentSubstitute(String aString) |
String[] |
environmentSubstitute(String[] aString) |
void |
eraseParameters() |
String |
fieldSubstitute(String aString,
RowMetaInterface rowMeta,
Object[] rowData) |
DatabaseMeta |
findDatabase(String name)
Find a database connection by it's name
|
SlaveServer |
findSlaveServer(String serverString)
Find a slave server using the name
|
protected void |
fireContentChangedListeners()
Fire content changed listeners.
|
protected void |
fireContentChangedListeners(boolean ch) |
protected void |
fireCurrentDirectoryChanged(String previous,
String current)
Notify listeners of a change in current directory.
|
protected void |
fireFilenameChangedListeners(String oldFilename,
String newFilename)
Fire filename changed listeners.
|
protected void |
fireNameChangedListeners(String oldName,
String newName)
Fire name changed listeners.
|
protected List<SharedObjectInterface> |
getAllSharedObjects() |
String |
getAttribute(String groupName,
String key) |
Map<String,String> |
getAttributes(String groupName) |
Map<String,Map<String,String>> |
getAttributesMap() |
boolean |
getBooleanValueOfVariable(String variableName,
boolean defaultValue) |
ChannelLogTable |
getChannelLogTable()
Gets the channel log table for the job.
|
String |
getContainerObjectId()
Gets the container object id.
|
List<ContentChangedListener> |
getContentChangedListeners() |
Date |
getCreatedDate()
Gets the date the transformation was created.
|
String |
getCreatedUser()
Gets the user by whom the transformation was created.
|
DatabaseMeta |
getDatabase(int i)
Retrieves a database connection information a a certain location.
|
String[] |
getDatabaseNames()
Gets the database names.
|
List<DatabaseMeta> |
getDatabases()
Returns a list of the databases.
|
String |
getDescription()
Gets the description of the job.
|
EmbeddedMetaStore |
getEmbeddedMetaStore() |
String |
getEmbeddedMetastoreProviderKey() |
String |
getExtendedDescription()
Gets the extended description of the job.
|
String |
getFilename()
Gets the filename.
|
LogLevel |
getLogLevel() |
int |
getMaxUndo()
Get the maximum number of undo operations possible
|
org.pentaho.metastore.api.IMetaStore |
getMetaStore() |
MetastoreLocatorOsgi |
getMetastoreLocatorOsgi() |
Date |
getModifiedDate()
Gets the date the transformation was modified.
|
String |
getModifiedUser()
Gets the user who last modified the transformation.
|
String |
getName()
Get the name of the transformation.
|
NamedClusterEmbedManager |
getNamedClusterEmbedManager() |
NamedClusterServiceOsgi |
getNamedClusterServiceOsgi() |
NotePadMeta |
getNote(int i)
Gets the note.
|
NotePadMeta |
getNote(int x,
int y)
Find the note that is located on a certain point on the canvas.
|
int[] |
getNoteIndexes(List<NotePadMeta> notes)
Get an array of the locations of an array of notes
|
List<NotePadMeta> |
getNotes()
Gets the notes.
|
String |
getObjectCopy() |
ObjectId |
getObjectId() |
String |
getObjectName() |
ObjectRevision |
getObjectRevision() |
String |
getParameterDefault(String key) |
String |
getParameterDescription(String key) |
String |
getParameterValue(String key) |
LoggingObjectInterface |
getParent()
Gets the interface to the parent log object.
|
VariableSpace |
getParentVariableSpace() |
Set<String> |
getPrivateDatabases()
Returns the set of databases available only for this meta or null if it was not initialized.
|
Date |
getRegistrationDate()
Gets the registration date for the transformation.
|
Repository |
getRepository()
Gets the repository.
|
RepositoryDirectoryInterface |
getRepositoryDirectory()
Gets the directory.
|
List<NotePadMeta> |
getSelectedNotes()
Gets a list of all selected notes.
|
SharedObjects |
getSharedObjects()
Gets the shared objects.
|
String |
getSharedObjectsFile()
Gets the shared objects file.
|
String[] |
getSlaveServerNames()
Gets an array of slave server names.
|
List<SlaveServer> |
getSlaveServers()
Gets a list of slave servers.
|
int |
getUndoSize()
Gets the undo size.
|
String |
getVariable(String variableName) |
String |
getVariable(String variableName,
String defaultValue) |
Boolean |
getVersioningEnabled()
Is versioning enabled.
|
boolean |
hasChanged() |
int |
hashCode() |
boolean |
hasMissingPlugins() |
boolean |
haveConnectionsChanged()
Checks whether or not the connections have changed.
|
boolean |
haveNotesChanged()
Checks whether or not any of the notes have been changed.
|
void |
importFromMetaStore() |
int |
indexOfDatabase(DatabaseMeta di)
Find the location of database
|
int |
indexOfNote(NotePadMeta ni)
Finds the location (index) of the specified note.
|
void |
initializeVariablesFrom(VariableSpace parent) |
void |
injectVariables(Map<String,String> prop) |
boolean |
isAlwaysShowRunOptions() |
boolean |
isClearingLog() |
boolean |
isSafeModeEnabled() |
boolean |
isShowDialog() |
String[] |
listParameters() |
String[] |
listVariables() |
protected boolean |
loadSharedObject(SharedObjectInterface object) |
void |
lowerNote(int p)
Lowers a note to the "bottom" of the list by removing the note at the specified index and re-inserting it at the
front.
|
void |
mergeParametersWith(NamedParams params,
boolean replace) |
void |
nameFromFilename()
Builds a name - if no name is set, yet - from the filename
|
TransAction |
nextUndo()
Get the next undo transaction on the list.
|
void |
notifyObservers(Object arg) |
int |
nrDatabases()
Count the nr of databases in the transformation.
|
int |
nrNotes()
Gets the number of notes.
|
TransAction |
previousUndo()
Get the previous undo operation and change the undo pointer
|
void |
raiseNote(int p)
Raises a note to the "top" of the list by removing the note at the specified index and re-inserting it at the end.
|
SharedObjects |
readSharedObjects()
Read shared objects.
|
void |
removeContentChangedListener(ContentChangedListener listener)
Removes the passed ContentChangedListener from the list of listeners.
|
void |
removeCurrentDirectoryChangedListener(CurrentDirectoryChangedListener listener)
Add a listener to be notified of design-time changes to current directory variable
|
void |
removeDatabase(int i)
Removes a database from the transformation on a certain location.
|
void |
removeFilenameChangedListener(FilenameChangedListener listener)
Removes the filename changed listener.
|
void |
removeNameChangedListener(NameChangedListener listener)
Removes the name changed listener.
|
void |
removeNote(int i)
Removes a note at a certain location (i.e.
|
void |
saveMetaStoreObjects(Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore)
Deprecated.
This method is empty since 2013.
|
void |
saveSharedObjects()
Saves shared objects, including databases, steps, partition schemas, slave servers, and cluster schemas, to a file.
|
void |
setAlwaysShowRunOptions(boolean alwaysShowRunOptions) |
void |
setAttribute(String groupName,
String key,
String value) |
void |
setAttributes(String groupName,
Map<String,String> attributes) |
void |
setAttributesMap(Map<String,Map<String,String>> attributesMap) |
void |
setCarteObjectId(String containerObjectId)
Sets the carte object id.
|
void |
setChanged() |
void |
setChanged(boolean ch) |
void |
setChannelLogTable(ChannelLogTable channelLogTable)
Sets the channel log table for the job.
|
void |
setClearingLog(boolean clearingLog) |
void |
setCreatedDate(Date createdDate)
Sets the date the transformation was created.
|
void |
setCreatedUser(String createdUser)
Sets the user by whom the transformation was created.
|
void |
setDatabases(List<DatabaseMeta> databases)
Sets the databases.
|
void |
setDescription(String description)
Set the description of the job.
|
void |
setEmbeddedMetastoreProviderKey(String embeddedMetastoreProviderKey) |
void |
setExtendedDescription(String extendedDescription)
Set the description of the job.
|
void |
setFilename(String newFilename)
Set the filename of the job
|
protected abstract void |
setInternalFilenameKettleVariables(VariableSpace var)
Sets the internal filename kettle variables.
|
void |
setInternalKettleVariables()
Calls setInternalKettleVariables on the default object.
|
abstract void |
setInternalKettleVariables(VariableSpace var)
This method sets various internal kettle variables.
|
protected abstract void |
setInternalNameKettleVariable(VariableSpace var)
Sets the internal name kettle variable.
|
void |
setLogLevel(LogLevel logLevel)
Sets the log level.
|
void |
setMaxUndo(int mu)
Sets the maximum number of undo operations that are allowed.
|
void |
setMetaStore(org.pentaho.metastore.api.IMetaStore metaStore) |
void |
setMetastoreLocatorOsgi(MetastoreLocatorOsgi metastoreLocatorOsgi) |
void |
setModifiedDate(Date modifiedDate)
Sets the date the transformation was modified.
|
void |
setModifiedUser(String modifiedUser)
Sets the user who last modified the transformation.
|
void |
setName(String newName)
Set the name.
|
void |
setNamedClusterServiceOsgi(NamedClusterServiceOsgi namedClusterServiceOsgi) |
void |
setObjectId(ObjectId objectId)
Set the database ID for this in the repository.
|
void |
setObjectRevision(ObjectRevision objectRevision) |
void |
setParameterValue(String key,
String value) |
void |
setParentVariableSpace(VariableSpace parent) |
void |
setPrivateDatabases(Set<String> privateDatabases)
Sets private databases' names
|
void |
setRepository(Repository repository)
Sets the repository.
|
void |
setRepositoryDirectory(RepositoryDirectoryInterface directory)
Sets the directory.
|
void |
setSafeModeEnabled(boolean safeModeEnabled) |
void |
setSharedObjects(SharedObjects sharedObjects)
Sets the shared objects.
|
void |
setSharedObjectsFile(String sharedObjectsFile)
Sets the shared objects file.
|
void |
setShowDialog(boolean showDialog) |
void |
setSlaveServers(List<SlaveServer> slaveServers)
Sets the slave servers.
|
void |
setVariable(String variableName,
String variableValue) |
void |
setVersioningEnabled(Boolean versioningEnabled)
Set versioning enabled
|
void |
shareVariablesWith(VariableSpace space) |
protected boolean |
shouldOverwrite(OverwritePrompter prompter,
Props props,
String message,
String rememberMessage) |
TransAction |
viewNextUndo()
Get the next undo transaction on the list.
|
TransAction |
viewPreviousUndo()
View previous undo, don't change undo position
|
TransAction |
viewThisUndo()
View current undo, don't change undo position
|
clone, equals, finalize, getClass, notify, notifyAll, toString, wait, wait, waitgetDefaultExtension, getFileType, getFilterExtensions, getFilterNames, getXMLgetRepositoryElementTypegetLogChannelId, getObjectType, isForcingSeparateLogging, isGatheringMetrics, setForcingSeparateLogging, setGatheringMetricspublic static final int TYPE_UNDO_CHANGE
public static final int TYPE_UNDO_NEW
public static final int TYPE_UNDO_DELETE
public static final int TYPE_UNDO_POSITION
protected ObjectId objectId
protected ObjectRevision objectRevision
protected String containerObjectId
protected String name
protected String description
protected String extendedDescription
protected String filename
protected RepositoryDirectoryInterface directory
protected Repository repository
protected List<DatabaseMeta> databases
protected Set<NameChangedListener> nameChangedListeners
protected Set<FilenameChangedListener> filenameChangedListeners
protected Set<ContentChangedListener> contentChangedListeners
protected Set<CurrentDirectoryChangedListener> currentDirectoryChangedListeners
protected List<SlaveServer> slaveServers
protected List<NotePadMeta> notes
protected ChannelLogTable channelLogTable
protected boolean changedNotes
protected boolean changedDatabases
protected List<TransAction> undo
protected EmbeddedMetaStore embeddedMetaStore
protected VariableSpace variables
protected NamedParams namedParams
protected LogLevel logLevel
protected org.pentaho.metastore.api.IMetaStore metaStore
protected String createdUser
protected String modifiedUser
protected Date createdDate
protected Date modifiedDate
protected NamedClusterServiceOsgi namedClusterServiceOsgi
protected MetastoreLocatorOsgi metastoreLocatorOsgi
protected NamedClusterEmbedManager namedClusterEmbedManager
protected String embeddedMetastoreProviderKey
protected String sharedObjectsFile
protected SharedObjects sharedObjects
protected final ChangedFlag changedFlag
protected int max_undo
protected int undo_position
protected org.pentaho.di.base.AbstractMeta.RunOptions runOptions
public boolean isShowDialog()
public void setShowDialog(boolean showDialog)
public boolean isAlwaysShowRunOptions()
public void setAlwaysShowRunOptions(boolean alwaysShowRunOptions)
public ObjectId getObjectId()
getObjectId in interface LoggingObjectInterfacegetObjectId in interface RepositoryElementInterfacegetObjectId in interface RepositoryObjectInterfacepublic void setObjectId(ObjectId objectId)
EngineMetaInterfacesetObjectId in interface EngineMetaInterfacesetObjectId in interface RepositoryElementInterfaceobjectId - the database ID for this in the repositorypublic String getContainerObjectId()
getContainerObjectId in interface LoggingObjectInterfacepublic void setCarteObjectId(String containerObjectId)
containerObjectId - the execution container Object id to setpublic String getName()
getName in interface EngineMetaInterfacegetName in interface RepositoryElementInterfacegetName in interface RepositoryObjectInterfacepublic void setName(String newName)
setName in interface RepositoryElementInterfacenewName - The new namepublic String getDescription()
getDescription in interface RepositoryElementInterfacepublic void setDescription(String description)
setDescription in interface RepositoryElementInterfacedescription - The new description of the jobpublic String getExtendedDescription()
public void setExtendedDescription(String extendedDescription)
extendedDescription - The new extended description of the jobpublic void nameFromFilename()
nameFromFilename in interface EngineMetaInterfacepublic String getFilename()
getFilename in interface EngineMetaInterfacegetFilename in interface LoggingObjectInterfaceEngineMetaInterface.getFilename()public void setFilename(String newFilename)
setFilename in interface EngineMetaInterfacenewFilename - The new filename of the jobpublic RepositoryDirectoryInterface getRepositoryDirectory()
getRepositoryDirectory in interface EngineMetaInterfacegetRepositoryDirectory in interface LoggingObjectInterfacegetRepositoryDirectory in interface RepositoryElementInterfacepublic void setRepositoryDirectory(RepositoryDirectoryInterface directory)
setRepositoryDirectory in interface RepositoryElementInterfacedirectory - The directory to set.public Repository getRepository()
getRepository in interface HasRepositoryInterfacepublic void setRepository(Repository repository)
setRepository in interface HasRepositoryInterfacerepository - the repository to setpublic void setInternalKettleVariables()
setInternalKettleVariables in interface EngineMetaInterfacepublic abstract void setInternalKettleVariables(VariableSpace var)
protected abstract void setInternalFilenameKettleVariables(VariableSpace var)
var - the new internal filename kettle variablespublic DatabaseMeta findDatabase(String name)
findDatabase in interface HasDatabasesInterfacename - The database name to look forpublic int nrDatabases()
HasDatabasesInterfacenrDatabases in interface HasDatabasesInterfacepublic DatabaseMeta getDatabase(int i)
HasDatabasesInterfacegetDatabase in interface HasDatabasesInterfacei - The database number.public void importFromMetaStore()
throws org.pentaho.metastore.api.exceptions.MetaStoreException,
KettlePluginException
org.pentaho.metastore.api.exceptions.MetaStoreExceptionKettlePluginExceptionpublic void addNameChangedListener(NameChangedListener listener)
listener - the listenerpublic void removeNameChangedListener(NameChangedListener listener)
listener - the listenerpublic void clearNameChangedListeners()
protected void fireNameChangedListeners(String oldName, String newName)
oldName - the old namenewName - the new namepublic void addFilenameChangedListener(FilenameChangedListener listener)
listener - the listenerpublic void removeFilenameChangedListener(FilenameChangedListener listener)
listener - the listenerprotected void fireFilenameChangedListeners(String oldFilename, String newFilename)
oldFilename - the old filenamenewFilename - the new filenamepublic void addContentChangedListener(ContentChangedListener listener)
listener - public void removeContentChangedListener(ContentChangedListener listener)
listener - public List<ContentChangedListener> getContentChangedListeners()
protected void fireContentChangedListeners()
protected void fireContentChangedListeners(boolean ch)
public void addCurrentDirectoryChangedListener(CurrentDirectoryChangedListener listener)
public void removeCurrentDirectoryChangedListener(CurrentDirectoryChangedListener listener)
protected void fireCurrentDirectoryChanged(String previous, String current)
public void addOrReplaceSlaveServer(SlaveServer slaveServer)
slaveServer - The slave server to be added.public List<SlaveServer> getSlaveServers()
getSlaveServers in interface HasSlaveServersInterfacepublic void setSlaveServers(List<SlaveServer> slaveServers)
slaveServers - the slaveServers to setpublic SlaveServer findSlaveServer(String serverString)
serverString - the name of the slave serverpublic String[] getSlaveServerNames()
public void addUndo(Object[] from, Object[] to, int[] pos, Point[] prev, Point[] curr, int type_of_change, boolean nextAlso)
UndoInterfaceaddUndo in interface UndoInterfacefrom - array of objects representing the old stateto - array of objectes representing the new statepos - An array of object locationsprev - An array of points representing the old positionscurr - An array of points representing the new positionstype_of_change - The type of change that's being done to the transformation.nextAlso - indicates that the next undo operation needs to follow this one.public void clearUndo()
public TransAction nextUndo()
UndoInterfacenextUndo in interface UndoInterfacepublic TransAction viewNextUndo()
UndoInterfaceviewNextUndo in interface UndoInterfacepublic TransAction previousUndo()
UndoInterfacepreviousUndo in interface UndoInterfacepublic TransAction viewThisUndo()
viewThisUndo in interface UndoInterfacepublic TransAction viewPreviousUndo()
UndoInterfaceviewPreviousUndo in interface UndoInterfacepublic int getMaxUndo()
UndoInterfacegetMaxUndo in interface UndoInterfacepublic void setMaxUndo(int mu)
UndoInterfacesetMaxUndo in interface UndoInterfacemu - The maximum number of undo operations that are allowed.public int getUndoSize()
public EmbeddedMetaStore getEmbeddedMetaStore()
public void setAttributesMap(Map<String,Map<String,String>> attributesMap)
setAttributesMap in interface AttributesInterfacepublic Map<String,Map<String,String>> getAttributesMap()
getAttributesMap in interface AttributesInterfacepublic void setAttribute(String groupName, String key, String value)
setAttribute in interface AttributesInterfacepublic void setAttributes(String groupName, Map<String,String> attributes)
setAttributes in interface AttributesInterfacepublic Map<String,String> getAttributes(String groupName)
getAttributes in interface AttributesInterfacepublic String getAttribute(String groupName, String key)
getAttribute in interface AttributesInterfacepublic void addNote(int p,
NotePadMeta ni)
p - The index into the notes listni - The note to be added.public void addNote(NotePadMeta ni)
ni - The note to be added.public NotePadMeta getNote(int x, int y)
x - the x-coordinate of the point queriedy - the y-coordinate of the point queriedpublic NotePadMeta getNote(int i)
i - the ipublic List<NotePadMeta> getNotes()
public List<NotePadMeta> getSelectedNotes()
public int indexOfNote(NotePadMeta ni)
ni - The note queriedpublic void lowerNote(int p)
p - the index into the notes list.public int nrNotes()
public void raiseNote(int p)
p - the index into the notes list.public void removeNote(int i)
i - The index into the notes listpublic boolean haveNotesChanged()
public int[] getNoteIndexes(List<NotePadMeta> notes)
notes - An array of notespublic ChannelLogTable getChannelLogTable()
public void addOrReplaceDatabase(DatabaseMeta databaseMeta)
HasDatabasesInterfaceaddOrReplaceDatabase in interface HasDatabasesInterfacedatabaseMeta - The database connection information.protected void addDatabase(DatabaseMeta databaseMeta, boolean replace)
public void addDatabase(DatabaseMeta ci)
HasDatabasesInterfaceaddDatabase in interface HasDatabasesInterfaceci - The database connection information.public void addDatabase(int p,
DatabaseMeta ci)
HasDatabasesInterfaceaddDatabase in interface HasDatabasesInterfacep - The locationci - The database connection information.public List<DatabaseMeta> getDatabases()
getDatabases in interface HasDatabasesInterfacepublic String[] getDatabaseNames()
public int indexOfDatabase(DatabaseMeta di)
HasDatabasesInterfaceindexOfDatabase in interface HasDatabasesInterfacedi - The database queriedpublic void setDatabases(List<DatabaseMeta> databases)
setDatabases in interface HasDatabasesInterfacedatabases - The databases to set.public boolean haveConnectionsChanged()
HasDatabasesInterfacehaveConnectionsChanged in interface HasDatabasesInterfacepublic void removeDatabase(int i)
HasDatabasesInterfaceremoveDatabase in interface HasDatabasesInterfacei - The locationpublic void clearChangedDatabases()
public void setChannelLogTable(ChannelLogTable channelLogTable)
channelLogTable - the channelLogTable to setpublic void copyVariablesFrom(VariableSpace space)
copyVariablesFrom in interface VariableSpacepublic String environmentSubstitute(String aString)
environmentSubstitute in interface VariableSpacepublic String[] environmentSubstitute(String[] aString)
environmentSubstitute in interface VariableSpacepublic String fieldSubstitute(String aString, RowMetaInterface rowMeta, Object[] rowData) throws KettleValueException
fieldSubstitute in interface VariableSpaceKettleValueExceptionpublic VariableSpace getParentVariableSpace()
getParentVariableSpace in interface VariableSpacepublic void setParentVariableSpace(VariableSpace parent)
setParentVariableSpace in interface VariableSpacepublic String getVariable(String variableName, String defaultValue)
getVariable in interface VariableSpacepublic String getVariable(String variableName)
getVariable in interface VariableSpacepublic boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
getBooleanValueOfVariable in interface VariableSpacepublic void initializeVariablesFrom(VariableSpace parent)
initializeVariablesFrom in interface VariableSpacepublic String[] listVariables()
listVariables in interface VariableSpacepublic void setVariable(String variableName, String variableValue)
setVariable in interface VariableSpacepublic void shareVariablesWith(VariableSpace space)
shareVariablesWith in interface VariableSpacepublic void injectVariables(Map<String,String> prop)
injectVariables in interface VariableSpacepublic void addParameterDefinition(String key, String defValue, String description) throws DuplicateParamException
addParameterDefinition in interface NamedParamsDuplicateParamExceptionpublic String getParameterDescription(String key) throws UnknownParamException
getParameterDescription in interface NamedParamsUnknownParamExceptionpublic String getParameterDefault(String key) throws UnknownParamException
getParameterDefault in interface NamedParamsUnknownParamExceptionpublic String getParameterValue(String key) throws UnknownParamException
getParameterValue in interface NamedParamsUnknownParamExceptionpublic String[] listParameters()
listParameters in interface NamedParamspublic void setParameterValue(String key, String value) throws UnknownParamException
setParameterValue in interface NamedParamsUnknownParamExceptionpublic void eraseParameters()
eraseParameters in interface NamedParamspublic void clearParameters()
clearParameters in interface NamedParamspublic void copyParametersFrom(NamedParams params)
copyParametersFrom in interface NamedParamspublic void mergeParametersWith(NamedParams params, boolean replace)
mergeParametersWith in interface NamedParamspublic void activateParameters()
activateParameters in interface NamedParamspublic LogLevel getLogLevel()
getLogLevel in interface LoggingObjectInterfacepublic void setLogLevel(LogLevel logLevel)
logLevel - the new log levelpublic org.pentaho.metastore.api.IMetaStore getMetaStore()
public void setMetaStore(org.pentaho.metastore.api.IMetaStore metaStore)
public String getSharedObjectsFile()
public void setSharedObjectsFile(String sharedObjectsFile)
sharedObjectsFile - the sharedObjectsFile to setpublic SharedObjects getSharedObjects()
public void setSharedObjects(SharedObjects sharedObjects)
sharedObjects - the sharedObjects to setpublic SharedObjects readSharedObjects() throws KettleException
KettleException - the kettle exceptionprotected boolean loadSharedObject(SharedObjectInterface object)
protected abstract void setInternalNameKettleVariable(VariableSpace var)
var - the new internal name kettle variablepublic Date getCreatedDate()
getCreatedDate in interface EngineMetaInterfacepublic void setCreatedDate(Date createdDate)
setCreatedDate in interface EngineMetaInterfacecreatedDate - The creation date to set.public void setCreatedUser(String createdUser)
setCreatedUser in interface EngineMetaInterfacecreatedUser - The user to set.public String getCreatedUser()
getCreatedUser in interface EngineMetaInterfacepublic void setModifiedDate(Date modifiedDate)
setModifiedDate in interface EngineMetaInterfacemodifiedDate - The modified date to set.public Date getModifiedDate()
getModifiedDate in interface EngineMetaInterfacepublic void setModifiedUser(String modifiedUser)
setModifiedUser in interface EngineMetaInterfacemodifiedUser - The user name to set.public String getModifiedUser()
getModifiedUser in interface EngineMetaInterfacepublic void clear()
public void clearChanged()
EngineMetaInterfaceclearChanged in interface ChangedFlagInterfaceclearChanged in interface EngineMetaInterfacepublic void setChanged()
setChanged in interface ChangedFlagInterfacepublic final void setChanged(boolean ch)
setChanged in interface ChangedFlagInterfacepublic void addObserver(PDIObserver o)
public void deleteObserver(PDIObserver o)
public void notifyObservers(Object arg)
public boolean canSave()
canSave in interface EngineMetaInterfaceEngineMetaInterface.canSave()public boolean hasChanged()
hasChanged in interface ChangedFlagInterfacepublic Date getRegistrationDate()
getRegistrationDate in interface LoggingObjectInterfacepublic LoggingObjectInterface getParent()
getParent in interface LoggingObjectInterfaceLoggingObjectInterface.getParent()public String getObjectName()
getObjectName in interface LoggingObjectInterfacepublic String getObjectCopy()
getObjectCopy in interface LoggingObjectInterfacepublic ObjectRevision getObjectRevision()
getObjectRevision in interface LoggingObjectInterfacegetObjectRevision in interface RepositoryElementInterfacepublic void setObjectRevision(ObjectRevision objectRevision)
setObjectRevision in interface RepositoryElementInterfaceprotected boolean shouldOverwrite(OverwritePrompter prompter, Props props, String message, String rememberMessage)
public boolean hasMissingPlugins()
public Set<String> getPrivateDatabases()
public void setPrivateDatabases(Set<String> privateDatabases)
privateDatabases - - The list of databases available only for this metapublic void saveSharedObjects()
throws KettleException
EngineMetaInterfacesaveSharedObjects in interface EngineMetaInterfaceKettleExceptionprotected List<SharedObjectInterface> getAllSharedObjects()
@Deprecated public void saveMetaStoreObjects(Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) throws org.pentaho.metastore.api.exceptions.MetaStoreException
metaStore - The store to save toorg.pentaho.metastore.api.exceptions.MetaStoreException - in case there is an error.protected int compare(AbstractMeta meta1, AbstractMeta meta2)
public NamedClusterServiceOsgi getNamedClusterServiceOsgi()
public void setNamedClusterServiceOsgi(NamedClusterServiceOsgi namedClusterServiceOsgi)
public MetastoreLocatorOsgi getMetastoreLocatorOsgi()
public void setMetastoreLocatorOsgi(MetastoreLocatorOsgi metastoreLocatorOsgi)
public NamedClusterEmbedManager getNamedClusterEmbedManager()
public void disposeEmbeddedMetastoreProvider()
public String getEmbeddedMetastoreProviderKey()
public void setEmbeddedMetastoreProviderKey(String embeddedMetastoreProviderKey)
public void setVersioningEnabled(Boolean versioningEnabled)
EngineMetaInterfacesetVersioningEnabled in interface EngineMetaInterfaceversioningEnabled - is versioning enabledpublic Boolean getVersioningEnabled()
EngineMetaInterfacegetVersioningEnabled in interface EngineMetaInterfacepublic boolean isClearingLog()
public void setClearingLog(boolean clearingLog)
public boolean isSafeModeEnabled()
public void setSafeModeEnabled(boolean safeModeEnabled)
Copyright © 2020 Hitachi Vantara. All rights reserved.