kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

上传部分验证脚本

This commit is contained in:
wusheng 2016-05-03 10:18:18 +08:00
parent fe8911d4aa
commit e8f7d7ceab
4 changed files with 25 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java
View File

@ -57,10 +57,10 @@ public class AnalysisServerDriver extends Configured implements Tool {
conf.set("hbase.zookeeper.quorum", Config.HBase.ZK_QUORUM);
conf.set("hbase.zookeeper.property.clientPort", Config.HBase.ZK_CLIENT_PORT);
//-XX:+UseParallelGC -XX:ParallelGCThreads=4 -XX:GCTimeRatio=10 -XX:YoungGenerationSizeIncrement=20 -XX:TenuredGenerationSizeIncrement=20 -XX:AdaptiveSizeDecrementScaleFactor=2
conf.set("mapred.child.java.opts",Config.MapReduce.java_opts);
conf.set("mapred.child.java.opts",Config.MapReduce.JAVA_OPTS);
String[] otherArgs = new GenericOptionsParser(conf, args).getRemainingArgs();
if (otherArgs.length != 2) {
System.err.println("Usage: AnalysisServer yyyy-MM-dd/HH:mm:ss yyyy-MM-dd/HH:mm:ss");
System.err.println("Usage: com.ai.cloud.skywalking.analysis.AnalysisServerDriver yyyy-MM-dd/HH:mm:ss yyyy-MM-dd/HH:mm:ss");
System.exit(2);
}

2
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/config/Config.java
View File

@ -31,6 +31,6 @@ public class Config {
}
public static class MapReduce{
public static String java_opts = "-Xmx200m";
public static String JAVA_OPTS = "-Xmx200m";
}
}

9
skywalking-analysis/src/test/java/com/ai/cloud/skywalking/analysis/datacheck/01.truncateHBaseTable.md Normal file
View File

@ -0,0 +1,9 @@
```sql
truncate "sw-chain-1day-summary"
truncate "sw-chain-1hour-summary"
truncate "sw-chain-1min-summary"
truncate "sw-chain-1month-summary"
truncate "sw-chain-detail"
truncate "sw-treeId-cid-mapping"
truncate "sw-traceId-cid-mapping"
```

13
skywalking-analysis/src/test/java/com/ai/cloud/skywalking/analysis/datacheck/02.scan4ColumnValue.md Normal file
View File

@ -0,0 +1,13 @@
* 查询某一张表中的某一列等于某一个值（比如sw-treeId-cid-mapping，sw-traceId-cid-mapping）
```java
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
import org.apache.hadoop.hbase.filter.BinaryComparator;
import org.apache.hadoop.hbase.filter.CompareFilter;
import org.apache.hadoop.hbase.filter. Filter;
scan 'sw-chain-info', { FILTER
=>SingleColumnValueFilter.new(Bytes.toBytes('trace_info'),Bytes.toBytes('cid'),
CompareFilter::CompareOp.valueOf('EQUAL'),
BinaryComparator.new(Bytes.toBytes('CID_B4CAEE3953B3C0DBD7A43656B2EEE345')))}
```