java .lang.ClassCastException: org. apache .beam.sdk.values.PCollection нельзя преобразовать в org. apache .beam.sdk.values.PBegin - PullRequest
Новая
       36

java .lang.ClassCastException: org. apache .beam.sdk.values.PCollection нельзя преобразовать в org. apache .beam.sdk.values.PBegin

0 голосов
/ 24 марта 2020

Apache луч, использующий SpannerIO, не работает, поскольку он генерирует ниже исключения: java .lang.ClassCastException: org. apache .beam.sdk.values.PCollection не может быть приведен к org. apache. beam.sdk.values.PBegin 

       PCollectionTuple pCollectionTuple1 = (PCollectionTuple) result.apply("Step", ParDo.of(
            new LocationTransform(props)).withOutputTags(PipelineTransformer.TAG_STATEMENT, TupleTagList.of(PipelineTransformer.TAG_DLQ_SINK)));

    PCollection queryStatement = pCollectionTuple1.get(PipelineTransformer.TAG_STATEMENT);

    PCollection<Struct> rows = (PCollection<Struct>) queryStatement .apply(
            SpannerIO.read()
                    .withInstanceId(props.getProperty(Constants.PROPERTY_NAME_SPANNER_INSTANCE_ID))
                    .withDatabaseId(props.getProperty(Constants.PROPERTY_NAME_SPANNER_DATABASE_ID))
                    .withQuery(queryStatement.toString()));
...