import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.*;
@Table(name="MyTable")
public class MyTable {
@RowKey
private String rowKey;
@Column(family="cf1", qualifier="col1")
private int col1;
@Column(family="cf2", qualifier="col2")
private String col2;
// Getters and Setters
public static Put toPut(MyTable myTable) {
Put put = new Put(Bytes.toBytes(myTable.getRowKey()));
put.addColumn(Bytes.toBytes("cf1"), Bytes.toBytes("col1"), Bytes.toBytes(myTable.getCol1()));
put.addColumn(Bytes.toBytes("cf2"), Bytes.toBytes("col2"), Bytes.toBytes(myTable.getCol2()));
return put;
}
}
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.Mutation;
@ScannerId(id=1234)
public interface MyTableScanner {
@RowFilters(filters={
@RowFilter(columnFamily="cf1", qualifier="col1", compareOp=CompareOp.EQUAL, value="123"),
@RowFilter(columnFamily="cf2", qualifier="col2", compareOp=CompareOp.GREATER, value="abc")
})
Result[] scanTable();
@MutationFilters(filters={
@MutationFilter(columnFamily="cf1", qualifier="col1", compareOp=CompareOp.EQUAL, value="456")
})
void updateTable(MyTable myTable);
}
