Author: dlanglais Date: 2010-02-16 16:15:51 +0100 (Tue, 16 Feb 2010) New Revision: 84 Added: trunk/msm-hbase/src/main/java/org/nuiton/mapstoragemanager/plugins/hbase/HBaseNewBigTable.java Modified: trunk/msm-hbase/pom.xml Log: Normalement, j'ai r?\195?\169ussi ?\195?\160 ajouter hbase et hadoop ?\195?\160 mon pom et maintenant, on arrive ?\195?\160 utiliser des classes de l'API hbase... normalement. Modified: trunk/msm-hbase/pom.xml =================================================================== --- trunk/msm-hbase/pom.xml 2010-02-16 13:01:54 UTC (rev 83) +++ trunk/msm-hbase/pom.xml 2010-02-16 15:15:51 UTC (rev 84) @@ -63,6 +63,16 @@ <version>4.7</version> <scope>test</scope> </dependency> + <dependency> + <groupId>org.apache.mahout.hadoop</groupId> + <artifactId>hadoop-core</artifactId> + <version>0.20.1</version> + </dependency> + <dependency> + <groupId>org.apache.mahout.hbase</groupId> + <artifactId>hbase</artifactId> + <version>0.20.0</version> + </dependency> </dependencies> <!-- ************************************************************* --> @@ -162,7 +172,7 @@ <resource> <directory>src/main/java/org/nuiton/mapstoragemanager/plugins/hbase</directory> <excludes> - <exclude>HBase.java</exclude> + <!--<exclude>HBase.java</exclude>--> </excludes> </resource> </resources> @@ -174,7 +184,7 @@ <artifactId>maven-compiler-plugin</artifactId> <configuration> <excludes> - <exclude>org/nuiton/mapstoragemanager/plugins/hbase/HBase.java</exclude> + <!--<exclude>org/nuiton/mapstoragemanager/plugins/hbase/HBase.java</exclude>--> </excludes> </configuration> </plugin> @@ -279,3 +289,5 @@ </project> + + Added: 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 (rev 0) +++ trunk/msm-hbase/src/main/java/org/nuiton/mapstoragemanager/plugins/hbase/HBaseNewBigTable.java 2010-02-16 15:15:51 UTC (rev 84) @@ -0,0 +1,99 @@ +package org.nuiton.mapstoragemanager.plugins.hbase; + +import java.util.Map; +import java.util.Set; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.nuiton.mapstoragemanager.plugins.NewBigTable; + +import org.apache.hadoop.hbase.HBaseConfiguration; +import org.apache.hadoop.hbase.client.HTable; + +public class HBaseNewBigTable implements NewBigTable { + + /** + * Logger. + */ + private static final Log LOG = LogFactory.getLog(NewBigTable.class); + + private HBaseConfiguration config; + private HTable table; + private String familyName = "mylittlecolumnfamily"; + private String rowName = "myLittleRow"; + private String tableName = "mylittletable"; + + public HBaseNewBigTable() { + // You need a configuration object to tell the client where to connect. + // When you create a HBaseConfiguration, it reads in whatever you've set + // into your hbase-site.xml and in hbase-default.xml, as long as these can + // be found on the CLASSPATH + org.apache.hadoop.conf.Configuration conf = new org.apache.hadoop.conf.Configuration(); + config = new HBaseConfiguration(conf); + LOG.info("test"); + } + + @Override + public boolean connect(String host, int port, String base, String username, String passwd) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public void createTable(String table) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public void deleteTable(String table) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public Set<String> getTablesNames() { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public void createColumn(String table, String column) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public void deleteColumn(String table, String column) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public Set<String> getColumnsNames(String table) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public void put(String table, String column, String key, String content) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public String get(String table, String column, String key) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public String get(String table, String column, String key, int version) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public Map<String, String> getRow(String table, String key) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public Set<String> getKeys(String table) { + throw new UnsupportedOperationException("Not supported yet."); + } + + @Override + public void selectTable(String table) { + throw new UnsupportedOperationException("Not supported yet."); + } +}