PutCassandraQL

描述:

基于Cassandra 1.x, 2.x, 或 3.0.x版本集群模式下执行CQL语句(Cassandra Query Language)。输入数据流的内容将作为CQL命令语句执行。CQL命令可能带有问号“?”并作为参数，此种情况，参数依赖于输入数据流的属性且命名规则为“cql.args.N.type” 和 “cql.args.N.value”。且N为正整数序列。还有“cql.args.N.type”指定的是小写字符串的Cassandra类型

参数:

如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 参数还支持表达式语言, 并且如果将一个参数认定为"敏感", 表示是加密状态. 在输入一个敏感参数时, 确保 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		指定记录数据的字符集编码支持表达式语言 (支持流属性和变量)
等待时长	0 seconds		运行CQL查询语句的超时时长。必须是时间单元格式：`<duration> <TimeUnit>` ， `<duration>`为正整数，TimeUnit指定为诸如： nanos, millis, secs, mins, hrs, days. 如果设置0，表示没有限制支持表达式语言 (支持流属性和变量)

连线:

名字	描述
retry	如果语句无法成功执行，但再次尝试该操作可能会成功，则数据流将输出到此连线
success	成功执行CQL语句后的数据输出到此连线
failure	CQL语句执行失败后的数据输出到此连线

读取属性:

名字	描述
cql.args.N.type	作为CQL语句参数的输入数据流属性。每个类型为小写且对应于Cassandra数据类型，比如 (text, int, boolean, 等等)。对于集合的情况，集合中元素的主类型将包含集合类型和元素类型，且通过尖括号分隔，比如`set<text>` 或者 `map<timestamp, int>`。
cql.args.N.value	作为CQL语句参数的输入数据流属性。参数的值将诸如cql.args.1.value, cql.args.2.value, cql.args.3.value, 等等。则cql.args.1.value参数值所对应的数据类型参数为cql.args.1.type属性

写入属性:

未提供。

状态管理:

该组件不保存状态。

限制:

该组件没有限制

输入流要求:

组件必须提供输入流。

系统资源考量:

资源	描述
MEMORY	此组件的实例可能导致此系统资源的高使用率。多个实例或高并发性设置可能导致性能下降。

PutCassandraQL

描述:​

标签:​

参数:​

连线:​

读取属性:​

写入属性:​

状态管理:​

限制:​

输入流要求:​

系统资源考量:​

描述:

标签:

参数:

连线:

读取属性:

写入属性:

状态管理:

限制:

输入流要求:

系统资源考量: