|
||||||||||
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.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 RepositoryObjectType |
REPOSITORY_ELEMENT_TYPE
|
static String |
XML_TAG
|
Constructor Summary | |
---|---|
PartitionSchema()
|
|
PartitionSchema(Node partitionSchemaNode)
|
|
PartitionSchema(String name,
List<String> partitionIDs)
|
Method Summary | |
---|---|
Object |
clone()
|
boolean |
equals(Object obj)
|
void |
expandPartitionsDynamically(int nrSlaves,
VariableSpace space)
|
Date |
getChangedDate()
|
String |
getDescription()
Gets the description of the repository object. |
String |
getHolderType()
Gets the high-level type of resource holder. |
String |
getName()
Gets the name of the repository object. |
String |
getNumberOfPartitionsPerSlave()
|
ObjectId |
getObjectId()
Get the database ID in the repository for this object. |
ObjectRevision |
getObjectRevision()
Gets the object revision. |
List<String> |
getPartitionIDs()
|
RepositoryDirectoryInterface |
getRepositoryDirectory()
Not supported for Partition schema, return the root. |
RepositoryObjectType |
getRepositoryElementType()
Gets the repository element type. |
String |
getTypeId()
|
String |
getXML()
Describes the Object implementing this interface as XML |
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 |
setChangedDate(Date changedDate)
|
void |
setDescription(String description)
Sets the description of the repository object. |
void |
setDynamicallyDefined(boolean dynamicallyDefined)
|
void |
setName(String name)
Sets the name of the repository object. |
void |
setNumberOfPartitionsPerSlave(String numberOfPartitionsPerSlave)
|
void |
setObjectId(ObjectId id)
Set the database ID for this object in the repository. |
void |
setObjectRevision(ObjectRevision objectRevision)
Sets the object revision. |
void |
setPartitionIDs(List<String> partitionIDs)
|
void |
setRepositoryDirectory(RepositoryDirectoryInterface repositoryDirectory)
|
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
public static final RepositoryObjectType REPOSITORY_ELEMENT_TYPE
Constructor Detail |
---|
public PartitionSchema()
public PartitionSchema(String name, List<String> partitionIDs)
name
- partitionIDs
- public PartitionSchema(Node partitionSchemaNode)
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()
RepositoryElementInterface
getName
in interface RepositoryElementInterface
getName
in interface RepositoryObjectInterface
getName
in interface ResourceHolderInterface
getName
in interface SharedObjectInterface
public void setName(String name)
RepositoryElementInterface
setName
in interface RepositoryElementInterface
name
- the name to setpublic List<String> getPartitionIDs()
public void setPartitionIDs(List<String> partitionIDs)
partitionIDs
- the partitionIDs to setpublic String getXML()
XMLInterface
getXML
in interface XMLInterface
getXML
in interface SharedObjectInterface
public boolean isShared()
isShared
in interface SharedObjectInterface
public void setShared(boolean shared)
setShared
in interface SharedObjectInterface
shared
- the shared to setpublic ObjectId getObjectId()
RepositoryElementInterface
getObjectId
in interface RepositoryElementInterface
getObjectId
in interface RepositoryObjectInterface
getObjectId
in interface ResourceHolderInterface
public String getDescription()
RepositoryElementInterface
getDescription
in interface RepositoryElementInterface
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, VariableSpace space)
public void retainPartitionsForSlaveServer(int slaveCount, int slaveNumber)
slaveCount
- slaveNumber
- public RepositoryDirectoryInterface getRepositoryDirectory()
getRepositoryDirectory
in interface RepositoryElementInterface
public void setRepositoryDirectory(RepositoryDirectoryInterface repositoryDirectory)
setRepositoryDirectory
in interface RepositoryElementInterface
public RepositoryObjectType getRepositoryElementType()
RepositoryElementInterface
getRepositoryElementType
in interface RepositoryElementInterface
public void setObjectId(ObjectId id)
RepositoryElementInterface
setObjectId
in interface RepositoryElementInterface
id
- the database ID for this object in the repositorypublic ObjectRevision getObjectRevision()
RepositoryElementInterface
getObjectRevision
in interface RepositoryElementInterface
public void setObjectRevision(ObjectRevision objectRevision)
RepositoryElementInterface
setObjectRevision
in interface RepositoryElementInterface
public void setDescription(String description)
RepositoryElementInterface
setDescription
in interface RepositoryElementInterface
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 |