QueryCassandra
描述:
基于Cassandra 1.x, 2.x, 或 3.0.x版本集群模式下执行CQL查询语句(Cassandra Query Language)。查询结果可被转换为Avro或JSON格式。 由于平台是基于流式处理，所以也就支持大数据量结果的输出。 输出数据流属性'executecql.row.count'表示有多少结果被查询并输出
标签:
cassandra, cql, select, 查询
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 参数还支持 表达式语言, 并且 如果将一个参数认定为"敏感", 表示是加密状态. 在输入一个敏感参数时, 确保 orchsym.properties 文件中存在属性设置 orchsym.sensitive.props.key.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| Cassandra节点 | 指定Cassandra节点的地址。如果是列表，通过英文逗号分隔，且格式为hostname:port。 比如： node1:port,node2:port,.... 默认的Cassandra客户端端口为9042，但是端口必须在此显式指定 支持表达式语言 (仅支持变量) | ||
| 键空间 | 指定用于连接Cassandra的键空间，如果不指定，则语句引用表中需要包含键空间名字 支持表达式语言 (仅支持变量) | ||
| SSL服务 | 控制器服务API: SSLContextService 实现: StandardRestrictedSSLContextService StandardSSLContextService | 用于为TLS/SSL连接提供客户端证书信息的SSL服务 | |
| 客户端认证 | 必须 | - 请求 - 必须 - 不需要 | 连接到安全（TLS/SSL）群集时的客户端身份验证策略。 该参数仅当启用SSL服务时有用。 |
| 用户名 | 用于访问Cassandra集群的用户名 支持表达式语言 (仅支持变量) | ||
| 密码 | 用于访问Cassandra集群的用户名密码 敏感状态 支持表达式语言 (仅支持变量) | ||
| 一致性策略 | ONE | - ANY - ONE - TWO - THREE - QUORUM - ALL - LOCAL_QUORUM - EACH_QUORUM - SERIAL - LOCAL_SERIAL - LOCAL_ONE | 指定返回结果之前必须响应多少副本的策略 |
| 字符编码 | UTF-8 | 指定记录数据的字符集编码 支持表达式语言 (支持流属性和变量) | |
| 查询语句 | 指定CQL查询语句 支持表达式语言 (支持流属性和变量) | ||
| 等待时长 | 0 seconds | 运行CQL查询语句的超时时长。 必须是时间单元格式：<duration> <TimeUnit> ， <duration>为正整数，TimeUnit指定为诸如： nanos, millis, secs, mins, hrs, days. 如果设置0，表示没有限制支持表达式语言 (支持流属性和变量) | |
| 批量大小 | 0 | 指定每次从结果集读取的数据行数，0表示不限制 支持表达式语言 (仅支持变量) | |
| 输出格式 | Avro | - Avro - JSON | 数据结果输出需要被转换的格式。如果是JSON，则对象中字段'results'包含查询结果的数组对象。每个输出数据结果则为一个JSON对象。 比如: { "results": [{"userid":1, "name":"Joe Smith"}]} |
连线:
| 名字 | 描述 |
|---|---|
| retry | 如果语句无法成功执行，但再次尝试该操作可能会成功，则数据流将输出到此连线 |
| success | CQL查询语句成功输出结果到此连线 |
| failure | CQL查询语句执行失败则输出到此连线 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| executecql.row.count | CQL查询结果的数据行数 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件允许提供输入流。
系统资源考量:
未提供。