我用apachebeam定义了流处理的管道，并为flingrunner构建了它。
我得到了一个jar文件，但是当我提取java文件时，java代码不是原生的flink代码。
虽然我在类中发现了一些生成的代码：

// $FF: synthetic method
 private static Object $deserializeLambda$(SerializedLambda lambda) {
  String var1 = lambda.getImplMethodName();
  byte var2 = -1;
  switch(var1.hashCode()) {
  case -30470307:
     if (var1.equals("lambda$main$fd9fc9ef$1")) {
        var2 = 1;
     }
     break;
  case -30470306:
     if (var1.equals("lambda$main$fd9fc9ef$2")) {
        var2 = 0;
     }
  }

有没有用flink代码生成的文件？
你好，阿里