Package cz.o2.proxima.direct.io.elasticsearch

Class ElasticsearchAccessor

java.lang.Object

cz.o2.proxima.core.storage.AbstractStorage

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

cz.o2.proxima.direct.io.elasticsearch.ElasticsearchAccessor

All Implemented Interfaces:

AbstractDataAccessor, DataAccessor, java.io.Serializable

public class ElasticsearchAccessor
extends AbstractStorage.SerializableAbstractStorage
implements DataAccessor

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
ElasticsearchAccessor(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<CommitLogReader>	getCommitLogReader(Context context)	Retrieve commit log reader (if applicable).
cz.o2.proxima.elasticsearch.shaded.org.elasticsearch.core.TimeValue	getFlushInterval()
cz.o2.proxima.elasticsearch.shaded.org.elasticsearch.client.RestHighLevelClient	getRestHighLevelClient()
java.util.Optional<AttributeWriterBase>	getWriter(Context context)	Retrieve writer (if applicable).
static java.lang.String	parseIndexName(java.net.URI uri)

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

getBatchLogReader, getCachedView, getRandomAccessReader, isAcceptable

Constructor Detail

ElasticsearchAccessor

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

Method Detail

parseIndexName

public static java.lang.String parseIndexName(java.net.URI uri)

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

getCommitLogReader

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

Description copied from interface: DataAccessor

Retrieve commit log reader (if applicable).

Specified by:

getCommitLogReader in interface DataAccessor

Parameters:

context - serializable context provided by repository

Returns:

optional @{link CommitLogReader} of this accessor

getRestHighLevelClient

public cz.o2.proxima.elasticsearch.shaded.org.elasticsearch.client.RestHighLevelClient getRestHighLevelClient()

getFlushInterval

@Nullable
public cz.o2.proxima.elasticsearch.shaded.org.elasticsearch.core.TimeValue getFlushInterval()