Package cz.o2.proxima.direct.io.cassandra

Class CassandraDBAccessor

java.lang.Object

cz.o2.proxima.core.storage.AbstractStorage

cz.o2.proxima.core.storage.AbstractStorage.SerializableAbstractStorage

cz.o2.proxima.direct.io.cassandra.CassandraDBAccessor

All Implemented Interfaces:

AbstractDataAccessor, DataAccessor, java.io.Serializable

public class CassandraDBAccessor
extends AbstractStorage.SerializableAbstractStorage
implements DataAccessor

AttributeWriter for Apache Cassandra.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class cz.o2.proxima.core.storage.AbstractStorage

AbstractStorage.SerializableAbstractStorage

Constructor Summary

Constructors

Constructor	Description
CassandraDBAccessor(EntityDescriptor entityDesc, java.net.URI uri, java.util.Map<java.lang.String,java.lang.Object> cfg)

Method Summary

Modifier and Type	Method	Description
java.util.Optional<BatchLogReader>	getBatchLogReader(Context context)	Retrieve batch log reader.
java.util.Optional<RandomAccessReader>	getRandomAccessReader(Context context)	Retrieve random access reader.
java.util.Optional<AttributeWriterBase>	getWriter(Context context)	Retrieve writer (if applicable).

Methods inherited from class cz.o2.proxima.core.storage.AbstractStorage

equals, hashCode

Methods inherited from class java.lang.Object

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

Methods inherited from interface cz.o2.proxima.core.storage.internal.AbstractDataAccessor

getUri

Methods inherited from interface cz.o2.proxima.direct.core.DataAccessor

getCachedView, getCommitLogReader, isAcceptable

Constructor Detail

CassandraDBAccessor

public CassandraDBAccessor(EntityDescriptor entityDesc,
                           java.net.URI uri,
                           java.util.Map<java.lang.String,java.lang.Object> cfg)

Method Detail

getWriter

public java.util.Optional<AttributeWriterBase> getWriter(Context context)

Description copied from interface: DataAccessor

Retrieve writer (if applicable).

Specified by:

getWriter in interface DataAccessor

Parameters:

context - the serializable context provided by repository

Returns:

optional AttributeWriterBase of this accessor

getRandomAccessReader

public java.util.Optional<RandomAccessReader> getRandomAccessReader(Context context)

Description copied from interface: DataAccessor

Retrieve random access reader.

Specified by:

getRandomAccessReader in interface DataAccessor

Parameters:

context - serializable context provided by repository

Returns:

optional RandomAccessReader of this accessor

getBatchLogReader

public java.util.Optional<BatchLogReader> getBatchLogReader(Context context)

Description copied from interface: DataAccessor

Retrieve batch log reader.

Specified by:

getBatchLogReader in interface DataAccessor

Parameters:

context - serializable context provided by repository

Returns:

optional BatchLogReader of this accessor