Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168331011 --- 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 -- done
---