我正在使用运行星火集群。我想使用自定义查询从大查询中获取数据。我能够运行基本单词计数示例,但我正在寻找一种运行自定义查询的方法。
SELECT ROW_NUMBER() OVER() as Id, prop11 FROM (
SELECT prop11 FROM (
TABLE_DATE_RANGE([mapping.abc_v2_], DATE_ADD(CURRENT_TIMESTAMP(), -1, 'MONTH'), CURRENT_TIMESTAMP())
) WHERE (prop11 IS NOT null AND prop11 !="") GROUP EACH BY prop11
)
我们在hadoop连接器中有Java吗?
发布于 2016-04-20 17:57:39
目前,用于Hadoop的BigQuery连接器没有执行BigQuery查询的支持机制。
如果您的查询可以表示为Spark或Spark,则可以使用从BigQuery到GCS的导出(当前的BigQuery Hadoop工作流),然后使用Spark生成最终结果。
https://stackoverflow.com/questions/36749550
复制相似问题