Uh oh!
There was an error while loading. Please reload this page.
PHOENIX-5895: Leverage WALCellFilter in the SystemCatalogWALEntryFilter to replicate system catalog table - #951
Conversation
@gjacoby126 can you please review this? |
virajjasani
left a comment
There was a problem hiding this comment.
Nice idea to leverage WALCellFilter
Uh oh!
There was an error while loading. Please reload this page.
| return isTenantRowCell(cell) ? cell : null; | ||
| } | ||
| private boolean isTenantRowCell(Cell cell) { |
There was a problem hiding this comment.
Not related to this changes, but wondering if we need to construct ImmutableBytesWritable object.
Can this method impl be reduced to:
return cell.getRowArray()[cell.getRowOffset()] != QueryConstants.SEPARATOR_BYTE;
There was a problem hiding this comment.
@virajjasani - yes, I believe that will work. ImmutableBytesWritable.get() just returns the underlying byte array
There was a problem hiding this comment.
yes, it should be same, I will change that
publicbyte [] get() {
if (this.bytes == null) {
thrownewIllegalStateException("Uninitialiized. Null constructor " +
"called w/o accompaying readFields invocation");
}
returnthis.bytes;
}| import org.apache.hadoop.hbase.replication.WALCellFilter; | ||
| import org.apache.hadoop.hbase.replication.WALEntryFilter; | ||
| import org.apache.hadoop.hbase.wal.WAL; | ||
| import org.apache.phoenix.query.QueryConstants; |
There was a problem hiding this comment.
nit: we can get rid of List and Lists imports
stoty
commented
Nov 2, 2020
💔 -1 overall
This message was automatically generated. |
gjacoby126
left a comment
There was a problem hiding this comment.
+1, thanks @sandeepvinayak
| return isTenantRowCell(cell) ? cell : null; | ||
| } | ||
| private boolean isTenantRowCell(Cell cell) { |
There was a problem hiding this comment.
@virajjasani - yes, I believe that will work. ImmutableBytesWritable.get() just returns the underlying byte array
Uh oh!
There was an error while loading. Please reload this page.
58d8813 to
2373aa8Comparestoty
commented
Nov 4, 2020
💔 -1 overall
This message was automatically generated. |
stoty
commented
Nov 4, 2020
💔 -1 overall
This message was automatically generated. |
ankitjain64
left a comment
There was a problem hiding this comment.
Thanks @sandeepvinayak .
gjacoby126
commented
Nov 11, 2020
@sandeepvinayak - could you please rename the commit to include the JIRA number? (Might as well squash while you're rebasing too.) Then I'll commit. |
2373aa8 to
5eee635Compare…r to replicate system catalog table
5eee635 to
eb8ff61Comparegjacoby126
commented
Nov 12, 2020
Thanks, @sandeepvinayak |
stoty
commented
Nov 12, 2020
💔 -1 overall
This message was automatically generated. |
No description provided.