PartitionListener
A callback for partitioned regions, invoked when a partition region is
created or any bucket in a partitioned region becomes primary
A sample implementation of this interface to colocate partition regions using
a primary key without having to honour the redundancy contract for every
colocate partition regions is as follows :
public class ColocatingPartitionListener implements PartitionListener,
Declarable {
private Cache cache;
private List<String> viewRegionNames = new ArrayList<String>();
public ColocatingPartitionListener() {
}
public void afterPrimary(int bucketId) {
for (String viewRegionName : viewRegionNames) {
Region viewRegion = cache.getRegion(viewRegionName);
PartitionManager.createPrimaryBucket(viewRegion, bucketId, true, true);
}
}
public void init(Properties props) {
String viewRegions = props.getProperty("viewRegions");
StringTokenizer tokenizer = new StringTokenizer(viewRegions, ",");
while (tokenizer.hasMoreTokens()) {
viewRegionNames.add(tokenizer.nextToken());
}
}
public void afterRegionCreate(Region<? |