|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.pentaho.di.www.TransformationMap
public class TransformationMap
This is a map between the transformation name and the (running/waiting/finished) transformation.
Constructor Summary | |
---|---|
TransformationMap()
|
|
TransformationMap(String parentThreadName)
Deprecated. The parent thread name is no longer used. |
Method Summary | |
---|---|
void |
addAppender(String transformationName,
org.apache.log4j.Appender appender)
|
void |
addTransformation(String transformationName,
Trans trans,
TransConfiguration transConfiguration)
|
SocketPortAllocation |
allocateServerSocketPort(int portRangeStart,
String hostname,
String transformationName,
String sourceSlaveName,
String sourceStepName,
String sourceStepCopy,
String targetSlaveName,
String targetStepName,
String targetStepCopy)
This is the meat of the whole problem. |
void |
deallocateServerSocketPort(int port,
String hostname)
|
void |
deallocateServerSocketPorts(String transName)
Deallocate all the ports for the given transformation name, accross all hosts. |
org.apache.log4j.Appender |
getAppender(String transformationName)
|
TransConfiguration |
getConfiguration(String transformationName)
|
Map<String,TransConfiguration> |
getConfigurationMap()
|
Trans |
getTransformation(String transformationName)
|
String[] |
getTransformationNames()
|
void |
removeAppender(String transformationName)
|
void |
removeTransformation(String transformationName)
|
void |
setConfigurationMap(Map<String,TransConfiguration> configurationMap)
|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TransformationMap(String parentThreadName)
parentThreadName
- public TransformationMap()
Method Detail |
---|
public void addTransformation(String transformationName, Trans trans, TransConfiguration transConfiguration)
public Trans getTransformation(String transformationName)
public TransConfiguration getConfiguration(String transformationName)
public void removeTransformation(String transformationName)
public org.apache.log4j.Appender getAppender(String transformationName)
public void addAppender(String transformationName, org.apache.log4j.Appender appender)
public void removeAppender(String transformationName)
public String[] getTransformationNames()
public Map<String,TransConfiguration> getConfigurationMap()
public void setConfigurationMap(Map<String,TransConfiguration> configurationMap)
configurationMap
- the configurationMap to setpublic SocketPortAllocation allocateServerSocketPort(int portRangeStart, String hostname, String transformationName, String sourceSlaveName, String sourceStepName, String sourceStepCopy, String targetSlaveName, String targetStepName, String targetStepCopy)
portRangeStart
- the start of the port range as described in the used cluster schemahostname
- the hostname to allocate this address fortransformationName
- sourceStepName
- sourceStepCopy
-
public void deallocateServerSocketPorts(String transName)
transName
- the transformation name to releasepublic void deallocateServerSocketPort(int port, String hostname)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |