What is the purpose of the change
Committing the new CassandraPojoInputFormat class. This works similarly to the
CassandraInputClass, but allows the data that is read from Cassandra to be
output as a custom POJO that the user has created whichhas been annotated using
Datastax API.
Brief change log
-Initial commit of the CassandraPojoInputFormat class and validation test.
Verifying this change
-CassandraPojoInputFormat can be validated with the
testCassandraBatchPojoFormat test in the CassandraConnectorITCaseTest.java file.
Does this pull request potentially affect one of the following parts:
Dependencies (does it add or upgrade a dependency): no
The public API, i.e., is any changed class annotated with
@Public(Evolving): no
The serializers: no
The runtime per-record code paths (performance sensitive): don't know
Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Yarn/Mesos, ZooKeeper: no
The S3 file system connector: no
Documentation
Does this pull request introduce a new feature? yes
If yes, how is the feature documented? JavaDocs
[ Full content available at: https://github.com/apache/flink/pull/6735 ]
This message was relayed via gitbox.apache.org for [email protected]
