public class JobEntryBase extends Object implements Cloneable, VariableSpace, CheckResultSourceInterface, ResourceHolderInterface, LoggingObjectInterface, AttributesInterface, ExtensionDataInterface
execute() method.| Modifier and Type | Field and Description |
|---|---|
protected Map<String,Map<String,String>> |
attributesMap |
protected String |
containerObjectId
The container object id
|
protected Map<String,Object> |
extensionDataMap |
protected LogChannelInterface |
log
The log channel interface object, used for logging
|
protected org.pentaho.metastore.api.IMetaStore |
metaStore |
protected Job |
parentJob
The parent job
|
protected JobMeta |
parentJobMeta |
protected Repository |
rep
The repository
|
protected VariableSpace |
variables
The variable bindings for the job entry
|
| Constructor and Description |
|---|
JobEntryBase()
Instantiates a new job entry base object.
|
JobEntryBase(String name,
String description)
Instantiates a new job entry base object with the given name and description.
|
| Modifier and Type | Method and Description |
|---|---|
void |
check(List<CheckResultInterface> remarks,
JobMeta jobMeta)
Deprecated.
|
void |
check(List<CheckResultInterface> remarks,
JobMeta jobMeta,
VariableSpace space,
Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore)
Allows JobEntry objects to check themselves for consistency
|
void |
clear()
Clears all variable values
|
Object |
clone()
This method is called when a job entry is duplicated in Spoon.
|
void |
copyVariablesFrom(VariableSpace space)
Copies variables from a given variable space to this job entry
|
String |
environmentSubstitute(String aString)
Substitutes any variable values into the given string, and returns the resolved string
|
String[] |
environmentSubstitute(String[] aString)
Substitutes any variable values into each of the given strings, and returns an array containing the resolved
string(s)
|
boolean |
equals(Object obj)
Checks if the JobEntry object is equal to the specified object
|
boolean |
evaluates()
This method must return true if the job entry supports the true/false outgoing hops.
|
String |
exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface namingInterface,
Repository repository)
|
String |
exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface namingInterface,
Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore)
Exports the object to a flat-file system, adding content with filename keys to a set of definitions.
|
String |
fieldSubstitute(String aString,
RowMetaInterface rowMeta,
Object[] rowData) |
String |
getAttribute(String groupName,
String key) |
Map<String,String> |
getAttributes(String groupName) |
Map<String,Map<String,String>> |
getAttributesMap() |
boolean |
getBooleanValueOfVariable(String variableName,
boolean defaultValue)
Returns a boolean representation of the specified variable after performing any necessary substitution.
|
String |
getContainerObjectId()
Gets the container object id
|
String |
getDescription()
Gets the description of the job entry
|
String |
getDialogClassName()
Deprecated.
As of release 8.1, use annotated-based dialog instead
PluginDialog |
Map<String,Object> |
getExtensionDataMap() |
String |
getFilename()
Gets the filename of the job entry.
|
String |
getHolderType()
Returns the holder type for the job entry
|
LogChannelInterface |
getLogChannel()
Gets the log channel.
|
String |
getLogChannelId()
Gets the logging channel id
|
LogLevel |
getLogLevel()
Gets the logging level for the job entry
|
org.pentaho.metastore.api.IMetaStore |
getMetaStore() |
String |
getName()
Gets the name of the job entry
|
String |
getObjectCopy()
Gets a string identifying a copy in a series of steps
|
ObjectId |
getObjectId()
Gets the object id
|
String |
getObjectName()
Gets the object name
|
ObjectRevision |
getObjectRevision()
Gets the revision of the object with respect to a repository
|
LoggingObjectType |
getObjectType()
Gets the logging object type
|
LoggingObjectInterface |
getParent()
Gets the logging object interface's parent
|
Job |
getParentJob()
Gets the parent job.
|
JobMeta |
getParentJobMeta() |
VariableSpace |
getParentVariableSpace()
Gets the parent variable space
|
String |
getPluginId()
Gets the plugin id.
|
String |
getRealFilename()
Gets the real filename of the job entry, by substituting any environment variables present in the filename.
|
String[] |
getReferencedObjectDescriptions() |
Date |
getRegistrationDate()
Returns the registration date for the job entry.
|
Repository |
getRepository()
Gets the repository for the job entry.
|
RepositoryDirectory |
getRepositoryDirectory()
Gets the directory of the job entry in the repository.
|
List<ResourceReference> |
getResourceDependencies(JobMeta jobMeta)
Gets a list of all the resource dependencies that the step is depending on.
|
List<SQLStatement> |
getSQLStatements(Repository repository)
Deprecated.
|
List<SQLStatement> |
getSQLStatements(Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore,
VariableSpace space)
Gets the SQL statements needed by this job entry to execute successfully, given a set of variables.
|
List<SQLStatement> |
getSQLStatements(Repository repository,
VariableSpace space)
Deprecated.
|
String |
getTypeDesc()
Gets the plug-in type description
|
String |
getTypeId()
Deprecated.
use
getPluginId() |
DatabaseMeta[] |
getUsedDatabaseConnections()
Gets all the database connections that are used by the job entry.
|
String |
getVariable(String variableName)
Gets the value of the specified variable, or returns a default value if no such variable exists
|
String |
getVariable(String variableName,
String defaultValue)
Gets the value of the specified variable, or returns a default value if no such variable exists
|
protected VariableSpace |
getVariables()
Gets the variable bindings for the job entry.
|
String |
getXML()
This method is called by PDI whenever a job entry needs to serialize its settings to XML.
|
boolean |
hasChanged()
Checks whether the job entry has changed
|
int |
hashCode() |
boolean |
hasRepositoryReferences()
Checks whether the job entry has repository references.
|
void |
initializeVariablesFrom(VariableSpace parent)
Sets the values of the job entry's variables to the values from the parent variables
|
void |
injectVariables(Map<String,String> prop)
Injects variables using the given Map.
|
boolean |
isBasic()
Checks if the logging level is basic.
|
boolean |
isDebug()
Checks if the logging level is debug.
|
boolean |
isDetailed()
Checks if the logging level is detailed.
|
boolean |
isDummy()
Checks if the job entry is a dummy entry
|
boolean |
isEvaluation()
Checks if the job entry is an evaluation.
|
boolean |
isForcingSeparateLogging() |
boolean |
isFTP()
Checks if this job entry performs an FTP operation
|
boolean |
isGatheringMetrics() |
boolean |
isHTTP()
Checks if this job entry performs an HTTP operation
|
boolean |
isJob()
Checks if the job entry executes a job
|
boolean |
isMail()
Checks if the job entry sends email
|
boolean[] |
isReferencedObjectEnabled() |
boolean |
isRowlevel()
Checks if the logging level is rowlevel.
|
boolean |
isSFTP()
Checks if this job entry performs an SFTP operation
|
boolean |
isShell()
Checks if the job entry executes a shell program
|
boolean |
isSpecial()
Checks if the job entry is of a special type (Start, Dummy, etc.)
|
boolean |
isStart()
Checks if the job entry has started
|
boolean |
isTransformation()
Checks if this job entry executes a transformation
|
boolean |
isUnconditional()
This method must return true if the job entry supports the unconditional outgoing hop.
|
String[] |
listVariables()
Gets a list of variable names for the job entry
|
Object |
loadReferencedObject(int index,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
VariableSpace space)
Load the referenced object
|
Object |
loadReferencedObject(int index,
Repository rep,
VariableSpace space)
Deprecated.
|
void |
loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
Deprecated.
|
void |
loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
This method is called by PDI whenever a job entry needs to read its settings from XML.
|
void |
loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository repository)
Deprecated.
|
void |
loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
void |
logBasic(String message)
Logs the specified string at the basic level.
|
void |
logBasic(String message,
Object... arguments)
Logs the specified string and arguments at the basic level.
|
void |
logDebug(String message)
Logs the specified string at the debug level.
|
void |
logDebug(String message,
Object... arguments)
Logs the specified string and arguments at the debug level.
|
void |
logDetailed(String message)
Logs the specified string at the detailed level.
|
void |
logDetailed(String message,
Object... arguments)
Logs the specified string and arguments at the detailed level.
|
void |
logError(String message)
Logs the specified string at the error level.
|
void |
logError(String message,
Object... arguments)
Logs the specified string and arguments at the error level.
|
void |
logError(String message,
Throwable e)
Logs the specified string and Throwable object at the error level.
|
void |
logMinimal(String message)
Logs the specified string at the minimal level.
|
void |
logMinimal(String message,
Object... arguments)
Logs the specified string and arguments at the minimal level.
|
void |
logRowlevel(String message)
Logs the specified string at the row level.
|
void |
logRowlevel(String message,
Object... arguments)
Logs the specified string and arguments at the row level.
|
void |
lookupRepositoryReferences(Repository repository)
Looks up the references after import
|
void |
parseRepositoryObjects(Repository rep)
Parses the repository objects.
|
boolean |
resetErrorsBeforeExecution()
Checks whether a reset of the number of errors is required before execution.
|
void |
saveRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_job) |
void |
saveRep(Repository rep,
ObjectId id_job)
Deprecated.
|
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 |
setChanged()
Sets that the job entry has changed (i.e.
|
void |
setChanged(boolean ch)
Sets whether the job entry has changed
|
void |
setContainerObjectId(String containerObjectId)
Sets the container object id
|
void |
setDescription(String Description)
Sets the description for the job entry.
|
void |
setForcingSeparateLogging(boolean forcingSeparateLogging) |
void |
setGatheringMetrics(boolean gatheringMetrics) |
void |
setID(long id)
Sets the id for the job entry
|
void |
setLogLevel(LogLevel logLevel)
Sets the logging level for the job entry
|
void |
setMetaStore(org.pentaho.metastore.api.IMetaStore metaStore) |
void |
setName(String name)
Sets the name of the job entry
|
void |
setObjectId(ObjectId id)
Sets the object id.
|
void |
setParentJob(Job parentJob)
Sets the parent job.
|
void |
setParentJobMeta(JobMeta parentJobMeta)
At save and run time, the system will attempt to set the jobMeta so that it can be accessed by the jobEntries
if necessary.
|
void |
setParentVariableSpace(VariableSpace parent)
Sets the parent variable space
|
void |
setPluginId(String configId)
Sets the plugin id.
|
void |
setRepository(Repository repository)
Sets the repository for the job entry.
|
void |
setTypeId(String typeId)
Deprecated.
|
void |
setVariable(String variableName,
String variableValue)
Sets the value of the specified variable to the specified value
|
void |
shareVariablesWith(VariableSpace space)
Shares a variable space from another variable space.
|
String |
toString()
Returns a string representation of the object.
|
protected VariableSpace variables
protected Repository rep
protected Job parentJob
protected LogChannelInterface log
protected String containerObjectId
protected org.pentaho.metastore.api.IMetaStore metaStore
protected JobMeta parentJobMeta
public boolean equals(Object obj)
equals in class ObjectObject.equals(java.lang.Object)public void clear()
public void setObjectId(ObjectId id)
id - the new object idpublic void setID(long id)
id - the new idpublic ObjectId getObjectId()
getObjectId in interface CheckResultSourceInterfacegetObjectId in interface LoggingObjectInterfacegetObjectId in interface ResourceHolderInterfaceCheckResultSourceInterface.getObjectId()public String getTypeDesc()
public void setName(String name)
name - the new namepublic String getName()
getName in interface CheckResultSourceInterfacegetName in interface ResourceHolderInterfaceCheckResultSourceInterface.getName()public void setDescription(String Description)
Description - the new descriptionpublic String getDescription()
getDescription in interface CheckResultSourceInterfacegetDescription in interface ResourceHolderInterfaceCheckResultSourceInterface.getDescription()public void setChanged()
setChanged(boolean)public void setChanged(boolean ch)
ch - true if the job entry has changed, false otherwisepublic boolean hasChanged()
public boolean isStart()
public boolean isDummy()
public boolean isEvaluation()
public boolean isJob()
public boolean isMail()
public boolean isShell()
public boolean isSpecial()
public boolean isTransformation()
public boolean isFTP()
public boolean isSFTP()
public boolean isHTTP()
public String getXML()
public void loadXML(Node entrynode, List<DatabaseMeta> databases, List<SlaveServer> slaveServers) throws KettleXMLException
entrynode - the top-level XML nodedatabases - the list of databasesslaveServers - the list of slave serversKettleXMLException - if any errors occur during the loading of the XML@Deprecated public void loadXML(Node entrynode, List<DatabaseMeta> databases, List<SlaveServer> slaveServers, Repository repository) throws KettleXMLException
loadXML(Node, List, List, Repository, IMetaStore)entrynode - databases - slaveServers - repository - KettleXMLExceptionpublic void loadXML(Node entrynode, List<DatabaseMeta> databases, List<SlaveServer> slaveServers, Repository rep, org.pentaho.metastore.api.IMetaStore metaStore) throws KettleXMLException
KettleXMLExceptionpublic void parseRepositoryObjects(Repository rep) throws KettleException
rep - the repositoryKettleException - if any errors occur during parsing@Deprecated public void loadRep(Repository rep, ObjectId id_jobentry, List<DatabaseMeta> databases, List<SlaveServer> slaveServers) throws KettleException
loadRep(Repository, IMetaStore, ObjectId, List, List)rep - the repository objectid_jobentry - the id of the job entrydatabases - the list of databasesslaveServers - the list of slave serversKettleException - if any errors occur during the loadpublic void loadRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases, List<SlaveServer> slaveServers) throws KettleException
KettleException@Deprecated public void saveRep(Repository rep, ObjectId id_job) throws KettleException
saveRep(Repository, IMetaStore, ObjectId)rep - the repository objectid_job - the id_jobKettleException - if any errors occur during the savepublic void saveRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, ObjectId id_job) throws KettleException
rep - metaStore - id_job - KettleExceptionpublic Object clone()
public String toString()
toString in class ObjectObject.toString()public boolean resetErrorsBeforeExecution()
public boolean evaluates()
public boolean isUnconditional()
@Deprecated public List<SQLStatement> getSQLStatements(Repository repository) throws KettleException
getSQLStatements(Repository, IMetaStore, VariableSpace)repository - the repositoryKettleException - if any errors occur during the generation of SQL statements@Deprecated public List<SQLStatement> getSQLStatements(Repository repository, VariableSpace space) throws KettleException
getSQLStatements(Repository, IMetaStore, VariableSpace)repository - the repository objectspace - a variable space object containing variable bindingsKettleException - if any errors occur during the generation of SQL statementspublic List<SQLStatement> getSQLStatements(Repository repository, org.pentaho.metastore.api.IMetaStore metaStore, VariableSpace space) throws KettleException
repository - the repository objectspace - a variable space object containing variable bindingsKettleException - if any errors occur during the generation of SQL statementspublic String getFilename()
getFilename in interface LoggingObjectInterfaceLoggingObjectInterface.getFilename()public String getRealFilename()
public DatabaseMeta[] getUsedDatabaseConnections()
public void copyVariablesFrom(VariableSpace space)
copyVariablesFrom in interface VariableSpaceVariableSpace.copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace)public String environmentSubstitute(String aString)
environmentSubstitute in interface VariableSpaceVariableSpace.environmentSubstitute(java.lang.String)public String[] environmentSubstitute(String[] aString)
environmentSubstitute in interface VariableSpaceVariableSpace.environmentSubstitute(java.lang.String[])public String fieldSubstitute(String aString, RowMetaInterface rowMeta, Object[] rowData) throws KettleValueException
fieldSubstitute in interface VariableSpaceKettleValueExceptionpublic VariableSpace getParentVariableSpace()
getParentVariableSpace in interface VariableSpaceVariableSpace.getParentVariableSpace()public void setParentVariableSpace(VariableSpace parent)
setParentVariableSpace in interface VariableSpaceVariableSpace.setParentVariableSpace(
org.pentaho.di.core.variables.VariableSpace)public String getVariable(String variableName, String defaultValue)
getVariable in interface VariableSpaceVariableSpace.getVariable(java.lang.String, java.lang.String)public String getVariable(String variableName)
getVariable in interface VariableSpaceVariableSpace.getVariable(java.lang.String)public boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
getBooleanValueOfVariable in interface VariableSpacevariableName - the name of the variable to interrogateVariableSpace.getBooleanValueOfVariable(java.lang.String, boolean)public void initializeVariablesFrom(VariableSpace parent)
initializeVariablesFrom in interface VariableSpaceVariableSpace.initializeVariablesFrom(
org.pentaho.di.core.variables.VariableSpace)public String[] listVariables()
listVariables in interface VariableSpaceVariableSpace.listVariables()public void setVariable(String variableName, String variableValue)
setVariable in interface VariableSpaceVariableSpace.setVariable(java.lang.String, java.lang.String)public void shareVariablesWith(VariableSpace space)
shareVariablesWith in interface VariableSpaceVariableSpace.shareVariablesWith(org.pentaho.di.core.variables.VariableSpace)public void injectVariables(Map<String,String> prop)
injectVariables in interface VariableSpaceVariableSpace.injectVariables(java.util.Map)@Deprecated public void check(List<CheckResultInterface> remarks, JobMeta jobMeta)
check(List, JobMeta, VariableSpace, Repository, IMetaStore)remarks - CheckResults from checking the job entryjobMeta - JobMeta information letting threading back to the JobMeta possiblepublic void check(List<CheckResultInterface> remarks, JobMeta jobMeta, VariableSpace space, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore)
remarks - List of CheckResult objects indicating consistency statusjobMeta - the metadata object for the job entryspace - the variable space to resolve string expressions with variables withrepository - the repository to load Kettle objects frommetaStore - the MetaStore to load common elements frompublic List<ResourceReference> getResourceDependencies(JobMeta jobMeta)
ResourceReference@Deprecated public String exportResources(VariableSpace space, Map<String,ResourceDefinition> definitions, ResourceNamingInterface namingInterface, Repository repository) throws KettleException
exportResources(VariableSpace, Map, ResourceNamingInterface, Repository, IMetaStore)space - The variable space to resolve (environment) variables with.definitions - The map containing the filenames and contentnamingInterface - The resource naming interface allows the object to be named appropriatelyrepository - The repository to load resources fromKettleException - in case something goes wrong during the exportpublic String exportResources(VariableSpace space, Map<String,ResourceDefinition> definitions, ResourceNamingInterface namingInterface, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) throws KettleException
space - The variable space to resolve (environment) variables with.definitions - The map containing the filenames and contentnamingInterface - The resource naming interface allows the object to be named appropriatelyrepository - The repository to load resources frommetaStore - the metaStore to load external metadata fromKettleException - in case something goes wrong during the exportpublic String getPluginId()
public void setPluginId(String configId)
configId - the new plugin id@Deprecated public String getTypeId()
getPluginId()getTypeId in interface CheckResultSourceInterfacegetTypeId in interface ResourceHolderInterface@Deprecated public void setTypeId(String typeId)
setPluginId(String)@Deprecated public String getDialogClassName()
PluginDialogpublic String getHolderType()
getHolderType in interface ResourceHolderInterfaceResourceHolderInterface.getHolderType()protected VariableSpace getVariables()
public void setRepository(Repository repository)
repository - the repositorypublic Repository getRepository()
public void setParentJob(Job parentJob)
parentJob - the new parent jobpublic Job getParentJob()
public boolean isBasic()
public boolean isDetailed()
public boolean isDebug()
public boolean isRowlevel()
public void logMinimal(String message)
message - the messagepublic void logMinimal(String message, Object... arguments)
message - the messagearguments - the argumentspublic void logBasic(String message)
message - the messagepublic void logBasic(String message, Object... arguments)
message - the messagearguments - the argumentspublic void logDetailed(String message)
message - the messagepublic void logDetailed(String message, Object... arguments)
message - the messagearguments - the argumentspublic void logDebug(String message)
message - the messagepublic void logDebug(String message, Object... arguments)
message - the messagearguments - the argumentspublic void logRowlevel(String message)
message - the messagepublic void logRowlevel(String message, Object... arguments)
message - the messagearguments - the argumentspublic void logError(String message)
message - the messagepublic void logError(String message, Throwable e)
message - the messagee - the epublic void logError(String message, Object... arguments)
message - the messagearguments - the argumentspublic LogChannelInterface getLogChannel()
public String getLogChannelId()
getLogChannelId in interface LoggingObjectInterfaceLoggingObjectInterface.getLogChannelId()public String getObjectName()
getObjectName in interface LoggingObjectInterfaceLoggingObjectInterface.getObjectName()public String getObjectCopy()
getObjectCopy in interface LoggingObjectInterfaceLoggingObjectInterface.getObjectCopy()public ObjectRevision getObjectRevision()
getObjectRevision in interface LoggingObjectInterfaceLoggingObjectInterface.getObjectRevision()public LoggingObjectType getObjectType()
getObjectType in interface LoggingObjectInterfaceLoggingObjectInterface.getObjectType()public LoggingObjectInterface getParent()
getParent in interface LoggingObjectInterfaceLoggingObjectInterface.getParent()public RepositoryDirectory getRepositoryDirectory()
getRepositoryDirectory in interface LoggingObjectInterfaceLoggingObjectInterface.getRepositoryDirectory()public LogLevel getLogLevel()
getLogLevel in interface LoggingObjectInterfaceLoggingObjectInterface.getLogLevel()public void setLogLevel(LogLevel logLevel)
logLevel - the new log levelpublic String getContainerObjectId()
getContainerObjectId in interface LoggingObjectInterfacepublic void setContainerObjectId(String containerObjectId)
containerObjectId - the container object id to setpublic Date getRegistrationDate()
getRegistrationDate in interface LoggingObjectInterfacepublic boolean hasRepositoryReferences()
public void lookupRepositoryReferences(Repository repository) throws KettleException
repository - the repository to reference.KettleException - if any errors occur during the lookuppublic String[] getReferencedObjectDescriptions()
public boolean[] isReferencedObjectEnabled()
@Deprecated public Object loadReferencedObject(int index, Repository rep, VariableSpace space) throws KettleException
loadReferencedObject(int, Repository, IMetaStore, VariableSpace)index - the referenced object index to load (in case there are multiple references)rep - the repositoryspace - the variable space to useKettleExceptionpublic Object loadReferencedObject(int index, Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, VariableSpace space) throws KettleException
index - the referenced object index to load (in case there are multiple references)rep - the repositorymetaStore - the metaStore to load fromspace - the variable space to useKettleExceptionpublic boolean isGatheringMetrics()
isGatheringMetrics in interface LoggingObjectInterfacepublic void setGatheringMetrics(boolean gatheringMetrics)
setGatheringMetrics in interface LoggingObjectInterfacepublic boolean isForcingSeparateLogging()
isForcingSeparateLogging in interface LoggingObjectInterfacepublic void setForcingSeparateLogging(boolean forcingSeparateLogging)
setForcingSeparateLogging in interface LoggingObjectInterfacepublic org.pentaho.metastore.api.IMetaStore getMetaStore()
public void setMetaStore(org.pentaho.metastore.api.IMetaStore metaStore)
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 Map<String,Object> getExtensionDataMap()
getExtensionDataMap in interface ExtensionDataInterfacepublic JobMeta getParentJobMeta()
public void setParentJobMeta(JobMeta parentJobMeta)
parentJobMeta - the JobMeta to which this JobEntryInterface belongsCopyright © 2018 Hitachi Vantara. All rights reserved.