@Component public class LocalPartitionManager extends Object implements PartitioningManager
Modifier and Type | Field and Description |
---|---|
static String |
LOCAL_STRATEGY |
Constructor and Description |
---|
LocalPartitionManager() |
Modifier and Type | Method and Description |
---|---|
boolean |
changePartitionStatus(String partitionId,
String targetState) |
void |
configure(Configuration configuration) |
List<PartitionInformationWrapper> |
getKnownPartitions() |
BagPartition |
getLocalPartition(String partitionId) |
void |
initializePartitions() |
List<BagPartition> |
splitPartition(BagPartition partition) |
public static final String LOCAL_STRATEGY
public void configure(Configuration configuration) throws ConfigurationException
configure
in interface PartitioningManager
ConfigurationException
public void initializePartitions() throws JasDBStorageException
initializePartitions
in interface PartitioningManager
JasDBStorageException
public List<BagPartition> splitPartition(BagPartition partition) throws JasDBStorageException
splitPartition
in interface PartitioningManager
JasDBStorageException
public boolean changePartitionStatus(String partitionId, String targetState) throws JasDBStorageException
changePartitionStatus
in interface PartitioningManager
JasDBStorageException
public List<PartitionInformationWrapper> getKnownPartitions() throws JasDBStorageException
getKnownPartitions
in interface PartitioningManager
JasDBStorageException
public BagPartition getLocalPartition(String partitionId) throws JasDBStorageException
getLocalPartition
in interface PartitioningManager
JasDBStorageException
Copyright © 2015. All rights reserved.