如何使用Google Datastore CompositeFilter和DataFlow？

Question

Pipeline p = ...
Filter filter = Filter.newBuilder()
        .setPropertyFilter(PropertyFilter.newBuilder()
                .setProperty(PropertyReference.newBuilder()
                        .setName("propertyA"))
                .setOp(PropertyFilter.Operator.EQUAL)
                .setValue(Value.newBuilder().setStringValue("valueA").build())
                .build())
        .build();

Query query = Query.newBuilder()
    .addKind(KindExpression.newBuilder().setName("myKind").build())
                .setFilter(filter)
                .build();
p.apply("read", DatastoreIO.v1().read().withProjectId("myProjectId")
                .withNamespace("myNamespace").withQuery(query)).apply(.....

经过一些研究，我发现了一个CompositeFilter，它应该能够组合多个过滤器。我可以构建一个复合筛选器，但是当我想在查询中将其设置为筛选器时，IDE会抱怨类型不匹配，而且似乎没有其他方法来应用筛选器。

通过使用GQL，我成功地使用了一个带有多个过滤器的查询，并且可以在日志中看到它被转换为CompositeFilter。我在这里不是要抱怨GQL的使用比手工构建查询/过滤器要好得多，而是想问一下在datastoreio.v1().read（....）上下文中如何使用库的复合过滤器或者如果不可能的话。

我正在使用com.google.cloud.dataflow/google-cloud-dataflow-java-sdk-all/2.2.0

谢谢你的帮助。

Answer 1

根据文件，你可以。您可以使用CompositeFilterNewBuilder方法，并创建一个过滤器，如下所示：

过滤器composeFilter=filter.newbuilder（）.setCompositeFilter(compositeFilter.newBuilder（）.addFilter1).addFilter2).build().build（）；

这里的Filter1和Filter2是与您所创建的过滤器类似的过滤器。我的IDE允许我这样做（我使用的是IntelliJ IDEA，最后一个版本）。