parent
c147999d2e
commit
75af94df73
|
|
@ -22,7 +22,6 @@ public class HBaseOperator {
|
|||
private static Connection connection;
|
||||
|
||||
private static void initHBaseClient() throws IOException {
|
||||
System.setProperty("hadoop.home.dir", "D:/hadoop/hadoop-2.4.1");
|
||||
if (configuration == null) {
|
||||
configuration = HBaseConfiguration.create();
|
||||
if (Config.HBaseConfig.ZK_HOSTNAME == null || "".equals(Config.HBaseConfig.ZK_HOSTNAME)) {
|
||||
|
|
@ -60,7 +59,7 @@ public class HBaseOperator {
|
|||
createTable(tableName);
|
||||
Table table = connection.getTable(TableName.valueOf(tableName));
|
||||
Put put = new Put(Bytes.toBytes(rowKey));
|
||||
put.add(Bytes.toBytes(Config.HBaseConfig.FAMILY_COLUMN_NAME), Bytes.toBytes(qualifier), Bytes
|
||||
put.addColumn(Bytes.toBytes(Config.HBaseConfig.FAMILY_COLUMN_NAME), Bytes.toBytes(qualifier), Bytes
|
||||
.toBytes(value));
|
||||
table.put(put);
|
||||
if (logger.isDebugEnabled()) {
|
||||
|
|
|
|||
|
|
@ -92,7 +92,4 @@ public class BuriedPointEntry {
|
|||
return result;
|
||||
}
|
||||
|
||||
public static void main(String[] args){
|
||||
BuriedPointEntry.convert("4d6d38a76c21436e998a81fe798d4ced-.0.0.0-0-com.ai.cloud.skywalking.plugin.spring.common.CallChainE.doBusiness()-1447671990694-0-astraea-PC/192.168.1.108-0- -M-false- -8080;4d6d38a76c21436e998a81fe798d4ced-.0.0-0-com.ai.cloud.skywalking.plugin.spring.common.CallChainC.doBusiness()-1447671990694-11-astraea-PC/192.168.1.108-0- -M-false- -8080");
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue