Package co.elastic.clients.elasticsearch.core.reindex

Class Source

java.lang.Object

co.elastic.clients.elasticsearch.core.reindex.Source

All Implemented Interfaces:

JsonpSerializable

@JsonpDeserializable
public class Source
extends Object
implements JsonpSerializable

See Also:

• API specification

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	Description
final List<String>	index()	Required - The name of the data stream, index, or alias you are copying from.
static Source	of(Function<Source.Builder,ObjectBuilder<Source>> fn)
final Query	query()	Specifies the documents to reindex using the Query DSL.
final RemoteSource	remote()	A remote instance of Elasticsearch that you want to index from.
final Map<String,RuntimeField>	runtimeMappings()	API name: runtime_mappings
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	setupSourceDeserializer(ObjectDeserializer<Source.Builder> op)
final Integer	size()	The number of documents to index per batch.
final SlicedScroll	slice()	Slice the reindex request manually using the provided slice ID and total number of slices.
final List<SortOptions>	sort()	API name: sort
final List<String>	sourceFields()	If true reindexes all source fields.
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<Source> _DESERIALIZER

Json deserializer for Source

Method Details

of

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

index

public final List<String> index()

Required - The name of the data stream, index, or alias you are copying from. Accepts a comma-separated list to reindex from multiple sources.

API name: index

query

@Nullable
public final Query query()

Specifies the documents to reindex using the Query DSL.

API name: query

remote

@Nullable
public final RemoteSource remote()

A remote instance of Elasticsearch that you want to index from.

API name: remote

size

@Nullable
public final Integer size()

The number of documents to index per batch. Use when indexing from remote to ensure that the batches fit within the on-heap buffer, which defaults to a maximum size of 100 MB.

API name: size

slice

@Nullable
public final SlicedScroll slice()

Slice the reindex request manually using the provided slice ID and total number of slices.

API name: slice

sort

public final List<SortOptions> sort()

API name: sort

sourceFields

public final List<String> sourceFields()

If true reindexes all source fields. Set to a list to reindex select fields.

API name: _source

runtimeMappings

public final Map<String,RuntimeField> runtimeMappings()

API name: runtime_mappings

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

setupSourceDeserializer

protected static void setupSourceDeserializer(ObjectDeserializer<Source.Builder> op)