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, wait
getDefaultExtension, getFileType, getFilterExtensions, getFilterNames, getXML
getRepositoryElementType
getLogChannelId, getObjectType, isForcingSeparateLogging, isGatheringMetrics, setForcingSeparateLogging, setGatheringMetrics
public 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 LoggingObjectInterface
getObjectId
in interface RepositoryElementInterface
getObjectId
in interface RepositoryObjectInterface
public void setObjectId(ObjectId objectId)
EngineMetaInterface
setObjectId
in interface EngineMetaInterface
setObjectId
in interface RepositoryElementInterface
objectId
- the database ID for this in the repositorypublic String getContainerObjectId()
getContainerObjectId
in interface LoggingObjectInterface
public void setCarteObjectId(String containerObjectId)
containerObjectId
- the execution container Object id to setpublic String getName()
getName
in interface EngineMetaInterface
getName
in interface RepositoryElementInterface
getName
in interface RepositoryObjectInterface
public void setName(String newName)
setName
in interface RepositoryElementInterface
newName
- The new namepublic String getDescription()
getDescription
in interface RepositoryElementInterface
public void setDescription(String description)
setDescription
in interface RepositoryElementInterface
description
- 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 EngineMetaInterface
public String getFilename()
getFilename
in interface EngineMetaInterface
getFilename
in interface LoggingObjectInterface
EngineMetaInterface.getFilename()
public void setFilename(String newFilename)
setFilename
in interface EngineMetaInterface
newFilename
- The new filename of the jobpublic RepositoryDirectoryInterface getRepositoryDirectory()
getRepositoryDirectory
in interface EngineMetaInterface
getRepositoryDirectory
in interface LoggingObjectInterface
getRepositoryDirectory
in interface RepositoryElementInterface
public void setRepositoryDirectory(RepositoryDirectoryInterface directory)
setRepositoryDirectory
in interface RepositoryElementInterface
directory
- The directory to set.public Repository getRepository()
getRepository
in interface HasRepositoryInterface
public void setRepository(Repository repository)
setRepository
in interface HasRepositoryInterface
repository
- the repository to setpublic void setInternalKettleVariables()
setInternalKettleVariables
in interface EngineMetaInterface
public 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 HasDatabasesInterface
name
- The database name to look forpublic int nrDatabases()
HasDatabasesInterface
nrDatabases
in interface HasDatabasesInterface
public DatabaseMeta getDatabase(int i)
HasDatabasesInterface
getDatabase
in interface HasDatabasesInterface
i
- The database number.public void importFromMetaStore() throws org.pentaho.metastore.api.exceptions.MetaStoreException, KettlePluginException
org.pentaho.metastore.api.exceptions.MetaStoreException
KettlePluginException
public 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 HasSlaveServersInterface
public 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)
UndoInterface
addUndo
in interface UndoInterface
from
- 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()
UndoInterface
nextUndo
in interface UndoInterface
public TransAction viewNextUndo()
UndoInterface
viewNextUndo
in interface UndoInterface
public TransAction previousUndo()
UndoInterface
previousUndo
in interface UndoInterface
public TransAction viewThisUndo()
viewThisUndo
in interface UndoInterface
public TransAction viewPreviousUndo()
UndoInterface
viewPreviousUndo
in interface UndoInterface
public int getMaxUndo()
UndoInterface
getMaxUndo
in interface UndoInterface
public void setMaxUndo(int mu)
UndoInterface
setMaxUndo
in interface UndoInterface
mu
- 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 AttributesInterface
public Map<String,Map<String,String>> getAttributesMap()
getAttributesMap
in interface AttributesInterface
public void setAttribute(String groupName, String key, String value)
setAttribute
in interface AttributesInterface
public void setAttributes(String groupName, Map<String,String> attributes)
setAttributes
in interface AttributesInterface
public Map<String,String> getAttributes(String groupName)
getAttributes
in interface AttributesInterface
public String getAttribute(String groupName, String key)
getAttribute
in interface AttributesInterface
public 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)
HasDatabasesInterface
addOrReplaceDatabase
in interface HasDatabasesInterface
databaseMeta
- The database connection information.protected void addDatabase(DatabaseMeta databaseMeta, boolean replace)
public void addDatabase(DatabaseMeta ci)
HasDatabasesInterface
addDatabase
in interface HasDatabasesInterface
ci
- The database connection information.public void addDatabase(int p, DatabaseMeta ci)
HasDatabasesInterface
addDatabase
in interface HasDatabasesInterface
p
- The locationci
- The database connection information.public List<DatabaseMeta> getDatabases()
getDatabases
in interface HasDatabasesInterface
public String[] getDatabaseNames()
public int indexOfDatabase(DatabaseMeta di)
HasDatabasesInterface
indexOfDatabase
in interface HasDatabasesInterface
di
- The database queriedpublic void setDatabases(List<DatabaseMeta> databases)
setDatabases
in interface HasDatabasesInterface
databases
- The databases to set.public boolean haveConnectionsChanged()
HasDatabasesInterface
haveConnectionsChanged
in interface HasDatabasesInterface
public void removeDatabase(int i)
HasDatabasesInterface
removeDatabase
in interface HasDatabasesInterface
i
- The locationpublic void clearChangedDatabases()
public void setChannelLogTable(ChannelLogTable channelLogTable)
channelLogTable
- the channelLogTable to setpublic void copyVariablesFrom(VariableSpace space)
copyVariablesFrom
in interface VariableSpace
public String environmentSubstitute(String aString)
environmentSubstitute
in interface VariableSpace
public String[] environmentSubstitute(String[] aString)
environmentSubstitute
in interface VariableSpace
public String fieldSubstitute(String aString, RowMetaInterface rowMeta, Object[] rowData) throws KettleValueException
fieldSubstitute
in interface VariableSpace
KettleValueException
public VariableSpace getParentVariableSpace()
getParentVariableSpace
in interface VariableSpace
public void setParentVariableSpace(VariableSpace parent)
setParentVariableSpace
in interface VariableSpace
public String getVariable(String variableName, String defaultValue)
getVariable
in interface VariableSpace
public String getVariable(String variableName)
getVariable
in interface VariableSpace
public boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
getBooleanValueOfVariable
in interface VariableSpace
public void initializeVariablesFrom(VariableSpace parent)
initializeVariablesFrom
in interface VariableSpace
public String[] listVariables()
listVariables
in interface VariableSpace
public void setVariable(String variableName, String variableValue)
setVariable
in interface VariableSpace
public void shareVariablesWith(VariableSpace space)
shareVariablesWith
in interface VariableSpace
public void injectVariables(Map<String,String> prop)
injectVariables
in interface VariableSpace
public void addParameterDefinition(String key, String defValue, String description) throws DuplicateParamException
addParameterDefinition
in interface NamedParams
DuplicateParamException
public String getParameterDescription(String key) throws UnknownParamException
getParameterDescription
in interface NamedParams
UnknownParamException
public String getParameterDefault(String key) throws UnknownParamException
getParameterDefault
in interface NamedParams
UnknownParamException
public String getParameterValue(String key) throws UnknownParamException
getParameterValue
in interface NamedParams
UnknownParamException
public String[] listParameters()
listParameters
in interface NamedParams
public void setParameterValue(String key, String value) throws UnknownParamException
setParameterValue
in interface NamedParams
UnknownParamException
public void eraseParameters()
eraseParameters
in interface NamedParams
public void clearParameters()
clearParameters
in interface NamedParams
public void copyParametersFrom(NamedParams params)
copyParametersFrom
in interface NamedParams
public void mergeParametersWith(NamedParams params, boolean replace)
mergeParametersWith
in interface NamedParams
public void activateParameters()
activateParameters
in interface NamedParams
public LogLevel getLogLevel()
getLogLevel
in interface LoggingObjectInterface
public 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 EngineMetaInterface
public void setCreatedDate(Date createdDate)
setCreatedDate
in interface EngineMetaInterface
createdDate
- The creation date to set.public void setCreatedUser(String createdUser)
setCreatedUser
in interface EngineMetaInterface
createdUser
- The user to set.public String getCreatedUser()
getCreatedUser
in interface EngineMetaInterface
public void setModifiedDate(Date modifiedDate)
setModifiedDate
in interface EngineMetaInterface
modifiedDate
- The modified date to set.public Date getModifiedDate()
getModifiedDate
in interface EngineMetaInterface
public void setModifiedUser(String modifiedUser)
setModifiedUser
in interface EngineMetaInterface
modifiedUser
- The user name to set.public String getModifiedUser()
getModifiedUser
in interface EngineMetaInterface
public void clear()
public void clearChanged()
EngineMetaInterface
clearChanged
in interface ChangedFlagInterface
clearChanged
in interface EngineMetaInterface
public void setChanged()
setChanged
in interface ChangedFlagInterface
public final void setChanged(boolean ch)
setChanged
in interface ChangedFlagInterface
public void addObserver(PDIObserver o)
public void deleteObserver(PDIObserver o)
public void notifyObservers(Object arg)
public boolean canSave()
canSave
in interface EngineMetaInterface
EngineMetaInterface.canSave()
public boolean hasChanged()
hasChanged
in interface ChangedFlagInterface
public Date getRegistrationDate()
getRegistrationDate
in interface LoggingObjectInterface
public LoggingObjectInterface getParent()
getParent
in interface LoggingObjectInterface
LoggingObjectInterface.getParent()
public String getObjectName()
getObjectName
in interface LoggingObjectInterface
public String getObjectCopy()
getObjectCopy
in interface LoggingObjectInterface
public ObjectRevision getObjectRevision()
getObjectRevision
in interface LoggingObjectInterface
getObjectRevision
in interface RepositoryElementInterface
public void setObjectRevision(ObjectRevision objectRevision)
setObjectRevision
in interface RepositoryElementInterface
protected 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
EngineMetaInterface
saveSharedObjects
in interface EngineMetaInterface
KettleException
protected 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)
EngineMetaInterface
setVersioningEnabled
in interface EngineMetaInterface
versioningEnabled
- is versioning enabledpublic Boolean getVersioningEnabled()
EngineMetaInterface
getVersioningEnabled
in interface EngineMetaInterface
public boolean isClearingLog()
public void setClearingLog(boolean clearingLog)
public boolean isSafeModeEnabled()
public void setSafeModeEnabled(boolean safeModeEnabled)
Copyright © 2018 Hitachi Vantara. All rights reserved.