Author: dlanglais Date: 2010-02-17 19:51:10 +0100 (Wed, 17 Feb 2010) New Revision: 94 Modified: trunk/msm-hbase/src/main/java/org/nuiton/mapstoragemanager/plugins/hbase/HBaseNewBigTable.java Log: Modifications mineures... (les PC s'?\195?\169teignent ?\195?\160 19h55 ?\195?\160 la fac...) Modified: trunk/msm-hbase/src/main/java/org/nuiton/mapstoragemanager/plugins/hbase/HBaseNewBigTable.java =================================================================== --- trunk/msm-hbase/src/main/java/org/nuiton/mapstoragemanager/plugins/hbase/HBaseNewBigTable.java 2010-02-17 18:24:43 UTC (rev 93) +++ trunk/msm-hbase/src/main/java/org/nuiton/mapstoragemanager/plugins/hbase/HBaseNewBigTable.java 2010-02-17 18:51:10 UTC (rev 94) @@ -15,6 +15,10 @@ import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.HTable; +/** + * A plugin for MSM using HBase API. + * @author Dorian Langlais + */ public class HBaseNewBigTable implements NewBigTable { /** @@ -24,10 +28,10 @@ private HBaseAdmin hBaseAdmin; private HBaseConfiguration config; - private HTable table; - private String familyName = "mylittlecolumnfamily"; - private String rowName = "myLittleRow"; - private String tableName = "mylittletable"; +// private HTable table; +// private String familyName = "mylittlecolumnfamily"; +// private String rowName = "myLittleRow"; +// private String tableName = "mylittletable"; public HBaseNewBigTable() throws MasterNotRunningException { // You need a configuration object to tell the client where to connect. @@ -41,13 +45,17 @@ LOG.info("test"); } - @Override + /** + * {@inheritDoc} + */ public boolean connect(String host, int port, String base, String username, String passwd) { throw new UnsupportedOperationException("Not supported yet."); } - @Override + /** + * {@inheritDoc} + */ public void createTable(String table) { HTableDescriptor hTableDescriptor = new HTableDescriptor(table); try { @@ -57,7 +65,9 @@ } } - @Override + /** + * {@inheritDoc} + */ public void deleteTable(String table) { try { hBaseAdmin.deleteTable(table); @@ -66,7 +76,9 @@ } } - @Override + /** + * {@inheritDoc} + */ public Set<String> getTablesNames() { Set<String> tablesNames = new HashSet<String>(); try { @@ -83,7 +95,9 @@ return tablesNames; } - @Override + /** + * {@inheritDoc} + */ public void createColumn(String table, String column) { HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(column); try { @@ -93,7 +107,9 @@ } } - @Override + /** + * {@inheritDoc} + */ public void deleteColumn(String table, String column) { try { hBaseAdmin.deleteColumn(table, column); @@ -102,37 +118,51 @@ } } - @Override + /** + * {@inheritDoc} + */ public Set<String> getColumnsNames(String table) { throw new UnsupportedOperationException("Not supported yet."); } - @Override + /** + * {@inheritDoc} + */ public void put(String table, String column, String key, String content) { throw new UnsupportedOperationException("Not supported yet."); } - @Override + /** + * {@inheritDoc} + */ public String get(String table, String column, String key) { throw new UnsupportedOperationException("Not supported yet."); } - @Override + /** + * {@inheritDoc} + */ public String get(String table, String column, String key, int version) { throw new UnsupportedOperationException("Not supported yet."); } - @Override + /** + * {@inheritDoc} + */ public Map<String, String> getRow(String table, String key) { throw new UnsupportedOperationException("Not supported yet."); } - @Override + /** + * {@inheritDoc} + */ public Set<String> getKeys(String table) { throw new UnsupportedOperationException("Not supported yet."); } - @Override + /** + * {@inheritDoc} + */ public void selectTable(String table) { throw new UnsupportedOperationException("Not supported yet."); }