Hit send too soon. I don't see you calling flush anywhere. Could be the edits are accumulated in the local client write buffer but haven't been sent to the store. The exact semantics will depend on what version and settings you're running.
Try adding a table.flush() before each call to printTableContent(). On Thu, Nov 20, 2014 at 3:29 PM, Nick Dimiduk <[email protected]> wrote: > Are you flushing the edits so that they're actually written to the server > before you send the gets? > > On Thu, Nov 20, 2014 at 2:43 PM, Sznajder ForMailingList < > [email protected]> wrote: > >> Sure >> >> Here is the sample code I used for testing. >> >> The call Delete and then Put return some weird content : some times the >> table is just... empty! >> >> Benjamin >> >> >> package db.hbase; >> >> import java.io.IOException; >> import java.util.List; >> >> import org.apache.hadoop.conf.Configuration; >> import org.apache.hadoop.hbase.HBaseConfiguration; >> import org.apache.hadoop.hbase.HColumnDescriptor; >> import org.apache.hadoop.hbase.HTableDescriptor; >> import org.apache.hadoop.hbase.KeyValue; >> import org.apache.hadoop.hbase.TableExistsException; >> import org.apache.hadoop.hbase.client.Delete; >> import org.apache.hadoop.hbase.client.Get; >> import org.apache.hadoop.hbase.client.HBaseAdmin; >> import org.apache.hadoop.hbase.client.HTable; >> import org.apache.hadoop.hbase.client.Put; >> import org.apache.hadoop.hbase.client.Result; >> import org.apache.hadoop.hbase.util.Bytes; >> >> public class HBaseStandaloneTest { >> >> private final static String NAME = >> "dummy-test-"+System.currentTimeMillis(); >> private final static byte[] ROW1 = Bytes.toBytes("row1"); >> private final static byte[] COLFAM1 = Bytes.toBytes("colfam1"); >> private final static byte[] QUAL1 = Bytes.toBytes("qual1"); >> private final static byte[] QUAL2 = Bytes.toBytes("qual2"); >> private final static byte[] VAL = Bytes.toBytes("val"); >> >> private static final String HBASE_CONFIGURATION_ZOOKEEPER_QUORUM = >> "hbase.zookeeper.quorum"; >> private static final String HBASE_CONFIGURATION_ZOOKEEPER_CLIENTPORT = >> "hbase.zookeeper.property.clientPort"; >> >> >> private static HTable table; >> private static HBaseAdmin admin; >> >> private static void init() throws IOException { >> Configuration conf = HBaseConfiguration.create(); >> conf.set(HBASE_CONFIGURATION_ZOOKEEPER_QUORUM, IP_ADRESS); >> conf.set(HBASE_CONFIGURATION_ZOOKEEPER_CLIENTPORT, "2181"); >> >> admin = new HBaseAdmin(conf); >> try { >> if (admin.tableExists(NAME)) { >> admin.disableTable(NAME); >> admin.deleteTable(NAME); >> } >> } catch (Exception e ) { >> // >> } >> HTableDescriptor desc = new HTableDescriptor(NAME); >> HColumnDescriptor coldef = new >> HColumnDescriptor(Bytes.toString(COLFAM1)); >> desc.addFamily(coldef); >> try { >> admin.createTable(desc); >> } catch (TableExistsException e) { >> System.err.println("table \'" + NAME + "\' already exists"); >> } >> >> table = new HTable(conf, NAME); >> } >> >> private static void testUpdateRows() throws Exception{ >> >> for (int i = 0 ; i < 10; i++) { >> System.out.println("\n\nIteration " + i); >> printTableContent("Before put"); >> putRow1Version1(); >> printTableContent("After put - before delete"); >> deleteRow1(); >> //printTableContent("After delete - before 2nd put"); >> putRow1Version2(); >> printTableContent("After second put"); >> } >> } >> >> private static void putRow1Version2() throws Exception { >> Put put = new Put(ROW1); >> put.add(COLFAM1, QUAL1, VAL); >> >> table.put(put); >> >> } >> >> private static void deleteRow1() throws Exception { >> Delete del = new Delete(ROW1); >> table.delete(del); >> } >> >> private static void putRow1Version1() throws Exception { >> Put put = new Put(ROW1); >> put.add(COLFAM1, QUAL1, VAL); >> put.add(COLFAM1, QUAL2, VAL); >> >> table.put(put); >> } >> >> private static void printTableContent(String str) throws IOException { >> System.out.print((str+" >> ").substring(0,30)); >> Result res = table.get(new Get(ROW1)); >> List<KeyValue> list = res.list(); >> if (list == null) { >> System.out.println("\t\tEmpty result"); >> } else { >> StringBuilder strBlder = new StringBuilder(); >> for (KeyValue keyVal : list) { >> String fam = Bytes.toString(keyVal.getFamily()); >> String qual = Bytes.toString(keyVal.getQualifier()); >> String data = >> Bytes.toString(res.getValue(keyVal.getFamily(), keyVal.getQualifier())); >> >> strBlder.append("{"+ fam + "," + qual + "," + data +"}"); >> } >> System.out.println("\t\t"+strBlder.toString()); >> } >> } >> >> public static void main(String[] args) throws Exception { >> init(); >> try { >> testUpdateRows(); >> } finally { >> cleanup(); >> } >> } >> >> private static void cleanup() throws IOException { >> table.close(); >> admin.disableTable(NAME); >> admin.deleteTable(NAME); >> } >> } >> >> >> On Thu, Nov 20, 2014 at 1:48 PM, Nick Dimiduk <[email protected]> wrote: >> >> > Attachements are filtered from the list. Please include a link if you'd >> > like to share some attachment. >> > >> > On Thu, Nov 20, 2014 at 11:46 AM, Sznajder ForMailingList < >> > [email protected]> wrote: >> > >> > > Hi Nick >> > > >> > > Many thanks for your rapid answer! >> > > >> > > By "unpredictable results", I mean that I do not get the expected >> value >> > in >> > > the row, after the new Put call (after Delete). >> > > >> > > I tried to call a delete before a put (see the attached file) >> > > >> > > And I get some weird results: after iterations, I start to get some >> > "empty >> > > content". >> > > >> > > Apparently, "Delete" and "Put" on a same key are not well >> supported.... >> > > >> > > Benjamin >> > > >> > > On Thu, Nov 20, 2014 at 11:40 AM, Nick Dimiduk <[email protected]> >> > wrote: >> > > >> > >> What does "unpredictable results" mean? If you know all the existing >> > >> qualifiers, just provide new values of all of them in a single put. >> If >> > you >> > >> don't, you can use a delete family marker to clear visibility of an >> > entire >> > >> family. I think you'll need to do this separately from writing the >> new >> > >> values. >> > >> >> > >> On Thu, Nov 20, 2014 at 9:17 AM, Sznajder ForMailingList < >> > >> [email protected]> wrote: >> > >> >> > >> > Hi, >> > >> > >> > >> > I would like to **replace** the whole content of a Row in HBase by >> > some >> > >> new >> > >> > content. >> > >> > However: >> > >> > * Simple *put* call just replaces the cells in the new put row. >> > >> > * I thought to call Delete and then Put, and I get some very >> > >> unpredictable >> > >> > results... >> > >> > >> > >> > Is there a solution for replacing the whole content of a Row? >> > >> > >> > >> > Many thanks! >> > >> > >> > >> > Benjamin >> > >> > >> > >> >> > > >> > > >> > >> > >
