Hi everyone,

I'm trying to insert a large amount of rows from a mysql table into Hbase with the java api.
Can i insert the rows with the following code?

rs = stmt.executeQuery("SELECT *,UNIX_TIMESTAMP(time) as time1 FROM log" + date + " LIMIT "+count+",100000");
System.out.print(".");
while(rs.next())
{
  long lockId = table.startUpdate(new Text(rs.getString("id")));
  table.put(lockId, new Text("logtype:"), rs.getBytes("logtype"));
  table.commit(lockId);
}
rs.close();

Or is this completly wrong?

Marcus

Reply via email to