|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.pentaho.di.core.changed.ChangedFlag org.pentaho.di.cluster.SlaveServer
public class SlaveServer
Field Summary | |
---|---|
static RepositoryObjectType |
REPOSITORY_ELEMENT_TYPE
|
static String |
STRING_SLAVESERVER
|
static String |
XML_TAG
|
Constructor Summary | |
---|---|
SlaveServer()
|
|
SlaveServer(Node slaveNode)
|
|
SlaveServer(String name,
String hostname,
String port,
String username,
String password)
|
|
SlaveServer(String name,
String hostname,
String port,
String username,
String password,
String proxyHostname,
String proxyPort,
String nonProxyHosts,
boolean master)
|
Method Summary | |
---|---|
void |
addCredentials(org.apache.commons.httpclient.HttpClient client)
|
void |
addProxy(org.apache.commons.httpclient.HttpClient client)
|
int |
allocateServerSocket(String runId,
int portRangeStart,
String hostname,
String transformationName,
String sourceSlaveName,
String sourceStepName,
String sourceStepCopy,
String targetSlaveName,
String targetStepName,
String targetStepCopy)
|
WebResult |
cleanupTransformation(String transName,
String carteObjectId)
|
Object |
clone()
|
String |
constructUrl(String serviceAndArguments)
|
void |
copyVariablesFrom(VariableSpace space)
Copy the variables from another space, without initializing with the defaults. |
WebResult |
deAllocateServerSockets(String transName,
String clusteredRunId)
|
String |
environmentSubstitute(String aString)
Substitute the string using the current variable space. |
String[] |
environmentSubstitute(String[] aString)
Replaces environment variables in an array of strings. |
boolean |
equals(Object obj)
|
String |
execService(String service)
|
static SlaveServer |
findSlaveServer(List<SlaveServer> slaveServers,
ObjectId id)
|
static SlaveServer |
findSlaveServer(List<SlaveServer> slaveServers,
String name)
|
boolean |
getBooleanValueOfVariable(String variableName,
boolean defaultValue)
This method returns a boolean for the new variable check boxes. |
Date |
getChangedDate()
|
String |
getDescription()
Gets the description of the repository object. |
String |
getHostname()
|
SlaveServerJobStatus |
getJobStatus(String jobName,
String carteObjectId,
int startLogLineNr)
|
LogChannelInterface |
getLogChannel()
|
String |
getName()
Gets the name of the repository object. |
long |
getNextSlaveSequenceValue(String slaveSequenceName,
long incrementValue)
|
String |
getNonProxyHosts()
|
ObjectId |
getObjectId()
Get the database ID in the repository for this object. |
ObjectRevision |
getObjectRevision()
Gets the object revision. |
VariableSpace |
getParentVariableSpace()
Get the parent of the variable space. |
String |
getPassword()
|
String |
getPort()
|
String |
getPortSpecification()
|
String |
getProxyHostname()
|
String |
getProxyPort()
|
RepositoryDirectoryInterface |
getRepositoryDirectory()
Not used in this case, simply return root / |
RepositoryObjectType |
getRepositoryElementType()
Gets the repository element type. |
org.apache.commons.httpclient.methods.PostMethod |
getSendByteArrayMethod(byte[] content,
String service)
|
String |
getServerAndPort()
|
List<SlaveServerDetection> |
getSlaveServerDetections()
|
static String[] |
getSlaveServerNames(List<SlaveServer> slaveServers)
|
SlaveServerStatus |
getStatus()
|
SlaveServerTransStatus |
getTransStatus(String transName,
String carteObjectId,
int startLogLineNr)
|
String |
getUsername()
|
String |
getVariable(String variableName)
Get the value of a variable. |
String |
getVariable(String variableName,
String defaultValue)
Get the value of a variable with a default in case the variable is not found. |
String |
getWebAppName()
|
String |
getXML()
Describes the Object implementing this interface as XML |
int |
hashCode()
|
void |
initializeVariablesFrom(VariableSpace parent)
Initialize variable space using the defaults, copy over the variables from the parent (using copyVariablesFrom()), after this the "injected" variables should be inserted (injectVariables()). |
void |
injectVariables(Map<String,String> prop)
Inject variables. |
boolean |
isMaster()
|
boolean |
isShared()
|
String[] |
listVariables()
List the variables (not the values) that are currently in the variable space. |
WebResult |
pauseResumeTransformation(String transName,
String carteObjectId)
|
WebResult |
removeJob(String jobName,
String carteObjectId)
|
WebResult |
removeTransformation(String transName,
String carteObjectId)
|
void |
replaceMeta(SlaveServer slaveServer)
|
String |
sendExport(String filename,
String type,
String load)
Send an exported archive over to this slave server |
String |
sendXML(String xml,
String service)
|
void |
setChangedDate(Date changedDate)
|
void |
setDescription(String description)
Sets the description of the repository object. |
void |
setHostname(String urlString)
|
void |
setMaster(boolean master)
|
void |
setName(String name)
Sets the name of the repository object. |
void |
setNonProxyHosts(String nonProxyHosts)
|
void |
setObjectId(ObjectId id)
Set the database ID for this object in the repository. |
void |
setObjectRevision(ObjectRevision objectRevision)
Sets the object revision. |
void |
setParentVariableSpace(VariableSpace parent)
Set the parent variable space |
void |
setPassword(String password)
|
void |
setPort(String port)
|
void |
setProxyHostname(String proxyHostname)
|
void |
setProxyPort(String proxyPort)
|
void |
setRepositoryDirectory(RepositoryDirectoryInterface repositoryDirectory)
|
void |
setShared(boolean shared)
|
void |
setUsername(String username)
|
void |
setVariable(String variableName,
String variableValue)
Sets a variable in the Kettle Variables list. |
void |
setWebAppName(String webAppName)
|
void |
shareVariablesWith(VariableSpace space)
Share a variable space from another variable space. |
String |
sniffStep(String transName,
String stepName,
String copyNr,
int lines,
String type)
Sniff rows on a the slave server, return xml containing the row metadata and data. |
WebResult |
startJob(String jobName,
String carteObjectId)
|
WebResult |
startTransformation(String transName,
String carteObjectId)
|
WebResult |
stopJob(String transName,
String carteObjectId)
|
WebResult |
stopTransformation(String transName,
String carteObjectId)
|
String |
toString()
|
Methods inherited from class org.pentaho.di.core.changed.ChangedFlag |
---|
addObserver, clearChanged, deleteObserver, hasChanged, notifyObservers, setChanged, setChanged |
Methods inherited from class java.lang.Object |
---|
getClass, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final String STRING_SLAVESERVER
public static final String XML_TAG
public static final RepositoryObjectType REPOSITORY_ELEMENT_TYPE
Constructor Detail |
---|
public SlaveServer()
public SlaveServer(String name, String hostname, String port, String username, String password)
public SlaveServer(String name, String hostname, String port, String username, String password, String proxyHostname, String proxyPort, String nonProxyHosts, boolean master)
public SlaveServer(Node slaveNode)
Method Detail |
---|
public LogChannelInterface getLogChannel()
public String getXML()
XMLInterface
getXML
in interface XMLInterface
getXML
in interface SharedObjectInterface
public Object clone()
clone
in class Object
public void replaceMeta(SlaveServer slaveServer)
public String toString()
toString
in class Object
public String getServerAndPort()
public boolean equals(Object obj)
equals
in class Object
public int hashCode()
hashCode
in class Object
public String getHostname()
public void setHostname(String urlString)
public String getPassword()
public void setPassword(String password)
password
- the password to setpublic String getUsername()
public void setUsername(String username)
username
- the username to setpublic String getWebAppName()
public void setWebAppName(String webAppName)
username
- the username to setpublic String getNonProxyHosts()
public void setNonProxyHosts(String nonProxyHosts)
nonProxyHosts
- the nonProxyHosts to setpublic String getProxyHostname()
public void setProxyHostname(String proxyHostname)
proxyHostname
- the proxyHostname to setpublic String getProxyPort()
public void setProxyPort(String proxyPort)
proxyPort
- the proxyPort to setpublic String getPortSpecification()
public String constructUrl(String serviceAndArguments) throws UnsupportedEncodingException
UnsupportedEncodingException
public String getPort()
public void setPort(String port)
port
- the port to setpublic org.apache.commons.httpclient.methods.PostMethod getSendByteArrayMethod(byte[] content, String service) throws Exception
Exception
public String sendXML(String xml, String service) throws Exception
Exception
public String sendExport(String filename, String type, String load) throws Exception
filename
- The archive to sendtype
- The type of file to add to the slave server (AddExportServlet.TYPE_*)load
- The filename to load in the archive (the .kjb or .ktr)
Exception
- in case something goes awrypublic void addProxy(org.apache.commons.httpclient.HttpClient client)
public void addCredentials(org.apache.commons.httpclient.HttpClient client)
public boolean isMaster()
public void setMaster(boolean master)
master
- the master to setpublic String execService(String service) throws Exception
Exception
public SlaveServerStatus getStatus() throws Exception
Exception
public List<SlaveServerDetection> getSlaveServerDetections() throws Exception
Exception
public SlaveServerTransStatus getTransStatus(String transName, String carteObjectId, int startLogLineNr) throws Exception
Exception
public SlaveServerJobStatus getJobStatus(String jobName, String carteObjectId, int startLogLineNr) throws Exception
Exception
public WebResult stopTransformation(String transName, String carteObjectId) throws Exception
Exception
public WebResult pauseResumeTransformation(String transName, String carteObjectId) throws Exception
Exception
public WebResult removeTransformation(String transName, String carteObjectId) throws Exception
Exception
public WebResult removeJob(String jobName, String carteObjectId) throws Exception
Exception
public WebResult stopJob(String transName, String carteObjectId) throws Exception
Exception
public WebResult startTransformation(String transName, String carteObjectId) throws Exception
Exception
public WebResult startJob(String jobName, String carteObjectId) throws Exception
Exception
public WebResult cleanupTransformation(String transName, String carteObjectId) throws Exception
Exception
public WebResult deAllocateServerSockets(String transName, String clusteredRunId) throws Exception
Exception
public static SlaveServer findSlaveServer(List<SlaveServer> slaveServers, String name)
public static SlaveServer findSlaveServer(List<SlaveServer> slaveServers, ObjectId id)
public static String[] getSlaveServerNames(List<SlaveServer> slaveServers)
public int allocateServerSocket(String runId, int portRangeStart, String hostname, String transformationName, String sourceSlaveName, String sourceStepName, String sourceStepCopy, String targetSlaveName, String targetStepName, String targetStepCopy) throws Exception
Exception
public String getName()
RepositoryElementInterface
getName
in interface RepositoryElementInterface
getName
in interface RepositoryObjectInterface
getName
in interface SharedObjectInterface
public void setName(String name)
RepositoryElementInterface
setName
in interface RepositoryElementInterface
public boolean isShared()
isShared
in interface SharedObjectInterface
public void setShared(boolean shared)
setShared
in interface SharedObjectInterface
public void copyVariablesFrom(VariableSpace space)
VariableSpace
copyVariablesFrom
in interface VariableSpace
space
- the space to copy the variables from.public String environmentSubstitute(String aString)
VariableSpace
environmentSubstitute
in interface VariableSpace
aString
- The string to substitute.
public String[] environmentSubstitute(String[] aString)
VariableSpace
environmentSubstitute
in interface VariableSpace
aString
- The array of strings that wants its variables to be replaced.
public VariableSpace getParentVariableSpace()
VariableSpace
getParentVariableSpace
in interface VariableSpace
public void setParentVariableSpace(VariableSpace parent)
VariableSpace
setParentVariableSpace
in interface VariableSpace
parent
- The parent variable space to setpublic String getVariable(String variableName, String defaultValue)
VariableSpace
getVariable
in interface VariableSpace
variableName
- The name of the variabledefaultValue
- The default value in case the variable could not be
found
public String getVariable(String variableName)
VariableSpace
getVariable
in interface VariableSpace
variableName
- The name of the variable
public boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
VariableSpace
getBooleanValueOfVariable
in interface VariableSpace
variableName
- The variable to look up.defaultValue
- The default value to return.
static method ValueMeta.convertStringToBoolean()
public void initializeVariablesFrom(VariableSpace parent)
VariableSpace
initializeVariablesFrom
in interface VariableSpace
parent
- the parent to start from, or null if root.public String[] listVariables()
VariableSpace
listVariables
in interface VariableSpace
public void setVariable(String variableName, String variableValue)
VariableSpace
setVariable
in interface VariableSpace
variableName
- The name of the variable to setvariableValue
- The value of the variable to set. If the
variableValue is null, the variable is cleared
from the list.public void shareVariablesWith(VariableSpace space)
VariableSpace
shareVariablesWith
in interface VariableSpace
space
- Variable space to be shared.public void injectVariables(Map<String,String> prop)
VariableSpace
injectVariables
in interface VariableSpace
prop
- Properties object containing key-value pairs.public ObjectId getObjectId()
RepositoryElementInterface
getObjectId
in interface RepositoryElementInterface
getObjectId
in interface RepositoryObjectInterface
public void setObjectId(ObjectId id)
RepositoryElementInterface
setObjectId
in interface RepositoryElementInterface
id
- the database ID for this object in the repositorypublic RepositoryDirectoryInterface getRepositoryDirectory()
getRepositoryDirectory
in interface RepositoryElementInterface
public void setRepositoryDirectory(RepositoryDirectoryInterface repositoryDirectory)
setRepositoryDirectory
in interface RepositoryElementInterface
public RepositoryObjectType getRepositoryElementType()
RepositoryElementInterface
getRepositoryElementType
in interface RepositoryElementInterface
public ObjectRevision getObjectRevision()
RepositoryElementInterface
getObjectRevision
in interface RepositoryElementInterface
public void setObjectRevision(ObjectRevision objectRevision)
RepositoryElementInterface
setObjectRevision
in interface RepositoryElementInterface
public String getDescription()
RepositoryElementInterface
getDescription
in interface RepositoryElementInterface
public void setDescription(String description)
RepositoryElementInterface
setDescription
in interface RepositoryElementInterface
public String sniffStep(String transName, String stepName, String copyNr, int lines, String type) throws Exception
transName
- stepName
- copyNr
- lines
-
Exception
public long getNextSlaveSequenceValue(String slaveSequenceName, long incrementValue) throws KettleException
KettleException
public Date getChangedDate()
getChangedDate
in interface SharedObjectInterface
public void setChangedDate(Date changedDate)
changedDate
- the changedDate to set
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |