@Experimental public class ElasticsearchStore extends ExtensibleStore<org.eclipse.rdf4j.sail.elasticsearchstore.ElasticsearchDataStructure,org.eclipse.rdf4j.sail.elasticsearchstore.ElasticsearchNamespaceStore>
An RDF4J SailStore persisted to Elasticsearch.
This is an EXPERIMENTAL feature. Use at your own risk!
There is no write-ahead logging, so a failure during a transaction may result in partially persisted changes.
dataStructure, namespaceStore, sailStoreconnectionTimeOut, DEFAULT_CONNECTION_TIMEOUT, DEFAULT_ITERATION_SYNC_THRESHOLD, initializationLock| Constructor and Description |
|---|
ElasticsearchStore(org.eclipse.rdf4j.sail.elasticsearchstore.ClientProvider clientPool,
String index) |
ElasticsearchStore(org.eclipse.rdf4j.sail.elasticsearchstore.ClientProvider clientPool,
String index,
boolean cacheEnabled) |
ElasticsearchStore(org.elasticsearch.client.Client client,
String index) |
ElasticsearchStore(org.elasticsearch.client.Client client,
String index,
boolean cacheEnabled) |
ElasticsearchStore(String hostname,
int port,
String clusterName,
String index) |
ElasticsearchStore(String hostname,
int port,
String clusterName,
String index,
boolean cacheEnabled) |
| Modifier and Type | Method and Description |
|---|---|
String |
getClusterName() |
protected NotifyingSailConnection |
getConnectionInternal()
Returns a store-specific SailConnection object.
|
ExtensibleStatementHelper |
getExtensibleStatementHelper() |
String |
getHostname() |
String |
getIndex() |
int |
getPort() |
protected void |
initializeInternal()
Do store-specific operations to initialize the store.
|
boolean |
isWritable()
Checks whether this Sail object is writable, i.e.
|
void |
setElasticsearchBulkSize(int size) |
void |
setElasticsearchScrollTimeout(int timeout) |
protected void |
shutDownInternal()
Do store-specific operations to ensure proper shutdown of the store.
|
void |
waitForElasticsearch(int time,
java.time.temporal.TemporalUnit timeUnit) |
getDefaultIsolationLevel, getEvaluationStatisticsType, getEvaluationStrategyFactory, getFederatedServiceResolver, getSupportedIsolationLevels, getValueFactory, setEvaluationStrategyFactory, setFederatedServiceResolveraddSailChangedListener, getConnection, notifySailChanged, removeSailChangedListeneraddSupportedIsolationLevel, connectionClosed, debugEnabled, getDataDir, getIterationCacheSyncThreshold, init, initialize, isInitialized, isTrackResultSize, removeSupportedIsolationLevel, setConnectionTimeOut, setDataDir, setDefaultIsolationLevel, setIterationCacheSyncThreshold, setSupportedIsolationLevels, setSupportedIsolationLevels, setTrackResultSize, shutDown, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetDataDir, init, initialize, setDataDir, shutDownpublic ElasticsearchStore(String hostname, int port, String clusterName, String index)
public ElasticsearchStore(String hostname, int port, String clusterName, String index, boolean cacheEnabled)
public ElasticsearchStore(org.eclipse.rdf4j.sail.elasticsearchstore.ClientProvider clientPool,
String index)
public ElasticsearchStore(org.eclipse.rdf4j.sail.elasticsearchstore.ClientProvider clientPool,
String index,
boolean cacheEnabled)
public ElasticsearchStore(org.elasticsearch.client.Client client,
String index)
public ElasticsearchStore(org.elasticsearch.client.Client client,
String index,
boolean cacheEnabled)
protected void initializeInternal()
throws SailException
AbstractSailinitializeInternal in class ExtensibleStore<org.eclipse.rdf4j.sail.elasticsearchstore.ElasticsearchDataStructure,org.eclipse.rdf4j.sail.elasticsearchstore.ElasticsearchNamespaceStore>SailExceptionprotected void shutDownInternal()
throws SailException
AbstractSailshutDownInternal in class ExtensibleStore<org.eclipse.rdf4j.sail.elasticsearchstore.ElasticsearchDataStructure,org.eclipse.rdf4j.sail.elasticsearchstore.ElasticsearchNamespaceStore>SailExceptionpublic void waitForElasticsearch(int time,
java.time.temporal.TemporalUnit timeUnit)
public void setElasticsearchScrollTimeout(int timeout)
protected NotifyingSailConnection getConnectionInternal() throws SailException
AbstractSailgetConnectionInternal in class AbstractNotifyingSailSailExceptionpublic boolean isWritable()
throws SailException
SailSailExceptionpublic String getHostname()
public int getPort()
public String getClusterName()
public String getIndex()
public void setElasticsearchBulkSize(int size)
public ExtensibleStatementHelper getExtensibleStatementHelper()
getExtensibleStatementHelper in class ExtensibleStore<org.eclipse.rdf4j.sail.elasticsearchstore.ElasticsearchDataStructure,org.eclipse.rdf4j.sail.elasticsearchstore.ElasticsearchNamespaceStore>Copyright © 2015-2022 Eclipse Foundation. All Rights Reserved.