小编bag*_*agi的帖子

过滤掉元数据字段,仅返回elasticsearch中的源字段

有没有办法告诉elasticsearch不返回任何元数据?目前我可以选择要在源中返回哪些字段.但我只想要源代码中的字段.我宁愿没有返回元数据,因为我不需要它,并会节省一些不必要的解析和传输等.

我找到了Elasticsearch - 如何只返回数据,而不是元信息?更老的问题,有人评论说当时不可能做到这一点.想知道这个功能是否已添加或仍然缺失?

elasticsearch

29
推荐指数
3
解决办法
2万
查看次数

elasticsearch aggregation使用脚本转换要聚合的字段值

我目前有类似的东西:

__CODE__

然而,myfield的值是"alpha 1.0","alpha 2.0","beta 1.0".现在我想只聚合值"alpha","beta".我怎么做?我试过了:

__CODE__

但我想没有拆分功能.欢迎任何建议!

我在这里发现了一个类似的问题,也没有答案.

编辑:设法使用上面的链接完成它.以下查询完成工作.

__CODE__

mvel elasticsearch

7
推荐指数
1
解决办法
2908
查看次数

在 apache flink 中反序列化 protobuf 事件中的事件时出现问题

我正在我的 Flink 应用程序中读取来自 kinesis 的事件。事件采用 protobuf 格式。如果我'com.google.protobuf:protobuf-java:3.7.1'在 flink 应用程序中使用 with ,我就没有问题。但是,如果我将其更改为'com.google.protobuf:protobuf-java:3.10.0'我会得到上述堆栈跟踪异常

java.lang.IncompatibleClassChangeError: class com.google.protobuf.Descriptors$OneofDescriptor has interface com.google.protobuf.Descriptors$GenericDescriptor as super class
        at java.lang.ClassLoader.defineClass1(Native Method)
        at java.lang.ClassLoader.defineClass(ClassLoader.java:763)
        at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
        at java.net.URLClassLoader.defineClass(URLClassLoader.java:468)
        at java.net.URLClassLoader.access$100(URLClassLoader.java:74)
        at java.net.URLClassLoader$1.run(URLClassLoader.java:369)
        at java.net.URLClassLoader$1.run(URLClassLoader.java:363)
        at java.security.AccessController.doPrivileged(Native Method)
        at java.net.URLClassLoader.findClass(URLClassLoader.java:362)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
        at java.lang.Class.getDeclaredMethods0(Native Method)
        at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
        at java.lang.Class.privateGetPublicMethods(Class.java:2902)
        at java.lang.Class.privateGetPublicMethods(Class.java:2917)
        at java.lang.Class.getMethods(Class.java:1615)
        at org.apache.flink.api.java.typeutils.TypeExtractor.isValidPojoField(TypeExtractor.java:1786)
        at org.apache.flink.api.java.typeutils.TypeExtractor.analyzePojo(TypeExtractor.java:1856)
        at org.apache.flink.api.java.typeutils.TypeExtractor.privateGetForClass(TypeExtractor.java:1746)
        at org.apache.flink.api.java.typeutils.TypeExtractor.privateGetForClass(TypeExtractor.java:1643)
        at org.apache.flink.api.java.typeutils.TypeExtractor.createTypeInfoWithTypeHierarchy(TypeExtractor.java:921)
        at org.apache.flink.api.java.typeutils.TypeExtractor.privateCreateTypeInfo(TypeExtractor.java:781)
        at org.apache.flink.api.java.typeutils.TypeExtractor.createTypeInfo(TypeExtractor.java:735)
        at org.apache.flink.api.java.typeutils.TypeExtractor.createTypeInfo(TypeExtractor.java:731)
        at org.apache.flink.api.common.typeinfo.TypeInformation.of(TypeInformation.java:211)
        at org.apache.flink.api.java.typeutils.ListTypeInfo.<init>(ListTypeInfo.java:45)
        at …
Run Code Online (Sandbox Code Playgroud)

java protocol-buffers amazon-kinesis apache-flink

1
推荐指数
1
解决办法
1857
查看次数