org.jberet.support.io

Class CassandraBatchlet

java.lang.Object

org.jberet.support.io.CassandraReaderWriterBase

org.jberet.support.io.CassandraBatchlet

All Implemented Interfaces:

javax.batch.api.Batchlet

@Named
 @Dependent
public class CassandraBatchlet
extends CassandraReaderWriterBase
implements javax.batch.api.Batchlet

A batchlet that executes one cql statement, or multiple cql statements grouped into one cql batch.

Since:

1.3.0

See Also:

CassandraItemReader, CassandraItemWriter, CassandraReaderWriterBase

Field Summary

Fields inherited from class org.jberet.support.io.CassandraReaderWriterBase

beanType, cluster, clusterInstance, clusterProperties, contactPoints, cql, customCodecList, customCodecs, keyspace, password, propertyDescriptors, session, sessionCreated, sessionInstance, user

Constructor Summary

Constructors

Constructor and Description
CassandraBatchlet()

Method Summary

Modifier and Type	Method and Description
String	process() This method executes the cql statement(s) as specified in CassandraReaderWriterBase.cql batch property, and returns the string representation of the first row in the result set.
void	stop() This method does nothing.

Methods inherited from class org.jberet.support.io.CassandraReaderWriterBase

applyClusterProperties, close, initBeanPropertyDescriptors, initCustomCodecs, initSession

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CassandraBatchlet

public CassandraBatchlet()

Method Detail

process

public String process()
               throws Exception

This method executes the cql statement(s) as specified in CassandraReaderWriterBase.cql batch property, and returns the string representation of the first row in the result set. For certain mutation cql statements (e.g., update, insert, delete), the underlying driver does not return any row, and so the return value of this method will also be null.

Specified by:

process in interface javax.batch.api.Batchlet

Throws:

Exception

stop

public void stop()
          throws Exception

This method does nothing.

Specified by:

stop in interface javax.batch.api.Batchlet

Throws:

Exception