test/dataflow
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

grpc map function 执行

Browse Source
This commit is contained in:
eson 2022-06-20 18:29:37 +08:00
parent 6de583aebc
commit fe396afe76
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/yuandian/dataflow/grpc/CollectPackets.java
View File

@ -54,10 +54,8 @@ public class CollectPackets extends CollectPacketsServerImplBase {
Map<String, Function<Any, Object>> domap = new HashMap(); Map<String, Function<Any, Object>> domap = new HashMap();
System.out.println( Any.pack(ApmBaseDataFlow.newBuilder().build()).getTypeUrl() ); System.out.println( Any.pack(ApmBaseDataFlow.newBuilder().build()).getTypeUrl() );
System.out.println( AppFlow.class.hashCode() );
domap.put(Any.pack(ApmBaseDataFlow.newBuilder().build()).getTypeUrl(), (p)->{ domap.put(Any.pack(ApmBaseDataFlow.newBuilder().build()).getTypeUrl(), (p)->{
try { try {