Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5272#discussion_r168169354
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java
---
@@ -37,11 +36,11 @@
import java.io.IOException;
/**
- * OutputFormat to write {@link org.apache.flink.api.java.tuple.Tuple}
into Apache Cassandra.
+ * CassandraOutputFormat is the common abstract class for writing into
Apache Cassandra.
*
- * @param <OUT> type of Tuple
+ * @param <OUT> Type of the elements to write.
*/
-public class CassandraOutputFormat<OUT extends Tuple> extends
RichOutputFormat<OUT> {
+public abstract class CassandraOutputFormat<OUT> extends
RichOutputFormat<OUT> {
--- End diff --
Rename to `CassandraOutputFormatBase`
---
