Dear Wiki user, You have subscribed to a wiki page or wiki category on "Lucene-hadoop Wiki" for change notification.
The following page has been changed by udanax: http://wiki.apache.org/lucene-hadoop/Hbase The comment on the change is: Download Link was broken. ------------------------------------------------------------------------------ the architecture to which the comment is directed. Thank you. ---- - '''By [wiki:udanax udanax]''' - I'm not in the implementation group of HBase. - - So far, I haven't fully figured out how your view/understand the ideas of !BigTable or if you are dealing with parallel processing issues when planning strategies/implementing HBase. - - * I am not sure I understand the requirement here. We do plan to have an interface between Hadoop map/reduce and HBase. Do you have other requirements? If so, listing them here would help us prioritize future work. -- JimKellerman - - So, I've recently started a similar project. But, I indeed hope that i`ll bring some ideas to your group discussion and learn more from Hbase. - - Please check my "!BigTable !TestSimulation Code Source", which you can download from here: - [[BR]]http://www.hadoop.co.kr/moin.cgi/Maplib?action=AttachFile&do=get&target=maplib-0.0.1-alpha.tgz - - I expect can recording of multiple <K,V> maps from Once-through process to parsing a tab delimited text file. - - {{{#!java - Table t = new Table(); - t.Create("webtable", new String[]{"anchor","language"}); - - //Write a new anchor, language - RowMutation r1 = new RowMutation(t.OpenOrDie("webtable"), "udanax.org"); - - r1.Set("anchor:hadoop.co.kr","hadoop korean user group"); - r1.Set("anchor:joinc.co.kr","joinc"); - r1.Set("language:kr", "euc-kr"); - r1.Set("anchor:hadoop.co.kr", "hadoop"); - r1.Set("anchor:naver.com", "naver"); - - Operation op = new Operation(); - op.Apply(r1); - - //Reading from table - Scanner stream = new Scanner("webtable"); - stream.FetchColumnFamily("anchor"); - stream.Lookup("udanax.org"); - - while(stream.next()) - { - System.out.print("(RowName):"); - System.out.print(stream.RowName()); - System.out.print(" (ColumnName):"); - System.out.print(stream.ColumnName()); - System.out.print(" (Value):"); - System.out.println(stream.Value()); - } - - stream.close(); - }}} -
