org.nuxeo.elasticsearch.seqgen

Class ESUIDSequencer

java.lang.Object

org.nuxeo.ecm.core.uidgen.AbstractUIDSequencer

org.nuxeo.elasticsearch.seqgen.ESUIDSequencer

All Implemented Interfaces:

UIDSequencer

public class ESUIDSequencer
extends AbstractUIDSequencer

Elasticsearch implementation of UIDSequencer.

Since elasticsearch does not seem to support a notion of native sequence, the implementation uses the auto-increment of the version attribute as described in the ElasticSearch::Sequence - a blazing fast ticket server blog post.

Since:

7.3

Field Summary

Fields

Modifier and Type	Field and Description
protected org.elasticsearch.client.Client	esClient

Fields inherited from class org.nuxeo.ecm.core.uidgen.AbstractUIDSequencer

name

Constructor Summary

Constructors

Constructor and Description
ESUIDSequencer()

Method Summary

Modifier and Type	Method and Description
void	dispose() Cleanup callback
protected void	ensureESIndex(org.elasticsearch.client.Client esClient)
protected org.elasticsearch.client.Client	getClient()
protected String	getESIndexName()
int	getNext(String sequenceName) For the given key returns the incremented UID which is also stored in the same sequence entry.
void	init() Init Sequencer

Methods inherited from class org.nuxeo.ecm.core.uidgen.AbstractUIDSequencer

getName, initSequence, setName

Methods inherited from class java.lang.Object

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

Field Detail

esClient

protected org.elasticsearch.client.Client esClient

Constructor Detail

ESUIDSequencer

public ESUIDSequencer()

Method Detail

getClient

protected org.elasticsearch.client.Client getClient()

dispose

public void dispose()

Description copied from interface: UIDSequencer

Cleanup callback

Specified by:

dispose in interface UIDSequencer

Specified by:

dispose in class AbstractUIDSequencer

getNext

public int getNext(String sequenceName)

Description copied from interface: UIDSequencer

For the given key returns the incremented UID which is also stored in the same sequence entry. This is a "one time use" function for a document.

Specified by:

getNext in interface UIDSequencer

Specified by:

getNext in class AbstractUIDSequencer

Returns:

init

public void init()

Description copied from interface: UIDSequencer

Init Sequencer

Specified by:

init in interface UIDSequencer

Specified by:

init in class AbstractUIDSequencer

ensureESIndex

protected void ensureESIndex(org.elasticsearch.client.Client esClient)

getESIndexName

protected String getESIndexName()