如何在Druid转换规范表达式中检查“in”子句
在Druid转换规范表达式中，可以使用"in"子句进行检查。"in"子句用于检查一个字段是否在给定的一组值中。
下面是在Druid转换规范表达式中检查"in"子句的示例：
- 表达式语法:
- 表达式语法:
- 其中，
columnName是要检查的字段名，(value1, value2, ...)是一组要进行匹配的值。 - 功能说明:
- 当
columnName的值与(value1, value2, ...)中的任何一个值匹配时，表达式返回true。 - 当
columnName的值与(value1, value2, ...)中的所有值都不匹配时，表达式返回false。
- 当
- 应用场景：
- 在数据查询中，可以使用"in"子句来过滤某个字段的多个取值。
- 例如，在电商应用中，可以使用"in"子句来筛选某个商品类别的多个具体商品。
- 示例代码：
- 示例代码：
- 其中，
columnName是要检查的字段名，('value1', 'value2', ...)是一组要进行匹配的值。 - 相关产品推荐： 腾讯云Druid的相关产品是TDSQL-Druid，它是腾讯云自主研发的一款在线分析处理（OLAP）引擎。TDSQL-Druid能够提供实时的高性能查询和分析能力，支持灵活的数据聚合、多维分析和可视化。您可以访问TDSQL-Druid产品介绍了解更多详情。
请注意，上述答案仅供参考，实际的表达式语法和产品推荐可能因产品版本更新而有所变化，请以官方文档为准。
相关·内容
Apache索引服务使用avro_stream作为解析器类型，avroBytesDecoder集类型为schema_registry和url模式注册表url。当使用kafka数据和logParseExceptions为真时，获取以下日志：
2021-01-06T02:48:33,022 ERROR [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Encountered parse exception on row from partition[
浏览 6提问于2021-01-06得票数 0
回答已采纳
首先，我将两个mysql表插入到kafka中，然后在druid.Now中加载kafka主题。我在druid中有两个数据源，其中一个数据源包含多达6000条记录，另一个数据源包含多达720000条记录。我试图使用druid join查询从两个数据源获取记录，但它显示以下错误： Resource limit exceeded / Subquery generated results beyond maximum[100000] /
org.apache.druid.query.ResourceLimitExceededException 查询： SELECT * FROM unsold_all
浏览 116提问于2020-10-06得票数 0
我正在尝试使用火龙带从PostgreSQL到Druid的数据。
我在conf文件中添加了druid.extensions.loadList=["postgresql-metadata-storage"]，但是任务失败
java.lang.ClassCastException:不能将java.util.LinkedHashMap转换为java.nio.ByteBuffer
摄食规格文件
{
"type": "index",
"spec": {
"dataSchema": {
浏览 0提问于2019-07-10得票数 0
回答已采纳
1回答
面对快速摄取德鲁伊的问题。在org.apache.hadoop.mapred.LocalJobRunner - map任务执行器完成后，事情开始中断。它能够获取输入文件。
我的规范json文件-
{
"hadoopCoordinates": "org.apache.hadoop:hadoop-client:2.6.0",
"spec": {
"dataSchema": {
"dataSource": "apps_searchprivacy",
浏览 3提问于2017-02-03得票数 1
在MacOSX 10.12上安装了德鲁伊和动物园管理员之后，我无法让霸主进程运行。
java `cat conf-quickstart/druid/overlord/jvm.config | xargs` -cp "conf-quickstart/druid/_common:conf-quickstart/druid/overlord:lib/*" io.druid.cli.Main server overlord
我得到了地址已经在使用的错误。
浏览 6提问于2017-06-21得票数 0
回答已采纳
我对Druid查询有一些疑问。
根据公文，有两种查询语言，即Druid查询和本地查询。
在我的使用中，我觉得使用Druid更舒服，因为我对本机查询不太了解，并且有一个简单的代码。
但是，我不知道两种查询语言在性能上的差别。
他们之间的表现有很大的不同吗？
我看到了一个。在该文档中，在Druid0.15.0或之后重新使用Druid。(目前，Druid的最新版本是0.23.0)
使用Druid查询还是本机查询更好？？
浏览 5提问于2022-08-11得票数 0
回答已采纳
当我向Druid霸主API发送JSON摄入规范时，我会得到以下响应：
HTTP/1.1 400 Bad Request
Content-Type: application/json
Date: Wed, 25 Sep 2019 11:44:18 GMT
Server: Jetty(9.4.10.v20180503)
Transfer-Encoding: chunked
{
"error": "Instantiation of [simple type, class org.apache.druid.indexing.common.task.IndexTask]
浏览 12提问于2019-09-25得票数 5
回答已采纳
1回答
druid_d_c_t=AC6F5384019F7DBA76B7AC009393E539&p_auth=l3wEweSQ
我已经为druid_d_c_t= druid_d_c_t","(.+?)"和p_auth=p_auth=(.*?)&准备了正则表达式
在运行脚本后，我得到了如下输出：
GET https://aaaaaaaaaaaaaaaaaaaaaaa/druid-web/status?druid_d_c_t=${druid}&p_auth=me6Xr3xa
我认为p_auth工作得很好，但是druid不工作。我需要在哪部分改正它？
浏览 1提问于2015-07-16得票数 0
我正通过宁静把卡夫卡的溪流推入德鲁伊。卡夫卡版本为0.9.1，宁静为0.8，德鲁伊为0.10。当没有产生消息时，宁静会很好地启动，但是当生产者发送消息时，我会得到这样的JsonMappingException：
ava.lang.IllegalArgumentException: Can not deserialize instance of java.util.ArrayList out of VALUE_STRING token
at [Source: N/A; line: -1, column: -1]
at com.fasterxml.jackson.databind.Obj
浏览 2提问于2017-05-16得票数 0
回答已采纳
我在普雷姆机器上安装了德鲁伊的微型服务器。我想用HDFS作为德鲁伊的深层存储。我使用了以下、和作为参考。
我在/apache-druid-0.16.0-incubating/conf/druid/single-server/micro-quickstart/_common/common.runtime.properties中做了以下修改
druid.extensions.loadList=["druid-hdfs-storage", "druid-kafka-indexing-service", "druid-datasketches"]
#
浏览 9提问于2019-12-03得票数 0
回答已采纳
我使用的是德鲁伊io 0.9.0。我正在尝试添加一个帖子聚合字段作为度量规范。我的意图是显示post聚合字段的值，类似于指标(度量)的显示方式(在使用Pivot的Druid io中)。
我的Druid io模式文件是
{
"dataSources" : {
"NPS1112" : {
"spec" : {
"dataSchema" : {
"dataSource" : "NPS1112",
浏览 1提问于2016-06-06得票数 3
使用Linq.Expression<T>类型，我们可以编程地定义AST以供以后的评估和/或执行。
但实际上，以这种方式定义方法签名意味着什么：
public void SomeMethod1(Func<bool> func) { ... } // 1.
而不是
public void SomeMethod2(Expression<Func<bool>> expr) { ... } // 2.
显然，我们从Func<bool>获得结果的方式有以下几种：
var result = func(); // 1.
至
var func = ex
浏览 3提问于2013-03-21得票数 0
1回答
我的环境在下面。
MacBook Pro (13英寸，2019年，4个迅雷3端口)
2.8 GHz四CoreIntel核心i7
16 GB 2133 MHz LPDDR3
Intel Iris Plus Graphics 655 1536 MB
码头: 19.03.12
德鲁伊: 0.19.0
尽管我遵守了官方的指示，但我未能在本地构建或运行德鲁伊。
关于这个：
我输入了以下命令。
git clone https://github.com/apache/druid.git
docker build -t apache/druid:tag -f distribut
浏览 0提问于2020-08-06得票数 1
我有一个Apache Druid数据库，我想用Prometheus监控Apache Druid数据库。我研究发现Druid Exporter支持Prometheus从Apache Druid收集指标，我找到了下面的文档：
我把所有东西都安装在docker里。
遵循指引，我在德鲁伊的common.runtime.properties文件中设置：
> druid_emitter_http_recipientBaseUrl=http://<druid_exporter_url>:<druid_exporter_port>/druid
> druid_emitte
浏览 31提问于2021-07-19得票数 0
如何在Druid SQL中从当前日期获取7天前的日期？我在Postgres SQL中做过类似的事情
CURRENT_DATE - interval '7 day'
我需要在Druid SQL查询中执行相同的操作
浏览 0提问于2020-08-20得票数 0
我正在我的企业Kube上部署Druid-operator。我正在得到OOM终止错误：
NAME READY STATUS RESTARTS AGE
druid-operator-c68cf5bc8-n6pzt 1/1 Running 0 107m
druid-tiny-cluster-brokers-0 0/1 OOMKilled 1 62s
druid-tiny-cluster-coordinators-0 0/1
浏览 9提问于2021-03-30得票数 1
既然Druid已成为Google ()的可选组件，我想知道如何从Dataproc集群创建Druid配置？我尝试了以下gcloud命令：
%gcloud dataproc clusters create test1 --region=us-east1 --zone=us-east1-b --
num-masters=1 --num-workers=2 --optional-components=ZOOKEEPER,DRUID --
properties=druid:druid.storage.type=google,...
但是它返回一个错误：
属性“druid:druid.storage
浏览 6提问于2020-08-03得票数 2
我是第一次设置德鲁伊，在尝试使用docker-compose启动德鲁伊时遇到了以下问题， 2020-04-10T14:40:01,837错误qtp1667348377-84 org.apache.druid.server.router.QueryHostFinder -灾难性故障！根本找不到服务器！请求失败！：{class=org.apache.druid.server.router.QueryHostFinder} 2020-04-10T14:40:01,837 WARN qtp1667348377-84 org.eclipse.jetty.server.HttpChannel - /dr
浏览 159提问于2020-04-11得票数 5
我试图运行超过500 K数据限制的groupBy查询。我得到了这个错误。
{
"error": "Resource limit exceeded",
"errorMessage": "Not enough dictionary space to execute this query. Try increasing druid.query.groupBy.maxMergingDictionarySize or enable disk spilling by setting druid.query.groupBy.maxOnD
浏览 0提问于2018-07-10得票数 3
2回答
TempTable(Ncol1, Ncol2) as
(SELECT
col1,
SUBSTR(xmlserialize(xmlagg(xmltext(CONCAT( ', ', col2))) as VARCHAR(1024)), 3) AS ConcatCol2
FROM Table A
WHERE A.col2 IN ('A','B','C','D')
and A.Date >= (select FirstDayMonth from dates)
GROU
浏览 6提问于2021-01-14得票数 0
回答已采纳
3回答
我按照文档进行了编辑：
druid-0.9.2/conf/druid/_common/common.runtime.properties
并添加了：
"druid-kafka-indexing-service"
连接到druid.extensions.loadList，并重新启动了所有的德鲁伊服务：middlemanager、overlord、coordinator、broker、historical
我跑了一下：
curl -X 'POST' -H 'Content-Type:application/json' -d @kafka_connec
浏览 2提问于2017-02-24得票数 4
我将apache 0.22.1安装为集群(主节点、数据和查询节点)，并将其添加到common.runtime.properties中的数组common.runtime.properties中，从而启用了“德鲁伊-谷歌-扩展”。最后，我将GOOGLE_APPLICATION_CREDENTIALS (它的值为中定义的服务帐户json )定义为运行德鲁伊服务的用户的环境变量。然而，当我尝试从GCR桶中摄取数据时，我得到了以下错误：
org.apache.druid.data.input.google.GoogleCloudStorageInputSource，错误:无法构造问题的实例:无法提供，请
浏览 13提问于2022-01-11得票数 0
回答已采纳
我在德鲁伊提交了一个摄取任务。任务正在成功完成，并且在hdfs中创建了数据段。
以前使用相同的配置时，数据段缓存正在更新。
但是，新数据源的数据段不会更新druid- segment缓存。
我已经检查并发现所有的德鲁伊服务都已启动并运行。
下面是一个被记录的异常。
io.druid.query.lookup.LookupReferencesManager.start()] on object[io.druid.query.lookup.LookupReferencesManager@7336fd8f].
INFO [main] io.druid.query.lookup.LookupRefe
浏览 5提问于2018-09-26得票数 0
3回答
我们能在德鲁伊进行改造吗？
、、、、
我有一个场景，我将在csv文件中接收数据，在那里，我需要用现有的列生成一些列。示例：
Col_1 Col_2 Col_3 Col_4
abc 1 No 123
xyz 2 Yes 123
def 1 Yes 345
预期：
Col_1 Col_2 Col_3 Col_4 Col_5 Col_6
abc 1 No 123 1 1
xyz 2 Yes 123 0 0
浏览 6提问于2021-12-13得票数 3
1回答
我正在遵循德鲁伊网站上的步骤：
但由于某种原因，它一直给我这个错误：
2016-07-19T22:44:36,276 ERROR [task-runner-0-priority-0] io.druid.indexing.overlord.ThreadPoolTaskRunner - Exception while running task[HadoopIndexTask{id=index_hadoop_wikiticker_2016-07-19T22:44:25.500Z, type=index_hadoop, dataSource=wikiticker}]
java.lang.Runtime
浏览 9提问于2016-07-20得票数 2
我写规范是为了收集卡夫卡的数据。但是我知道Druid将自动转换类型为double、long到0.0和0的空值。‘但是我想存储空值而不是0。那么，当为每个维度列设置类型时，我应该做什么。
浏览 12提问于2022-03-15得票数 0
1回答
我创建了一个带有存储处理程序的hive表，现在我想在该表中添加一个列，但是它给出了下面的错误：
[Code: 10134, SQL State: 42000] Error while compiling statement: FAILED:
SemanticException [Error 10134]: ALTER TABLE can only be used for [ADDPROPS,
DROPPROPS] to a non-native table
根据单元文档，使用存储处理程序创建的任何单元表都是非本机表。
这里有一个链接
这里有一个JIRA案例，对于相同的Apache来说，增
浏览 2提问于2018-03-21得票数 1
回答已采纳
1回答
我使用这个查询来转换和提取一些日期值： Select
Format(TRY_CAST(CD.Import_Date as Date),'MM/dd/yyyy') As 'Import_Date'
From dbo.QE_CD CD
Where CD.Import_Date IS NOT NULL And DATALENGTH(CD.Import_Date) > 0 但是，即使在省略空值之后，我仍然在我的返回集中收到它们： ? 我的理解是，使用TRY_CAST的失败转换返回NULL -那么我的where子句不应该省略它们吗？
浏览 28提问于2020-09-15得票数 0
回答已采纳
1回答
昨天，我从Hive创建了我的第一个数据源Druid。今天，我不确定这是否行得通..。 首先，我运行以下代码来创建我的数据库： SET hive.druid.broker.address.default = 10.20.173.30:8082;
SET hive.druid.metadata.username = druid;
SET hive.druid.metadata.password = druid_password;
SET hive.druid.metadata.db.type = postgresql;
SET hive.druid.metadata.uri = jdbc:pos
浏览 52提问于2019-10-15得票数 2
回答已采纳
2回答
刚刚开始探索Druid，我们还没有找到在AWS上安装Druid的博客链接，有没有机会在AWS EMR上安装Druid？如果是这样，如果有任何预先定义的云形成可以执行，这将对我在Druid上的研发有很大的帮助。
浏览 2提问于2019-06-13得票数 1
2回答
我试图用hibernate从我的数据库中检索数据，但是它总是抛出异常。
2012-11- 11 :35:45,943主错误com.storage.hibernate.DatabaseAccessRequestsImpl -有一个错误javax.persistence.PersistenceException: org.hibernate.exception.SQLGrammarException:无法执行查询
@Override
public List<Trade> requestPeriod() {
List<Trade> trades = null;
浏览 1提问于2012-11-11得票数 3
回答已采纳
在我的休眠系统中，我有一个class Picture，它有一些简单的数据，一个安装列表和一些(巨大的)二进制数据。安装列表是通过连接表实现的，因为它是一个ManyToMany关系，并且是在安装端定义的：
@Entity
public class Picture {
@Id
private long pictureId;
private String mimeType;
@Lob
@Basic(fetch=FetchType.LAZY) // Don't load all data unless required
private byte[] picture;
浏览 0提问于2010-06-29得票数 2
回答已采纳
1回答
我已经使用命令(./bin/start-micro-quickstart)部署了Druid单服务器 我的服务器规格是8vCPU和32 My内存(EC2 t2.2Xlarge)，还增加了100 My的交换空间，我正在尝试将27M条记录从kafka转换到Druid。 现在，我在Druid数据源中显示了4M条记录，总大小为506 MB，段大小为5400 (平均段大小为92.99 KB) 我的内存使用量是 total used free shared buff/cache available
Mem: 31G
浏览 121提问于2020-04-30得票数 1
2回答
我有来自Kafka的具有以下结构的事件数据，我想在Druid中摄取这些数据 {
"event": "some_event",
"id": "1",
"parameters": {
"campaigns": "campaign1, campaign2",
"other_stuff": "important_info"
}
} 具体地说，我希望将维度"campaigns“从逗号分隔的字符串转换为数组/多值维度，
浏览 18提问于2019-06-21得票数 1
在原始的druid模式中有一个"__time“字段(以毫秒为单位)，而现在我需要将几个”派生“字段添加到"__time”的日|月|年中进行分组，如何在超集"List Druid Column“选项卡中添加它们？
浏览 0提问于2018-06-19得票数 1
在过去的一周里，我一直在使用Druid，我想为一些postAggregations启用javascript。
我想我已经按照概述的步骤进行了操作，并更新了../con f/druid/_common/中的common.runtime.properties文件以包含druid.javascript.enabled=true。然后我停止了当前的进程，并重新运行了快速入门过程，但它仍然显示JavaScript被禁用：
{
"error" : "Unknown exception",
"errorMessage" : "Instantia
浏览 3提问于2017-08-16得票数 1
我正在尝试了解Apache Druid中原生查询的某些方面的性能。有没有办法获得原生查询的执行计划？对于Druid中的SQL，我们有...
EXPLAIN PLAN FOR SELECT * FORM ds
对于原生查询，有没有等效的命令？
浏览 7提问于2020-08-10得票数 2
2回答
我的Druid版本是0.16。 我有一个很长的专栏: status_code，它只是表示http响应状态。 当启用rollup时，此列将被聚合，但我不需要它。事件我创建了一个转换列，添加一个字符串前缀到status_code，生成一个字符串列。它也将被聚合为长列。 如何从汇总中排除此列？请帮帮我..。
浏览 18提问于2019-12-23得票数 0
回答已采纳
下面是SelectMany()的简单形式。如果我们可以将其转换为查询语法，该如何处理？
var array = new string[] { "Shaun", "Luttin" };
array
.SelectMany(
s => s
);
我所能做的最好的就是产生相同的输出，但是引入了一个新的变量c..。
var query =
from s in array.AsQueryable()
from c in s
select c;
...and的结果是使用以下fluent语法。
array
浏览 1提问于2015-04-14得票数 4
回答已采纳
2回答
我在sqlite查询中得到了以下异常：
表达式包含未定义的函数调用lower()
我在VS2012中有一个非常简单的VS2012类型化数据集。
我正在解析大量数据，并希望在添加新行之前检查行是否已经存在。
我正在使用.select()方法返回一个数据数组。如果数组的长度为零，则添加一个新的。很简单！
所有这些都运行良好，但我添加了一项检查，以防止在情况错误时添加重复行。我在存储文件名。
select语句是：
"lower(FileName) = '" + EscapeFileName(strFileName).ToLower() + "'"
浏览 7提问于2013-02-28得票数 1
回答已采纳
2回答
我在数据访问层中为实体框架对象使用LINQ实体。
我的目标是尽可能多地从数据库中过滤，而不将过滤逻辑应用于内存中的结果。
为此，业务逻辑层将谓词传递给数据访问层。
我是说
Func<MyEntity, bool>
所以，如果我直接使用这个谓词，就像
public IQueryable<MyEntity> GetAllMatchedEntities(Func<MyEntity, Boolean> isMatched)
{
return qry = _Context.MyEntities.Where(x => isMatched(x));
}
我要
浏览 3提问于2013-10-27得票数 32
回答已采纳
我尝试创建我的Druid模式，我引用了一个示例如下：
{"dimensionsSpec": {"dimensions": ["timestamp”,"netname"] },
"columns": ["second_time","timestamp"],
"delimiter": "/001"
}
我的问题是，如果我指出尺寸，为什么我应该再次表示列。顺便说一句，我应该在维度中加上时间戳(它是秒)吗？因为我的粒度很小。
浏览 1提问于2019-01-31得票数 0
回答已采纳
1回答
我从link attached here 安装了德鲁伊来安装德鲁伊。 已将以下代码添加到common.runtime.properties文件中。 # Basic Security
druid.auth.authenticatorChain=["MyBasicAuthenticator"]
druid.auth.authenticator.MyBasicAuthenticator.type=basic
druid.auth.authenticator.MyBasicAuthenticator.initialAdminPassword=password1
druid.auth
浏览 39提问于2019-12-17得票数 1
回答已采纳
我使用服务从Kafka加载自己的流。
我使用来实现它。
卡夫卡默认拥有所有设置(仅从tgz中提取)。
当我使用空数据(在var删除文件夹之后)启动-2.2.3 Druid时，所有操作都正常。
但是，当我停止卡夫卡2.11-0.10.2.0并再次启动它时，就会发生错误，并且Druid摄入不再起作用，直到我停止暗示(Druid)并删除所有数据(即删除var文件夹)。
有时候德鲁伊只是不吃卡夫卡的数据，甚至没有卡夫卡的错误。当我移除德鲁伊中的var文件夹时，所有的内容都将恢复到下一个相同的错误。
错误：
kafka.common.NoReplicaOnlineException: No replic
浏览 0提问于2017-08-03得票数 0
如果我将POST的响应解析为字符串，它将完美地工作：
ResponseEntity<String> stringResponse = restTemplate.postForEntity(DruidClient.QUERY_HOST + "/druid/v2", query, String.class);
String valueResults = stringResponse.getBody();
DruidValueResult[] results = new ObjectMapper().readValue(valueResults, DruidValueRe
浏览 3提问于2014-08-25得票数 1
回答已采纳
这是Debian squeeze上的SBCL 1.0.55。我可能遗漏了一些明显的东西，但我是一个初学者，所以请容忍我。
CL-USER> (defparameter x 0)
CL-USER> (case x (t 111) )
111
所以这里的情况看起来像是将变量x与真值符号t匹配。我尝试过的所有东西都会发生这种情况；这个x只是一个例子。我不明白为什么会发生这种事。由于case使用eql进行匹配，因此我尝试了
CL-USER> (eql x t)
NIL
因此，eql与x和t不匹配。我遗漏了什么？提前谢谢。
浏览 0提问于2012-03-18得票数 5
回答已采纳
当我试图向德鲁伊用户界面(通过路由器)提交摄取规范时，我得到了“未能提交主管:状态代码502的请求失败”的错误。摄入规范在独立的德鲁伊服务器中工作。
我使用4台机器设置了集群--1台用于协调器和霸主(主)，1台用于历史和中间管理器(数据)，1台用于代理(查询)，1台用于路由器，其中包含一个单独的用于动物园管理员的实例。日志中没有错误。
摄入规范如下：
{
"type": "kafka",
"dataSchema": {
"dataSource": "table1",
"parser&
浏览 1提问于2019-05-20得票数 1
回答已采纳
描述druid支持的dataproc页面没有关于如何将数据加载到集群中的部分。我一直在尝试使用GC Storage来做到这一点，但我不知道如何为它设置一个有效的规范。我希望"firehose“部分有一些google特定的引用，但没有例子说明如何做到这一点。 将数据加载到Druid中，直接在GCP dataproc上直接运行的方法是什么？
浏览 9提问于2019-09-20得票数 6
回答已采纳
3回答
string grid = @"08 02 22 97 38 15 00 40 00 75 04 05 07 78 52 12 50 77 91 08";
string[] res = grid.Split(' ');
var lowNums = from n in res
where n.Length > 0
select int.Parse(n);
我在将上面的linQ语句转换成等效的lambda语句时遇到了问题。下面的代码行得通，但只返回enumernable<string>，而我
浏览 0提问于2010-07-01得票数 2
回答已采纳
我下面的linq表达式，我想知道into关键字是如何在基于方法的语法中转换的？
var q = from pd in dataContext.tblProducts
join od in dataContext.tblOrders on pd.ProductID equals od.ProductID
into t
from rt in t.DefaultIfEmpty()
orderby pd.ProductID
select pd
浏览 8提问于2014-02-27得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
