[ingester] request_resource/request_domain add bloomfilter index

deepflowio · Jan 16, 2024 · d8952b4 · d8952b4
1 parent 57ab3ca
commit d8952b4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/server/ingester/ckissu/ckissu.go b/server/ingester/ckissu/ckissu.go
@@ -1009,7 +1009,7 @@ var IndexAdd64 = []*IndexAdds{
 	&IndexAdds{
 		Dbs:         []string{"flow_log"},
 		Tables:      []string{"l7_flow_log_local"},
-		ColumnNames: []string{"trace_id", "x_request_id_0", "x_request_id_1"},
+		ColumnNames: []string{"trace_id", "x_request_id_0", "x_request_id_1", "request_resource", "request_domain", "endpoint"},
 		IndexType:   ckdb.IndexBloomfilter,
 	},
 	&IndexAdds{

diff --git a/server/ingester/flow_log/log_data/l7_flow_log.go b/server/ingester/flow_log/log_data/l7_flow_log.go
@@ -251,9 +251,9 @@ func L7FlowLogColumns() []*ckdb.Column {
 		ckdb.NewColumn("is_tls", ckdb.UInt8),
 
 		ckdb.NewColumn("request_type", ckdb.LowCardinalityString).SetComment("请求类型, HTTP请求方法、SQL命令类型、NoSQL命令类型、MQ命令类型、DNS查询类型"),
-		ckdb.NewColumn("request_domain", ckdb.String).SetComment("请求域名, HTTP主机名、RPC服务名称、DNS查询域名"),
-		ckdb.NewColumn("request_resource", ckdb.String).SetComment("请求资源, HTTP路径、RPC方法名称、SQL命令、NoSQL命令"),
-		ckdb.NewColumn("endpoint", ckdb.String).SetComment("端点"),
+		ckdb.NewColumn("request_domain", ckdb.String).SetIndex(ckdb.IndexBloomfilter).SetComment("请求域名, HTTP主机名、RPC服务名称、DNS查询域名"),
+		ckdb.NewColumn("request_resource", ckdb.String).SetIndex(ckdb.IndexBloomfilter).SetComment("请求资源, HTTP路径、RPC方法名称、SQL命令、NoSQL命令"),
+		ckdb.NewColumn("endpoint", ckdb.String).SetIndex(ckdb.IndexBloomfilter).SetComment("端点"),
 		ckdb.NewColumn("request_id", ckdb.UInt64Nullable).SetComment("请求ID, HTTP请求ID、RPC请求ID、MQ请求ID、DNS请求ID"),
 
 		ckdb.NewColumn("response_status", ckdb.UInt8).SetComment("响应状态 0:正常, 1:异常 ,2:不存在，3:服务端异常, 4:客户端异常"),