I would also at least overload the `CassandraPojoInputFormat` constructor with additional parameter which is a factory for `Mapper<OUT>` because now it is hidden in the internals of this class but users might want to configure it in a special way (e.g. `Mapper.setDefaultSaveOptions(...)`), similar to `ClusterBuilder`.
[ Full content available at: https://github.com/apache/flink/pull/5876 ] This message was relayed via gitbox.apache.org for [email protected]
