Package co.elastic.clients.elasticsearch.indices

Class Translog

java.lang.Object

co.elastic.clients.elasticsearch.indices.Translog

All Implemented Interfaces:

JsonpSerializable

@JsonpDeserializable
public class Translog
extends Object
implements JsonpSerializable

See Also:

• API specification

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Translog.Builder	Builder for Translog.

Field Summary

Fields

Modifier and Type	Field	Description
static final JsonpDeserializer<Translog>	_DESERIALIZER	Json deserializer for Translog

Method Summary

Modifier and Type	Method	Description
final TranslogDurability	durability()	Whether or not to fsync and commit the translog after every index, delete, update, or bulk request.
final String	flushThresholdSize()	The translog stores all operations that are not yet safely persisted in Lucene (i.e., are not part of a Lucene commit point).
static Translog	of(Function<Translog.Builder,ObjectBuilder<Translog>> fn)
final TranslogRetention	retention()	API name: retention
void	serialize(jakarta.json.stream.JsonGenerator generator, JsonpMapper mapper)	Serialize this object to JSON.
protected void	serializeInternal(jakarta.json.stream.JsonGenerator generator, JsonpMapper mapper)
protected static void	setupTranslogDeserializer(ObjectDeserializer<Translog.Builder> op)
final Time	syncInterval()	How often the translog is fsynced to disk and committed, regardless of write operations.
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

_DESERIALIZER

public static final JsonpDeserializer<Translog> _DESERIALIZER

Json deserializer for Translog

Method Details

of

public static Translog of(Function<Translog.Builder,ObjectBuilder<Translog>> fn)

syncInterval

@Nullable
public final Time syncInterval()

How often the translog is fsynced to disk and committed, regardless of write operations. Values less than 100ms are not allowed.

API name: sync_interval

durability

@Nullable
public final TranslogDurability durability()

Whether or not to fsync and commit the translog after every index, delete, update, or bulk request.

API name: durability

flushThresholdSize

@Nullable
public final String flushThresholdSize()

The translog stores all operations that are not yet safely persisted in Lucene (i.e., are not part of a Lucene commit point). Although these operations are available for reads, they will need to be replayed if the shard was stopped and had to be recovered. This setting controls the maximum total size of these operations, to prevent recoveries from taking too long. Once the maximum size has been reached a flush will happen, generating a new Lucene commit point.

API name: flush_threshold_size

retention

@Nullable
public final TranslogRetention retention()

API name: retention

serialize

public void serialize(jakarta.json.stream.JsonGenerator generator,
 JsonpMapper mapper)

Serialize this object to JSON.

Specified by:

serialize in interface JsonpSerializable

serializeInternal

protected void serializeInternal(jakarta.json.stream.JsonGenerator generator,
 JsonpMapper mapper)

toString

public String toString()

Overrides:

toString in class Object

setupTranslogDeserializer

protected static void setupTranslogDeserializer(ObjectDeserializer<Translog.Builder> op)