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`


---

Reply via email to