Skip to main content

结果表

一、介绍​

Solr写入，目前只支持开启Kerberos的Solr数据源。

二、支持版本​

Solr 7.4

三、插件名称​

SQLsolr-x

四、参数说明​

1、SQL​

  • zk-hosts
    • 描述：Solr的zookeeper集群地址，每个节点用, 分割
    • 必选：是
    • 参数类型：string
    • 默认值：无
  • zk-chroot
    • 描述：Solr所在的Zookeeper chroot
    • 必选：否
    • 参数类型：string
    • 默认值：无
  • collection
    • 描述：Solr collection名称
    • 必选：是
    • 参数类型：string
    • 默认值：无
  • security.kerberos.principal
    • 描述：kerberos认证的principal
    • 必选：是
    • 默认值：无
  • security.kerberos.keytab
    • 描述：kerberos认证的keytab文件路径
    • 必选：是
    • 默认值：无
  • security.kerberos.krb5conf
    • 描述：kerberos认证的krb5conf文件路径
    • 必选：是
    • 默认值：无
  • sink.parallelism
    • 描述：sink并行度
    • 必选：是
    • 默认值：无
  • sink.buffer-flush.max-rows
    • 描述：批量写入条数
    • 必选：否
    • 默认值：无
  • sink.buffer-flush.interval
    • 描述：批量写入时间间隔：单位毫秒。
    • 必选：否
    • 默认值：无

五、数据类型​

支持bool
int
long
string
text
float
double
date
暂不支持array

六、脚本示例​


CREATE TABLE kafka_source
(
    val_bool   boolean,
    val_int    int,
    val_long   bigint,
    val_str    string,
    val_float  float,
    val_double double,
    val_date   timestamp
) WITH (
    'connector' = 'kafka-x',
    'topic' = 'luna',
    'properties.bootstrap.servers' = 'localhost:9092',
    'properties.group.id' = 'luna_g',
    'format' = 'json',
    'json.timestamp-format.standard' = 'SQL'
);

CREATE TABLE solr_sink
(
    val_bool   boolean,
    val_int    int,
    val_long   bigint,
    val_str    string,
    val_float  float,
    val_double double,
    val_date   timestamp
) WITH (
    'connector' = 'solr-x',
    'zk-hosts' = 'master:2181,worker:2181,tools:2181',
    'zk-chroot' = '/solr',
    'collection' = 'flink_dev',
    'krb5conf' = './krb5.conf',
    'keytab' = './solr.keytab',
    'principal' = 'solr/worker@DTSTACK.COM',
    'sink.parallelism' = '1',
    'sink.buffer-flush.max-rows' = '1',
    'sink.buffer-flush.interval' = '5000'
);

INSERT INTO solr_sink
SELECT *
FROM kafka_source;