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
int	getBatchSize()
int	getBulkSizeMb()
java.util.Map<java.lang.String,java.lang.Object>	getCfg()
java.util.Optional<CommitLogReader>	getCommitLogReader(Context context)	Retrieve commit log reader (if applicable).
int	getConcurrentRequests()
int	getConnectionRequestTimeoutMs()
int	getConnectTimeoutMs()
DocumentFormatter	getDocumentFormatter()
cz.o2.proxima.elasticsearch.shaded.org.elasticsearch.core.TimeValue	getFlushInterval()
java.lang.String	getIndexName()
java.lang.String	getKeystorePassword()
java.lang.String	getKeystorePath()
java.lang.String	getKeystoreType()
cz.o2.proxima.elasticsearch.shaded.org.elasticsearch.client.RestHighLevelClient	getRestHighLevelClient()
java.lang.String	getScheme()
int	getSocketTimeoutMs()
java.lang.String	getTruststorePassword()
java.lang.String	getTruststorePath()
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, getEntityDescriptor, getUri, 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()

getCfg

public java.util.Map<java.lang.String,java.lang.Object> getCfg()

getScheme

public java.lang.String getScheme()

getIndexName

public java.lang.String getIndexName()

getConnectTimeoutMs

public int getConnectTimeoutMs()

getConnectionRequestTimeoutMs

public int getConnectionRequestTimeoutMs()

getSocketTimeoutMs

public int getSocketTimeoutMs()

getConcurrentRequests

public int getConcurrentRequests()

getBatchSize

public int getBatchSize()

getKeystoreType

public java.lang.String getKeystoreType()

getKeystorePath

public java.lang.String getKeystorePath()

getKeystorePassword

public java.lang.String getKeystorePassword()

getTruststorePath

public java.lang.String getTruststorePath()

getTruststorePassword

public java.lang.String getTruststorePassword()

getDocumentFormatter

public DocumentFormatter getDocumentFormatter()

getBulkSizeMb

public int getBulkSizeMb()