Невозможно вызвать getSchema, если схема отсутствует при объединении двух коллекций Pcollections. ⇐ JAVA
-
Гость
Невозможно вызвать getSchema, если схема отсутствует при объединении двух коллекций Pcollections.
Надеюсь, у вас все хорошо.
У меня есть две PCollection, и я хочу применить leftOuterJoin, но когда я это применяю, у меня возникает эта ошибка, и я не понимаю, почему: java.lang.IllegalStateException: невозможно вызвать getSchema, когда нет схемы
final PCollection classA = BigQueryReader.getClassA(pipeline, Configuration.getBigQueryOptions()); окончательный PCollection classB = BigQueryReader.getClassB(pipeline, Configuration.getBigQueryOptions()); окончательный PCollection join = classA .apply("Применить присоединение", Join.leftOuterJoin(classB).using("id1", "id2"); Кто-нибудь может помочь понять, почему возникает эта ошибка.
Большое спасибо.
Надеюсь, у вас все хорошо.
У меня есть две PCollection, и я хочу применить leftOuterJoin, но когда я это применяю, у меня возникает эта ошибка, и я не понимаю, почему: java.lang.IllegalStateException: невозможно вызвать getSchema, когда нет схемы
final PCollection classA = BigQueryReader.getClassA(pipeline, Configuration.getBigQueryOptions()); окончательный PCollection classB = BigQueryReader.getClassB(pipeline, Configuration.getBigQueryOptions()); окончательный PCollection join = classA .apply("Применить присоединение", Join.leftOuterJoin(classB).using("id1", "id2"); Кто-нибудь может помочь понять, почему возникает эта ошибка.
Большое спасибо.
