ES
所有文档

          百度流式计算 BSC

          ES

          ES DDL

          CREATE TABLE sink_es_table (
              `field01` STRING,
              `field02` BIGINT,
              `field03` FLOAT,
              `field04` BINARY,
              `field05` INT,
              `field06` TINYINT,
              `field07` BOOLEAN,
              `field08` DATA,
              `field09` DOUBLE,
              `field10` SMALLINT
          ) WITH (
              'connector.type' = 'ES',
              'connector.version' = '6.5.3',
              'connector.cluster-id' = 'xxxxxxxxxxxxx',
              'connector.host'  = '192.168.11.208',
              'connector.port'  = '8200',
              'connector.index' = 'bsc_test',
              'connector.document-type' = 'doc_type',
              'connector.username' = 'superuser',
              'connector.password' = 'bsc_1234'
          );

          ES 参数设置

          名称 简称 是否必填 用例 SPARK FLINK 说明
          connector.type type Y ES Y Y 服务类型
          connector.version version 6.5.3 Y ES 集群版本
          connector.cluster-id cluster-id Y xxxxxxxxxxx Y Y ES 集群ID
          connector.host host Y 192.168.11.208 Y Y ES 集群机器
          connector.port port Y 8200 Y Y ES 集群端口
          connector.index index Y bsc_test Y Y ES 创建的索引名称
          connector.document-type document-type Y doc_type Y Y ES 创建的索引类型
          connector.username username Y superuser Y Y ES 用户名称
          connector.password password Y bsc_1234 Y Y ES 用户密码
          上一篇
          Formats
          下一篇
          BOS