| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/ |
| H A D | TestVisibilityLabelsWithDeletes.java | 147 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithDeleteColumns()
185 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithDeleteFamily()
223 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithDeleteFamilyVersion()
261 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithDeleteColumnExactVersion()
300 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithDeleteColumnsWithMultipleVersions()
305 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithDeleteColumnsWithMultipleVersions()
310 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithDeleteColumnsWithMultipleVersions()
316 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithDeleteColumnsWithMultipleVersions()
365 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithDeleteColumnsWithMultipleVersionsNoTimestamp()
414 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithDeleteColumnsWithNoMatchVisExpWithMultipleVersionsNoTimestamp()
[all …]
|
| H A D | TestDefaultScanLabelGeneratorStack.java | 137 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testDefaultScanLabelGeneratorStack()
143 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testDefaultScanLabelGeneratorStack()
149 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testDefaultScanLabelGeneratorStack()
173 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testDefaultScanLabelGeneratorStack()
180 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testDefaultScanLabelGeneratorStack()
198 assertTrue(Bytes.equals(current1.getRowArray(), current1.getRowOffset(), in testDefaultScanLabelGeneratorStack()
205 assertTrue(Bytes.equals(current1.getRowArray(), current1.getRowOffset(), in testDefaultScanLabelGeneratorStack()
221 assertTrue(Bytes.equals(current2.getRowArray(), current2.getRowOffset(), in testDefaultScanLabelGeneratorStack()
|
| H A D | TestVisibilityLablesWithGroups.java | 151 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testGroupAuths()
157 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testGroupAuths()
163 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testGroupAuths()
206 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testGroupAuths()
213 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testGroupAuths()
231 assertTrue(Bytes.equals(current1.getRowArray(), current1.getRowOffset(), in testGroupAuths()
238 assertTrue(Bytes.equals(current1.getRowArray(), current1.getRowOffset(), in testGroupAuths()
254 assertTrue(Bytes.equals(current2.getRowArray(), current2.getRowOffset(), in testGroupAuths()
315 assertTrue(Bytes.equals(current1.getRowArray(), current1.getRowOffset(), in testGroupAuths()
|
| H A D | TestVisibilityLabels.java | 141 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testSimpleVisibilityLabels()
146 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testSimpleVisibilityLabels()
167 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testSimpleVisibilityLabelsWithUniCodeCharacters()
172 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testSimpleVisibilityLabelsWithUniCodeCharacters()
177 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testSimpleVisibilityLabelsWithUniCodeCharacters()
197 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testAuthorizationsWithSpecialUnicodeCharacters()
202 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testAuthorizationsWithSpecialUnicodeCharacters()
207 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testAuthorizationsWithSpecialUnicodeCharacters()
227 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithComplexLabels()
232 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityLabelsWithComplexLabels()
[all …]
|
| H A D | TestVisibilityLabelsReplication.java | 237 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityReplication()
242 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityReplication()
247 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityReplication()
252 assertTrue(Bytes.equals(current.getRowArray(), current.getRowOffset(), in testVisibilityReplication()
286 if ((Bytes.equals(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(), row, 0, in doAssert()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-common/src/main/java/org/apache/hadoop/hbase/ |
| H A D | CellComparator.java | 79 return findCommonPrefix(left.getRowArray(), right.getRowArray(), left.getRowLength() in findCommonPrefixInRowPart()
121 a.getRowArray(), a.getRowOffset(), a.getRowLength(), in equalsRow()
122 b.getRowArray(), b.getRowOffset(), b.getRowLength()); in equalsRow()
186 return Bytes.compareTo(left.getRowArray(), left.getRowOffset(), left.getRowLength(), in compareRows()
187 right.getRowArray(), right.getRowOffset(), right.getRowLength()); in compareRows()
284 int rowHash = Bytes.hashCode(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); in calculateHashForKeyValue()
320 return compare(left.getRowArray(), left.getRowOffset() + rowCommonPrefix, left.getRowLength() in compareCommonRowPrefix()
321 - rowCommonPrefix, right.getRowArray(), right.getRowOffset() + rowCommonPrefix, in compareCommonRowPrefix()
429 byte [] midRow = getMinimumMidpointArray(left.getRowArray(), left.getRowOffset(), in getMidpoint()
431 right.getRowArray(), right.getRowOffset(), right.getRowLength()); in getMidpoint()
[all …]
|
| H A D | CellUtil.java | 49 return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); in fillRowRange()
112 System.arraycopy(cell.getRowArray(), cell.getRowOffset(), destination, destinationOffset, in copyRowTo()
151 return cell.getRowArray()[cell.getRowOffset() + index]; in getRowByte()
390 return Bytes.equals(left.getRowArray(), left.getRowOffset(), left.getRowLength(),
391 right.getRowArray(), right.getRowOffset(), right.getRowLength());
395 return Bytes.equals(left.getRowArray(), left.getRowOffset(), left.getRowLength(), buf, 0,
755 out.write(cell.getRowArray(), cell.getRowOffset(), rowLen);
770 cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()));
824 out.write(cell.getRowArray(), cell.getRowOffset() + commonPrefix, rLen - commonPrefix);
855 int rkCommonPrefix = ByteBufferUtils.findCommonPrefix(c1.getRowArray(), c1.getRowOffset(),
[all …]
|
| H A D | KeyValueUtil.java | 229 System.arraycopy(in.getRowArray(), in.getRowOffset(), nextRow, 0, in.getRowLength()); in createFirstKeyInNextRow()
238 byte[] thisRow = new SimpleMutableByteRange(in.getRowArray(), in.getRowOffset(), in createFirstKeyInIncrementedRow()
296 return createLastOnRow(kv.getRowArray(), kv.getRowOffset(), kv.getRowLength(), null, 0, 0, in createLastOnRow()
312 return new KeyValue(kv.getRowArray(), kv.getRowOffset(), kv.getRowLength(), in createLastOnRowCol()
329 return new KeyValue(kv.getRowArray(), kv.getRowOffset(), kv.getRowLength(), in createFirstOnRowColTS()
528 kv.getRowArray(), kv.getRowOffset(), kv.getRowLength(), in createFirstOnRowColTS()
639 out.write(cell.getRowArray(), cell.getRowOffset(), rlen); in oswrite()
|
| H A D | Cell.java | 79 byte[] getRowArray(); in getRowArray() method
|
| H A D | KeyValue.java | 748 this(c.getRowArray(), c.getRowOffset(), (int)c.getRowLength(), in KeyValue()
1357 public byte[] getRowArray() { in getRowArray() method in KeyValue
1882 byte[] left = l.getRowArray(); in compareRowKey()
1885 byte[] right = r.getRowArray(); in compareRowKey()
1966 cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(), in compareKey()
2034 return compareRows(left.getRowArray(),left.getRowOffset(), left.getRowLength(), in compareRows()
2035 right.getRowArray(), right.getRowOffset(), right.getRowLength()); in compareRows()
2293 matchingRows(left.getRowArray(), left.getRowOffset(), lrowlength, in matchingRows()
2294 right.getRowArray(), right.getRowOffset(), rrowlength); in matchingRows()
2489 return new KeyValue(c.getRowArray(), c.getRowOffset(), (int)c.getRowLength(),
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ |
| H A D | StoreFileScanner.java | 239 && getComparator().compareRows(cur.getRowArray(), cur.getRowOffset(), in skipKVsNewerThanReadpoint()
240 cur.getRowLength(), startKV.getRowArray(), startKV.getRowOffset(), in skipKVsNewerThanReadpoint()
337 haveToSeek = reader.passesGeneralBloomFilter(kv.getRowArray(), in requestSeek()
344 haveToSeek = reader.passesDeleteFamilyBloomFilter(kv.getRowArray(), in requestSeek()
449 KeyValue seekKey = KeyValueUtil.createFirstOnRow(key.getRowArray(), key.getRowOffset(), in seekToPreviousRow()
458 .getRowArray(), hfs.getKeyValue().getRowOffset(), hfs.getKeyValue().getRowLength()); in seekToPreviousRow()
509 || getComparator().compareRows(cur.getRowArray(), cur.getRowOffset(), in backwardSeek()
510 cur.getRowLength(), key.getRowArray(), key.getRowOffset(), in backwardSeek()
|
| H A D | ScanQueryMatcher.java | 288 cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); in match()
507 if (rowComparator.compareRows(kv.getRowArray(), kv.getRowOffset(), in moreRowsMayExistAfter()
515 rowComparator.compareRows(kv.getRowArray(),kv.getRowOffset(), in moreRowsMayExistAfter()
572 kv.getRowArray(), kv.getRowOffset(), kv.getRowLength(), in getKeyForNextColumn()
577 kv.getRowArray(), kv.getRowOffset(), kv.getRowLength(), in getKeyForNextColumn()
585 kv.getRowArray(), kv.getRowOffset(), kv.getRowLength(), in getKeyForNextRow()
597 kv.getRowArray(), kv.getRowOffset(), kv.getRowLength(), in compareKeyForNextRow()
612 kv.getRowArray(), kv.getRowOffset(), kv.getRowLength(), in compareKeyForNextColumn()
618 kv.getRowArray(), kv.getRowOffset(), kv.getRowLength(), in compareKeyForNextColumn()
|
| H A D | StripeMultiFileWriter.java | 200 cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); in append()
210 (comparator.compareRows(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(), in isCellAfterCurrentWriter()
222 lastCell.getRowArray(), lastCell.getRowOffset(), lastCell.getRowLength()); in commitWritersInternal()
329 sanityCheckLeft(left, cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); in append()
332 && !comparator.matchingRows(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(), in append()
385 right, lastCell.getRowArray(), lastCell.getRowOffset(), lastCell.getRowLength()); in commitWritersInternal()
|
| H A D | GetClosestRowBeforeTracker.java | 75 l = KeyValue.getDelimiter(kv.getRowArray(), rowoffset, kv.getRowLength(), in GetClosestRowBeforeTracker()
242 return Bytes.compareTo(this.targetkey.getRowArray(), this.rowoffset, in isTargetTable()
244 kv.getRowArray(), kv.getRowOffset(), this.tablenamePlusDelimiterLength) == 0; in isTargetTable()
|
| H A D | ReversedKeyValueHeap.java | 80 if (comparator.getComparator().compareRows(topKey.getRowArray(), in seekToPreviousRow()
81 topKey.getRowOffset(), topKey.getRowLength(), seekKey.getRowArray(), in seekToPreviousRow()
|
| H A D | DefaultMemStore.java | 457 firstOnRow = new KeyValue(p.cell.getRowArray(), p.cell.getRowOffset(), p.cell.getRowLength(), in getRowKeyBefore()
582 cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(), in upsert()
978 Cell firstKeyOnRow = KeyValueUtil.createFirstOnRow(key.getRowArray(), key.getRowOffset(), in seekToPreviousRow()
991 Cell firstKeyOnPreviousRow = KeyValueUtil.createFirstOnRow(lastCellBeforeRow.getRowArray(), in seekToPreviousRow()
1013 Cell firstCellOnLastRow = KeyValueUtil.createFirstOnRow(higherCell.getRowArray(), in seekToLastRow()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/protobuf/ |
| H A D | TestReplicationProtobuf.java | 72 assertTrue(Bytes.equals(scanner.current().getRowArray(), scanner.current().getRowOffset(), in testAdvancetHasSameRow()
74 kv.getRowArray(), kv.getRowOffset(), kv.getRowLength())); in testAdvancetHasSameRow()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/ |
| H A D | TestSeekBeforeWithReverseScan.java | 99 assertEquals(Bytes.toString(res.get(0).getRowArray(), res.get(0).getRowOffset(), res.get(0) in testReverseScanWithoutPadding()
101 assertEquals(Bytes.toString(res.get(1).getRowArray(), res.get(1).getRowOffset(), res.get(1) in testReverseScanWithoutPadding()
103 assertEquals(Bytes.toString(res.get(2).getRowArray(), res.get(2).getRowOffset(), res.get(2) in testReverseScanWithoutPadding()
|
| H A D | TestPrefixTree.java | 121 assertEquals(rows[i], Bytes.toString(cellScanner.current().getRowArray(), cellScanner in testHBASE11728()
140 assertEquals(rows[i], Bytes.toString(cellScanner.current().getRowArray(), cellScanner in testHBASE11728()
156 assertEquals(rows[i], Bytes.toString(cellScanner.current().getRowArray(), cellScanner in testHBASE11728()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/ |
| H A D | TagRewriteCell.java | 55 public byte[] getRowArray() { in getRowArray() method in TagRewriteCell
56 return cell.getRowArray(); in getRowArray()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-prefix-tree/src/main/java/org/apache/hadoop/hbase/codec/prefixtree/ |
| H A D | PrefixTreeSeeker.java | 97 return new ClonedPrefixTreeCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(), in getKeyValue()
314 public byte[] getRowArray() { in getRowArray() method in PrefixTreeSeeker.ClonedPrefixTreeCell
435 String row = Bytes.toStringBinary(getRowArray(), getRowOffset(), getRowLength()); in toString()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/ |
| H A D | TestQueryMatcher.java | 114 qm.setRow(k.getRowArray(), k.getRowOffset(), k.getRowLength()); in _testMatch_ExplicitColumns()
177 qm.setRow(k.getRowArray(), k.getRowOffset(), k.getRowLength()); in testMatch_Wildcard()
231 qm.setRow(k.getRowArray(), k.getRowOffset(), k.getRowLength()); in testMatch_ExpiredExplicit()
284 qm.setRow(k.getRowArray(), k.getRowOffset(), k.getRowLength()); in testMatch_ExpiredWildcard()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-common/src/main/java/org/apache/hadoop/hbase/io/encoding/ |
| H A D | BufferedDataBlockEncoder.java | 181 public byte[] getRowArray() { in getRowArray() method in BufferedDataBlockEncoder.SeekerState
182 return currentKey.getRowArray(); in getRowArray()
379 public byte[] getRowArray() { in getRowArray() method in BufferedDataBlockEncoder.ClonedSeekerState
732 + Bytes.toStringBinary(seekCell.getRowArray())); in seekToKeyInBlock()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ |
| H A D | ReplicationSink.java | 144 new Delete(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()): in replicateEntries()
145 new Put(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); in replicateEntries()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/ |
| H A D | PerformanceEvaluationCommons.java | 49 assertKey(expected, c.getRowArray(), c.getRowOffset(), c.getRowLength()); in assertKey()
|