介绍
Elasticsearch 数据目的表支持将数据写入到 Elasticsearch 中。
注意
Elasticsearch 数据目的表暂时只支持 Elasticsearch 6 或 Elasticsearch 7 版本。
常见数据类型映射
Flink 数据类型 | Elasticsearch 对应数据类型 |
text | STRING |
match_only_text | STRING |
binary | STRING |
keyword | STRING |
wildcard | STRING |
search_as_you_type | STRING |
ip | STRING |
short | SMALLINT |
integer | INT |
long | BIGINT |
unsigned_long | BIGINT |
float | FLOAT |
half_float | FLOAT |
double | DOUBLE |
boolean | BOOLEAN |
date | TIMESTAMP(3) |
date_nanos | TIMESTAMP(6) |
注意
暂时不支持上述表格没有提到的类型。
注意事项
主键说明
Elasticsearch 必须设置主键,设置为主键的字段会被写入到 _id 字段中,相同 ID 的数据会进行覆盖。
版本差异
Elasticsearch 6 版本与 Elasticsearch 7 版本在配置上有一些不同,Elasticsearch 6 版本需要配置 document-type 而 Elasticsearch 7 版本不需要。