Пример ZetaSQL с использованием Apache Beam - PullRequest
0 голосов
/ 15 октября 2019

У меня проблемы при использовании ZetaSQL в Apache Beam Framework (2.17.0-SNAPSHOT). После просмотра документации по Apache Beam я не могу найти образец для ZetaSQL.

Я попытался добавить Планировщик: options.setPlannerName("org.apache.beam.sdk.extensions.sql.zetasql.ZetaSQLQueryPlanner");

Но проблема все еще остается, ниже добавлен фрагмент кода. для справки.

    ```
    String sql =
                    "SELECT CAST (1243 as INT64), "
                        + "CAST ('2018-09-15 12:59:59.000000+00' as TIMESTAMP), "
                        + "CAST ('string' as STRING);";

      ZetaSQLQueryPlanner zetaSQLQueryPlanner = new ZetaSQLQueryPlanner();
            BeamRelNode beamRelNode = zetaSQLQueryPlanner.convertToBeamRel(sql);
            PCollection<Row> stream = BeamSqlRelUtils.toPCollection(p, beamRelNode);
    p.run();

Я понимаю, что нам нужен приведенный ниже фрагмент кода, но не удалось создать конфигурационный файл Frameworks.newConfigBuilder ()

, и во время выполнения кода я обнаружил следующие исключения:

    Exception in thread "main" java.util.ServiceConfigurationError: com.google.zetasql.ClientChannelProvider: Provider com.google.zetasql.JniChannelProvider could not be instantiated
        at java.util.ServiceLoader.fail(Unknown Source)
        at java.util.ServiceLoader.access$100(Unknown Source)
        at java.util.ServiceLoader$LazyIterator.nextService(Unknown Source)

...