tencent cloud

Stream Compute Service

Releases Notes and Announcements
Release Notes
Product Introduction
Overview
Strengths
Use Cases
Purchase Guide
Billing Overview
Billing Mode
Refund
Configuration Adjustments
Getting Started
Preparations
Creating a Private Cluster
Creating a SQL Job
Creating a JAR Job
Creating an ETL Job
Creating a Python Job
Operation Guide
Managing Jobs
Developing Jobs
Monitoring Jobs
Job Logs
Events and Diagnosis
Managing Metadata
Managing Checkpoints
Tuning Jobs
Managing Dependencies
Managing Clusters
Managing Permissions
SQL Developer Guide
Overview
Glossary and Data Types
DDL Statements
DML Statements
Merging MySQL CDC Sources
Connectors
SET Statement
Operators and Built-in Functions
Identifiers and Reserved Words
Python Developer Guide
ETL Developer Guide
Overview
Glossary
Connectors
FAQ
Contact Us

Elasticsearch Sinks

PDF
Modo Foco
Tamanho da Fonte
Última atualização: 2023-11-08 16:20:45

Overview

An Elasticsearch data sink can write data to Elasticsearch.
Note
Currently, Elasticsearch data sinks only support Elasticsearch 6 and Elasticsearch 7.

Mapping of common data types

For the data types supported by Elasticsearch, see Elasticsearch Data ‍Types. The table below lists some of the common data types and their counterparts in Flink.
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)
Note
Data types not listed in the above table are not supported currently.

Notes

Primary key

A primary key is required for Elasticsearch. The field set as the primary key will be written into _id, and data with the same ID will be overwritten.

Version differences

Please note that if you use Elasticsearch 6, you need to configure document-type. This is not necessary with Elasticsearch 7.

WITH parameters

Elasticsearch data sinks are developed based on the data analytics engine Elasticsearch. The two have identical WITH parameters. For details, see Elasticsearch Service.

Ajuda e Suporte

Esta página foi útil?

comentários