@Test @Ignore("Only supported with HBase 0.94.14") public void testClientKeyValue() throws Exception { byte[] TABLE = Bytes.toBytes("testClientKeyValue"); HTable table = TEST_UTIL.createTable(TABLE, new byte[][] { FAMILY }); Put p = new Put(ROW); byte[] v = Bytes.toBytes("v1"); KeyValue kv = new ClientKeyValue(ROW, FAMILY, QUALIFIER, 10, Type.Put, v); p.add(kv); byte[] v2 = Bytes.toBytes("v2"); kv = new ClientKeyValue(ROW, FAMILY, QUALIFIER, 11, Type.Put, v2); p.add(kv); byte[] v3 = Bytes.toBytes("v3"); kv = new ClientKeyValue(ROW, FAMILY, QUALIFIER, 12, Type.Put, v3); p.add(kv); table.put(p); table.flushCommits(); byte[][] values = new byte[][] { v, v2, v3 }; long[] times = new long[] { 10, 11, 12 }; scanAllVersionsAndVerify(table, ROW, FAMILY, QUALIFIER, times, values, 0, 2); Delete d = new Delete(ROW); kv = new ClientKeyValue(ROW, FAMILY, QUALIFIER, 10, Type.Delete); d.addDeleteMarker(kv); table.delete(d); scanAllVersionsAndVerify(table, ROW, FAMILY, QUALIFIER, times, values, 1, 2); d = new Delete(ROW); kv = new ClientKeyValue(ROW, FAMILY, QUALIFIER, 11, Type.DeleteColumn); d.addDeleteMarker(kv); table.delete(d); scanAllVersionsAndVerify(table, ROW, FAMILY, QUALIFIER, times, values, 2, 2); kv = new ClientKeyValue(ROW, FAMILY, QUALIFIER, 12, Type.DeleteFamily); d.addDeleteMarker(kv); table.delete(d); scanVersionAndVerifyMissing(table, ROW, FAMILY, QUALIFIER, 12); table.close(); }
public ClientKeyValue(ImmutableBytesWritable row, ImmutableBytesWritable family, ImmutableBytesWritable qualifier, long ts, Type type, ImmutableBytesWritable value) { this.row = row; this.family = family == null ? NULL : family; this.qualifier = qualifier == null ? NULL : qualifier; this.type = type; this.ts = ts; this.value = value == null ? NULL : value; }
ClientKeyValue extends KeyValue { public ClientKeyValue(ImmutableBytesWritable row, ImmutableBytesWritable family, ImmutableBytesWritable qualifier, long ts, Type type, ImmutableBytesWritable value) { this.row = row; this.family = family == null ? NULL : family; this.qualifier = qualifier == null ? NULL : qualifier; this.type = type; this.ts = ts; this.value = value == null ? NULL : value; } }
ClientKeyValue extends KeyValue { public ClientKeyValue(ImmutableBytesWritable row, ImmutableBytesWritable family, ImmutableBytesWritable qualifier, long ts, Type type, ImmutableBytesWritable value) { this.row = row; this.family = family == null ? NULL : family; this.qualifier = qualifier == null ? NULL : qualifier; this.type = type; this.ts = ts; this.value = value == null ? NULL : value; } ClientKeyValue(ImmutableBytesWritable row, ImmutableBytesWritable family,
      ImmutableBytesWritable qualifier, long ts, Type type, ImmutableBytesWritable value);  ClientKeyValue(byte[] row, byte[] family, byte[] qualifier, long ts, Type t, byte[] value);  ClientKeyValue(byte[] row, byte[] family, byte[] qualifier, long ts, Type t); }
