|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.pentaho.di.core.changed.ChangedFlag
org.pentaho.di.partition.PartitionSchema
public class PartitionSchema
A partition schema allow you to partition a step according into a number of partitions that run independendly. It allows us to "map"
Field Summary | |
---|---|
static String |
XML_TAG
|
Constructor Summary | |
---|---|
PartitionSchema()
|
|
PartitionSchema(Node partitionSchemaNode)
|
|
PartitionSchema(Repository rep,
long id_partition_schema)
|
|
PartitionSchema(String name,
List<String> partitionIDs)
|
Method Summary | |
---|---|
Object |
clone()
|
boolean |
equals(Object obj)
|
void |
expandPartitionsDynamically(int nrSlaves,
org.pentaho.di.core.variables.VariableSpace space)
|
String |
getDescription()
|
String |
getHolderType()
Gets the high-level type of resource holder. |
long |
getId()
|
long |
getID()
|
String |
getName()
|
String |
getNumberOfPartitionsPerSlave()
|
List<String> |
getPartitionIDs()
|
String |
getTypeId()
|
String |
getXML()
|
int |
hashCode()
|
boolean |
isDynamicallyDefined()
|
boolean |
isShared()
|
void |
replaceMeta(PartitionSchema partitionSchema)
|
void |
retainPartitionsForSlaveServer(int slaveCount,
int slaveNumber)
Slaves don't need ALL the partitions, they just need a few. So we should only retain those partitions that are of interest to the slave server. Divide the number of partitions (6) through the number of slaves (2) That gives you 0, 1, 2, 3, 4, 5 Slave 0 : 0, 2, 4 Slave 1 : 1, 3, 5 --> slaveNumber == partitionNr % slaveCount |
void |
saveRep(Repository rep)
|
void |
saveRep(Repository rep,
long id_transformation,
boolean isUsedByTransformation)
|
void |
setDynamicallyDefined(boolean dynamicallyDefined)
|
void |
setId(long id)
|
void |
setName(String name)
|
void |
setNumberOfPartitionsPerSlave(String numberOfPartitionsPerSlave)
|
void |
setPartitionIDs(List<String> partitionIDs)
|
void |
setShared(boolean shared)
|
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 XML_TAG
Constructor Detail |
---|
public PartitionSchema()
public PartitionSchema(String name, List<String> partitionIDs)
name
- partitionIDs
- public PartitionSchema(Node partitionSchemaNode)
public PartitionSchema(Repository rep, long id_partition_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
Method Detail |
---|
public Object clone()
clone
in class Object
public void replaceMeta(PartitionSchema partitionSchema)
public String toString()
toString
in class Object
public boolean equals(Object obj)
equals
in class Object
public int hashCode()
hashCode
in class Object
public String getName()
getName
in interface ResourceHolderInterface
getName
in interface org.pentaho.di.shared.SharedObjectInterface
public void setName(String name)
name
- the name to setpublic List<String> getPartitionIDs()
public void setPartitionIDs(List<String> partitionIDs)
partitionIDs
- the partitionIDs to setpublic String getXML()
getXML
in interface org.pentaho.di.shared.SharedObjectInterface
public void saveRep(Repository rep) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void saveRep(Repository rep, long id_transformation, boolean isUsedByTransformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean isShared()
isShared
in interface org.pentaho.di.shared.SharedObjectInterface
public void setShared(boolean shared)
setShared
in interface org.pentaho.di.shared.SharedObjectInterface
shared
- the shared to setpublic long getId()
public long getID()
getID
in interface ResourceHolderInterface
public void setId(long id)
id
- the id to setpublic String getDescription()
getDescription
in interface ResourceHolderInterface
public String getHolderType()
ResourceHolderInterface
getHolderType
in interface ResourceHolderInterface
public String getTypeId()
getTypeId
in interface ResourceHolderInterface
public boolean isDynamicallyDefined()
public void setDynamicallyDefined(boolean dynamicallyDefined)
dynamicallyDefined
- the dynamicallyDefined to setpublic String getNumberOfPartitionsPerSlave()
public void setNumberOfPartitionsPerSlave(String numberOfPartitionsPerSlave)
numberOfPartitionsPerSlave
- the number of partitions per slave to set...public void expandPartitionsDynamically(int nrSlaves, org.pentaho.di.core.variables.VariableSpace space)
public void retainPartitionsForSlaveServer(int slaveCount, int slaveNumber)
slaveCount
- slaveNumber
-
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |