CassandraItemReader, CassandraItemWriter & CassandraBatchlet have been implemented in jberet-support. They will be formally available in the up-comming jberet 1.3.0.Final release.
CassandraItemReader, CassandraItemWriter & CassandraBatchlet are similar to their counter-parties in jdbc: JdbcItemReader, JdbcItemWriter & JdbcBatchlet, except for the following main differences:
* cassandra artifacts have different configuration batch properties than jdbc ones;
* unlike jdbc ones, cassandra artifacts do not have any dependencies on Jackson library;
* cassandra artifacts and jdbc artifacts are completely independent of each other.
To use any of the above cassandra batch artifacts, the only additional dependency is the datastax driver:
<dependency>
<groupId>com.datastax.cassandra</groupId>
<artifactId>cassandra-driver-core</artifactId>
</dependency>
For usage examples, see the following test apps:
jsr352/test-apps/cassandraInject at master · jberet/jsr352 · GitHub
jsr352/CassandraReaderWriterTest.java at master · jberet/jsr352 · GitHub
jsr352/org.jberet.support.io.CassandraReaderTest.xml at master · jberet/jsr352 · GitHub
jsr352/org.jberet.support.io.CassandraWriterTest.xml at master · jberet/jsr352 · GitHub
jsr352/org.jberet.support.io.CassandraBatchletTest.xml at master · jberet/jsr352 · GitHub
For more info, see JIRA issues:
JBERET-374
Implement Cassandra Batch Item Reader and Writer
JBERET-379
Implement Cassandra Batchlet to Run Cassandra CQL
JBERET-386
Support custom codec in Cassandra item reader and writer
If you see any issues, please report them in JBeret JIRA, and any feedback and comments are also welcome!
