Package cz.o2.proxima.direct.core

Interface DataAccessor

All Superinterfaces:

AbstractDataAccessor, java.io.Serializable

All Known Implementing Classes:

BlobStorageAccessor, CassandraDBAccessor, ElasticsearchAccessor, HadoopDataAccessor, HBaseDataAccessor, HttpAccessor, HttpWriter, JdbcDataAccessor, KafkaAccessor, OpenTsdbWriter, PubSubAccessor

@Internal
public interface DataAccessor
extends AbstractDataAccessor

Interface providing various types of data access patterns to storage.

Method Summary

Modifier and Type	Method	Description
default java.util.Optional<BatchLogReader>	getBatchLogReader(Context context)	Retrieve batch log reader.
default java.util.Optional<CachedView>	getCachedView(Context context)	Retrieve cached view of the data.
default java.util.Optional<CommitLogReader>	getCommitLogReader(Context context)	Retrieve commit log reader (if applicable).
default java.util.Optional<RandomAccessReader>	getRandomAccessReader(Context context)	Retrieve random access reader.
default java.util.Optional<AttributeWriterBase>	getWriter(Context context)	Retrieve writer (if applicable).
default boolean	isAcceptable(AttributeFamilyDescriptor familyDescriptor)	Check whether this accessor is acceptable for a given family.

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

getUri

Method Detail

getWriter

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

Retrieve writer (if applicable).

Parameters:

context - the serializable context provided by repository

Returns:

optional AttributeWriterBase of this accessor

getCommitLogReader

default java.util.Optional<CommitLogReader> getCommitLogReader(Context context)

Retrieve commit log reader (if applicable).

Parameters:

context - serializable context provided by repository

Returns:

optional @{link CommitLogReader} of this accessor

getRandomAccessReader

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

Retrieve random access reader.

Parameters:

context - serializable context provided by repository

Returns:

optional RandomAccessReader of this accessor

getBatchLogReader

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

Retrieve batch log reader.

Parameters:

context - serializable context provided by repository

Returns:

optional BatchLogReader of this accessor

getCachedView

default java.util.Optional<CachedView> getCachedView(Context context)

Retrieve cached view of the data.

Parameters:

context - serializable context provided by repository

Returns:

optional CachedView of this accessor

isAcceptable

default boolean isAcceptable(AttributeFamilyDescriptor familyDescriptor)

Check whether this accessor is acceptable for a given family.

Parameters:

familyDescriptor - Attribute family descriptor.

Returns:

True if this accessor is acceptable.