[
https://issues.apache.org/jira/browse/HBASE-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13097600#comment-13097600
]
Ted Yu edited comment on HBASE-2195 at 9/6/11 1:22 AM:
-------------------------------------------------------
Below is what I was thinking in terms of reading version:
{noformat}
/**
* Read WritableableUtils.vint prefix and see if it represents version
* which should be less than 0
* if no version is found, treat the prefix as the length for the byte-array
* @param in Input to read from.
* @throws IOException e
*/
public void readVersinAndRegionName(final DataInput in)
throws IOException {
this.version = 0;
int len = 0;
int lenOrVer = WritableUtils.readVInt(in);
if (lenOrVer < 0) { // we found the version
this.version = (byte)(lenOrVer & 0xFF);
len = WritableUtils.readVInt(in);
} else {
len = lenOrVer;
}
this.encodedRegionName = new byte[len];
in.readFully(this.encodedRegionName, 0, len);
}
{noformat}
was (Author: [email protected]):
Below is what I was thinking in terms of reading version:
{noformat}
/**
* Read WritableableUtils.vint prefix and see if it represents version
* which should be less than 0
* if no version is found, treat the prefix as the length for the byte-array
* @param in Input to read from.
* @throws IOException e
*/
public void readVersinAndRegionName(final DataInput in)
throws IOException {
this.version = 0;
int len = 0;
int lenOrVer = WritableUtils.readVInt(in);
if (lenOrVer < 0) { // we found the version
this.version = lenOrVer;
len = WritableUtils.readVInt(in);
} else {
len = lenOrVer;
}
this.encodedRegionName = new byte[len];
in.readFully(this.encodedRegionName, 0, len);
}
{noformat}
> Support cyclic replication
> --------------------------
>
> Key: HBASE-2195
> URL: https://issues.apache.org/jira/browse/HBASE-2195
> Project: HBase
> Issue Type: Sub-task
> Components: replication
> Reporter: Jean-Daniel Cryans
> Attachments: 2195-v5.txt, 2195.txt
>
>
> We need to support cyclic replication by using the cluster id of each HlogKey
> and stop replicating when it goes back to the original cluster.
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
