org.jberet.support.io

Class CassandraReaderWriterBase

java.lang.Object

org.jberet.support.io.CassandraReaderWriterBase

Direct Known Subclasses:

CassandraBatchlet, CassandraItemReader, CassandraItemWriter

public abstract class CassandraReaderWriterBase
extends Object

The base class for CassandraItemReader, CassandraItemWriter and CassandraBatchlet.

Since:

1.3.0

See Also:

CassandraItemReader, CassandraItemWriter, CassandraBatchlet

Field Summary

Fields

Modifier and Type	Field and Description
protected Class	beanType For ItemReader, it's the java type that each data item should be converted to; for ItemWriter, it's the java type for each incoming data item.
protected com.datastax.driver.core.Cluster	cluster
protected javax.enterprise.inject.Instance<com.datastax.driver.core.Cluster>	clusterInstance This field holds an optional injection of com.datastax.driver.core.Cluster.
protected Map<String,String>	clusterProperties Additional properties for the Cassandra cluster
protected List<String>	contactPoints Cassandra contact points
protected String	cql The CQL statement for reading data from, or inserting data into Cassandra.
protected List<com.datastax.driver.core.TypeCodec>	customCodecList
protected List<String>	customCodecs Custom codec's for converting between CQL values and Java objects
protected String	keyspace
protected String	password Password for the Cassandra connection
protected PropertyDescriptor[]	propertyDescriptors
protected com.datastax.driver.core.Session	session
protected boolean	sessionCreated
protected javax.enterprise.inject.Instance<com.datastax.driver.core.Session>	sessionInstance This field holds an optional injection of com.datastax.driver.core.Session.
protected String	user User name for the Cassandra connection

Constructor Summary

Constructors

Constructor and Description
CassandraReaderWriterBase()

Method Summary

Modifier and Type	Method and Description
protected void	applyClusterProperties(com.datastax.driver.core.Cluster.Builder clusterBuilder)
void	close()
protected void	initBeanPropertyDescriptors()
protected void	initCustomCodecs()
protected void	initSession()

Methods inherited from class java.lang.Object

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

Field Detail

clusterInstance

@Inject
protected javax.enterprise.inject.Instance<com.datastax.driver.core.Cluster> clusterInstance

This field holds an optional injection of com.datastax.driver.core.Cluster. The application may implement a javax.enterprise.inject.Produces method to satisfy this dependency injection.

sessionInstance

@Inject
protected javax.enterprise.inject.Instance<com.datastax.driver.core.Session> sessionInstance

This field holds an optional injection of com.datastax.driver.core.Session. The application may implement a javax.enterprise.inject.Produces method to satisfy this dependency injection.

cql

@Inject
protected String cql

The CQL statement for reading data from, or inserting data into Cassandra. When used in CassandraItemWriter, its value should include parameter markers that will be filled in with real data. When used in CassandraBatchlet, its value may be one cql statement, or multiple cql statements grouped into a cql batch group.

beanType

@Inject
protected Class beanType

For ItemReader, it's the java type that each data item should be converted to; for ItemWriter, it's the java type for each incoming data item. In either case, the valid values are:

• a custom java type that represents data item;
• java.util.Map
• java.util.List

This property is not used in CassandraBatchlet.

contactPoints

@Inject
protected List<String> contactPoints

Cassandra contact points

keyspace

@Inject
protected String keyspace

user

@Inject
protected String user

User name for the Cassandra connection

password

@Inject
protected String password

Password for the Cassandra connection

clusterProperties

@Inject
protected Map<String,String> clusterProperties

Additional properties for the Cassandra cluster

customCodecs

@Inject
protected List<String> customCodecs

Custom codec's for converting between CQL values and Java objects

cluster

protected com.datastax.driver.core.Cluster cluster

session

protected com.datastax.driver.core.Session session

sessionCreated

protected boolean sessionCreated

propertyDescriptors

protected PropertyDescriptor[] propertyDescriptors

customCodecList

protected List<com.datastax.driver.core.TypeCodec> customCodecList

Constructor Detail

CassandraReaderWriterBase

public CassandraReaderWriterBase()

Method Detail

initSession

protected void initSession()
                    throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Throws:

Exception

applyClusterProperties

protected void applyClusterProperties(com.datastax.driver.core.Cluster.Builder clusterBuilder)
                               throws Exception

Throws:

Exception

initBeanPropertyDescriptors

protected void initBeanPropertyDescriptors()
                                    throws IntrospectionException

Throws:

IntrospectionException

initCustomCodecs

protected void initCustomCodecs()
                         throws IllegalAccessException,
                                InstantiationException,
                                ClassNotFoundException

Throws:

IllegalAccessException

InstantiationException

ClassNotFoundException