使用Hive、Tez和偏移量执行查询
我试图在hive中执行偏移量查询，试图排除特定记录，但总是得到以下错误：
select * from sample order by id limit 1 OFFSET 1;
FAILED: ParseException line 1:41 missing EOF at 'OFFSET' near '1'
环境：
1) Cloudera 5.12
2) Hive 1.1.0-cdh5.12.0
共有1个答案
不清楚为什么要标记MySQL，但是offset并不作为HiveQL SELECT语法的一部分存在。
https://cwiki.apache.org/confluence/display/hive/languagemanual+select
-
简而言之，我想从一开始就对Kafka的数据重新运行Flink管道。 Flink0.10.2，Kafka0.8.2。 我在Kafka中有一个保留2小时的推文主题，以及Flink中的一个管道，该管道以每10秒5分钟的滑动窗口计算推文。 如果我中断管道并重新运行它，我希望它重新读取旧推文，从而发出价值5分钟的推文计数。相反，它似乎从新到达的推文重新开始，因此需要5分钟才能计数为“处于状态”。 我已经尝试
-
为什么实际主题中的偏移值与同一主题中的偏移值不同？PFB偏移位置以及使用的命令。 我错过了什么？
-
问题描述： 我们的Kafka consumer（在Spring Boot2.x中开发）正在执行几天。当我们重新启动这些消费者时，主题的所有消息都将被再次消费，但仅在特定条件下。 条件： 代理配置： 谢谢和问候
-
问题内容： 是否可以跳过X个第一行，并在一个查询中选择所有其他行？像那样： 它将选择：pqr，stu，vwx，yz 我尝试使用LIMIT和OFFSET完成此操作，但是问题是表是动态的，而且我不知道应该输入哪个LIMIT（我不知道表中有多少行）。 问题答案： 如果只需要最后N行，请尝试以下操作： 这会根据的顺序为您提供最后几条记录。 您可以使用自动递增的主键（希望有一个主键）来确定行的顺序（如果无法
-
我想避免的是JMeter的常规工作方式，即每个线程基本上一个接一个地触发一个请求。 背景：我们已经有了一个工具来创建这种剧本，它是一种模拟用户行为的非常现实的方式。我们现在正在评估是否可以使用JMeter来执行它们。
-
我有一个Kafka消费者，我从它消费数据从一个特定的主题，我看到下面的例外。我使用的是Kafka版本。 我添加了这两个额外的消费者属性，但仍然没有帮助： 那个错误意味着什么？我该如何解决它？我需要添加一些其他消费者属性吗？