Как получить собственный код flink из файла сборки apache beam? - PullRequest
Новая
       7

Как получить собственный код flink из файла сборки apache beam?

0 голосов
/ 14 января 2019

Я определил линию потоковой обработки с помощью Apache Beam и собрал ее для бегуна Fling.

Я получил файл 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?

С уважением, Али

...