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

修改配置项

This commit is contained in:
ascrutae 2016-01-29 10:10:56 +08:00
parent 4f7372c48c
commit 61e402a401
2 changed files with 5 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
skywalking-analysis/src/main/resources/analysis.conf
View File

@ -1,32 +1,14 @@
hbase.trace_detail_family_column=chain_detail
hbase.chain_summary_column_family=chain_summary
hbase.trace_info_column_family=trace_info
hbase.zk_quorum=10.1.235.197,10.1.235.198,10.1.235.199
hbase.zk_client_port=29181
hbase.trace_info_table_name=trace-info
hbase.table_call_chain_relationship=sw-chain-relationship
hbase.chain_relationship_column_family=chain-relationship
hbase.table_chain_info=sw-chain-info
hbase.table_chain_summary=sw-chain-summary
hbase.table_chain_detail=sw-chain-detail
hbase.table_call_chain=sw-call-chain
traceinfo.trace_info_column_cid=cid
mysql.url=jdbc:mysql://10.1.228.202:31316/test
mysql.username=devrdbusr21
mysql.password=devrdbusr21
mysql.driver_class=com.mysql.jdbc.Driver
filter.filter_package_name=com.ai.cloud.skywalking.analysis.categorize2chain.filter.impl

3
skywalking-analysis/src/test/java/com/ai/cloud/skywalking/analysis/mapper/CallChainMapperTest.java
View File

@ -6,6 +6,7 @@ import com.ai.cloud.skywalking.analysis.categorize2chain.Categorize2ChainReducer
import com.ai.cloud.skywalking.analysis.categorize2chain.model.ChainInfo;
import com.ai.cloud.skywalking.analysis.config.Config;
import com.ai.cloud.skywalking.analysis.config.ConfigInitializer;
import com.ai.cloud.skywalking.analysis.config.Constants;
import com.ai.cloud.skywalking.protocol.Span;
import org.apache.hadoop.conf.Configuration;
@ -48,7 +49,7 @@ public class CallChainMapperTest {
public static List<Span> selectByTraceId(String traceId) throws IOException {
List<Span> entries = new ArrayList<Span>();
Table table = connection.getTable(TableName.valueOf(Config.HBase.TABLE_CALL_CHAIN));
Table table = connection.getTable(TableName.valueOf(Constants.TABLE_CALL_CHAIN));
Get g = new Get(Bytes.toBytes(traceId));
Result r = table.get(g);
for (Cell cell : r.rawCells()) {