ClientKeyValue extends KeyValue { public ClientKeyValue(ImmutableBytesWritable row, ImmutableBytesWritable family, ImmutableBytesWritable qualifier, long ts, Type type, ImmutableBytesWritable value) { this.row = row; this.family = family == null ? NULL : family; this.qualifier = qualifier == null ? NULL : qualifier; this.type = type; this.ts = ts; this.value = value == null ? NULL : value; } ClientKeyValue(ImmutableBytesWritable row, ImmutableBytesWritable family,
      ImmutableBytesWritable qualifier, long ts, Type type, ImmutableBytesWritable value);  ClientKeyValue(byte[] row, byte[] family, byte[] qualifier, long ts, Type t, byte[] value);  ClientKeyValue(byte[] row, byte[] family, byte[] qualifier, long ts, Type t); @Override KeyValue clone(); @Override KeyValue shallowCopy(); @Override int getValueOffset(); @Override int getValueLength(); @Override int getRowOffset(); @Override short getRowLength(); @Override int getFamilyOffset(); @Override byte getFamilyLength(); @Override byte getFamilyLength(int foffset); @Override int getQualifierOffset(); @Override int getQualifierLength(); @Override int getQualifierLength(int rlength, int flength); @Override int getTotalColumnLength(int rlength, int foffset); @Override int getTotalColumnLength(); @Override byte[] getValue(); @Override byte[] getRow(); @Override long getTimestamp(); @Override byte[] getFamily(); @Override byte[] getQualifier(); @Override byte getType(); @Override boolean matchingFamily(byte[] family); @Override boolean matchingFamily(byte[] family, int offset, int length); @Override boolean matchingFamily(KeyValue other); @Override boolean matchingQualifier(byte[] qualifier); @Override boolean matchingQualifier(byte[] qualifier, int offset, int length); @Override boolean matchingQualifier(KeyValue other); @Override boolean matchingRow(byte[] row); @Override boolean matchingRow(byte[] row, int offset, int length); @Override boolean matchingRow(KeyValue other); @Override boolean matchingColumnNoDelimiter(byte[] column); @Override boolean matchingColumn(byte[] family, byte[] qualifier); @Override boolean nonNullRowAndColumn(); @Override boolean isEmptyColumn(); @Override void write(DataOutput out); @Override int getLength(); @Override String toString(); @Override boolean equals(Object obj); @Override int hashCode(); @Override void readFields(int length, DataInput in); @Override void readFields(DataInput in); @Override int getKeyOffset(); @Override int getFamilyOffset(int rlength); @Override int getQualifierOffset(int foffset); @Override int getTimestampOffset(); @Override int getTimestampOffset(int keylength); @Override int getOffset(); @Override boolean updateLatestStamp(byte[] now); @Override boolean isLatestTimestamp(); @Override int getKeyLength(); @Override byte[] getKey(); @Override String getKeyString(); @Override SplitKeyValue split(); @Override byte[] getBuffer(); }
ClientKeyValue extends KeyValue { public ClientKeyValue(ImmutableBytesWritable row, ImmutableBytesWritable family, ImmutableBytesWritable qualifier, long ts, Type type, ImmutableBytesWritable value) { this.row = row; this.family = family == null ? NULL : family; this.qualifier = qualifier == null ? NULL : qualifier; this.type = type; this.ts = ts; this.value = value == null ? NULL : value; } ClientKeyValue(ImmutableBytesWritable row, ImmutableBytesWritable family,
      ImmutableBytesWritable qualifier, long ts, Type type, ImmutableBytesWritable value);  ClientKeyValue(byte[] row, byte[] family, byte[] qualifier, long ts, Type t, byte[] value);  ClientKeyValue(byte[] row, byte[] family, byte[] qualifier, long ts, Type t); @Override KeyValue clone(); @Override KeyValue shallowCopy(); @Override int getValueOffset(); @Override int getValueLength(); @Override int getRowOffset(); @Override short getRowLength(); @Override int getFamilyOffset(); @Override byte getFamilyLength(); @Override byte getFamilyLength(int foffset); @Override int getQualifierOffset(); @Override int getQualifierLength(); @Override int getQualifierLength(int rlength, int flength); @Override int getTotalColumnLength(int rlength, int foffset); @Override int getTotalColumnLength(); @Override byte[] getValue(); @Override byte[] getRow(); @Override long getTimestamp(); @Override byte[] getFamily(); @Override byte[] getQualifier(); @Override byte getType(); @Override boolean matchingFamily(byte[] family); @Override boolean matchingFamily(byte[] family, int offset, int length); @Override boolean matchingFamily(KeyValue other); @Override boolean matchingQualifier(byte[] qualifier); @Override boolean matchingQualifier(byte[] qualifier, int offset, int length); @Override boolean matchingQualifier(KeyValue other); @Override boolean matchingRow(byte[] row); @Override boolean matchingRow(byte[] row, int offset, int length); @Override boolean matchingRow(KeyValue other); @Override boolean matchingColumnNoDelimiter(byte[] column); @Override boolean matchingColumn(byte[] family, byte[] qualifier); @Override boolean nonNullRowAndColumn(); @Override boolean isEmptyColumn(); @Override void write(DataOutput out); @Override int getLength(); @Override String toString(); @Override boolean equals(Object obj); @Override int hashCode(); @Override void readFields(int length, DataInput in); @Override void readFields(DataInput in); @Override int getKeyOffset(); @Override int getFamilyOffset(int rlength); @Override int getQualifierOffset(int foffset); @Override int getTimestampOffset(); @Override int getTimestampOffset(int keylength); @Override int getOffset(); @Override boolean updateLatestStamp(byte[] now); @Override boolean isLatestTimestamp(); @Override int getKeyLength(); @Override byte[] getKey(); @Override String getKeyString(); @Override SplitKeyValue split(); @Override byte[] getBuffer();  }