alpinegizmo commented on a change in pull request #16125:
URL: https://github.com/apache/flink/pull/16125#discussion_r649157510
##########
File path: docs/content/docs/connectors/datastream/cassandra.md
##########
@@ -105,7 +105,7 @@ More details on [checkpoints docs]({{< ref
"docs/dev/datastream/fault-tolerance/
## Examples
-The Cassandra sinks currently support both Tuple and POJO data types, and
Flink automatically detects which type of input is used. For general use case
of those streaming data type, please refer to [Supported Data Types]({{< ref
"docs/dev/serialization/types_serialization" >}}#supported-data-types). We show
two implementations based on
[SocketWindowWordCount](https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java),
for Pojo and Tuple data types respectively.
+The Cassandra sinks currently support both Tuple and POJO data types, and
Flink automatically detects which type of input is used. For general use case
of those streaming data type, please refer to [Supported Data Types]({{< ref
"docs/dev/datastream/fault-tolerance/serialization/types_serialization"
>}}#supported-data-types). We show two implementations based on
[SocketWindowWordCount](https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java),
for Pojo and Tuple data types respectively.
Review comment:
Grammatically the existing wording bothers me. Let's fix it while we're
here:
```suggestion
The Cassandra sink currently supports both Tuple and POJO data types, and
Flink automatically detects which type of input is used. For general use of
those streaming data types, please refer to [Supported Data Types]({{< ref
"docs/dev/datastream/fault-tolerance/serialization/types_serialization"
>}}#supported-data-types). We show two implementations based on
[SocketWindowWordCount](https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java),
for POJO and Tuple data types respectively.
```
##########
File path: docs/content.zh/docs/connectors/datastream/cassandra.md
##########
@@ -105,7 +105,7 @@ More details on [checkpoints docs]({{< ref
"docs/dev/datastream/fault-tolerance/
## Examples
-The Cassandra sinks currently support both Tuple and POJO data types, and
Flink automatically detects which type of input is used. For general use case
of those streaming data type, please refer to [Supported Data Types]({{< ref
"docs/dev/serialization/types_serialization" >}}#supported-data-types). We show
two implementations based on
[SocketWindowWordCount](https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java),
for Pojo and Tuple data types respectively.
+The Cassandra sinks currently support both Tuple and POJO data types, and
Flink automatically detects which type of input is used. For general use case
of those streaming data type, please refer to [Supported Data Types]({{< ref
"docs/dev/datastream/fault-tolerance/serialization/types_serialization"
>}}#supported-data-types). We show two implementations based on
[SocketWindowWordCount](https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java),
for Pojo and Tuple data types respectively.
Review comment:
Grammatically the existing wording bothers me. Let's fix it while we're
here:
```suggestion
The Cassandra sink currently supports both Tuple and POJO data types, and
Flink automatically detects which type of input is used. For general use of
those streaming data types, please refer to [Supported Data Types]({{< ref
"docs/dev/datastream/fault-tolerance/serialization/types_serialization"
>}}#supported-data-types). We show two implementations based on
[SocketWindowWordCount](https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java),
for POJO and Tuple data types respectively.
```
--
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]
