Scan 语法定义为两段式:{Index Query} | {Scan Query: where },其中管道符后面跟随的是 SQL 语法中的 where 子句。
SCAN语法是用于在EMR-3.23.0及后续版本的Spark SQL中定义数据源表的。它可以按批处理(BATCH)或流处理(STREAM)方式读取数据。基本语法如下:
CREATE SCAN tbName_alias
ON tbName
USING queryType
OPTIONS (propertyName=propertyValue[, propertyName=propertyValue]*)
queryType可以是BATCH或STREAM,OPTIONS用于设置数据源的参数。定义的视图只能作为数据源,不能用于输出。例如:
批处理示例:CREATE SCAN loghub_table_intput_test_batch
ON loghub_table_intput_test
USING BATCH;
流处理示例:CREATE SCAN loghub_table_intput_test_stream
ON loghub_table_intput_test
USING STREAM;
详细信息和示例可见Spark Streaming SQL的DDL概述。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。