klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] 
Translate Apache Cassandra Connector page into…
URL: https://github.com/apache/flink/pull/9188#discussion_r305619369
 
 

 ##########
 File path: docs/dev/connectors/cassandra.zh.md
 ##########
 @@ -130,9 +121,9 @@ CREATE TABLE IF NOT EXISTS example.wordcount (
 </div>
 
 ### Cassandra Sink Example for Streaming Tuple Data Type
-While storing the result with Java/Scala Tuple data type to a Cassandra sink, 
it is required to set a CQL upsert statement (via setQuery('stmt')) to persist 
each record back to the database. With the upsert query cached as 
`PreparedStatement`, each Tuple element is converted to parameters of the 
statement.
+在将结果通过 Java/Scala Tuple 数据类型存储到 Cassandra 接收器时,需要设置CQL upsert 语句(通过 
setQuery('stmt'))将每条记录保存回数据库。将 upsert 查询缓存为 `PreparedStatement` 时,每个 Tuple 
元素都将转换为语句的参数。
 
 Review comment:
   ```suggestion
   在将结果通过 Java/Scala Tuple 数据类型存储到 Cassandra 接收器时,需要设置 CQL upsert 语句(通过 
setQuery('stmt'))将每条记录保存回数据库。将 upsert 查询缓存为 `PreparedStatement` 时,每个 Tuple 
元素都将转换为语句的参数。
   ```

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to