开发者社区 问答 正文

Scan 语法是如何定义的?

Scan 语法是如何定义的?

展开
收起
迪哒迪滴喵 2024-08-27 15:31:35 53 分享 版权
2 条回答
写回答
取消 提交回答
  • Scan 语法定义为两段式:{Index Query} | {Scan Query: where },其中管道符后面跟随的是 SQL 语法中的 where 子句。

    2024-08-27 17:05:32
    赞同 2 展开评论
  • 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概述

    2024-08-27 16:23:02
    赞同 4 展开评论
问答地址: