Package org.elasticsearch.xpack.esql.datasources.dataset

Class DatasetService

java.lang.Object

org.elasticsearch.xpack.esql.datasources.dataset.DatasetService

public class DatasetService
extends Object

Orchestrates create / replace / delete of datasets in cluster state.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ClusterService	clusterService
static final Setting<Integer>	MAX_DATASETS_COUNT_SETTING

Constructor Summary

Constructors

Constructor	Description
DatasetService(ClusterService clusterService, Map<String,DataSourceValidator> validatorsByType)

Method Summary

Modifier and Type	Method	Description
void	deleteDatasets(ProjectId projectId, TimeValue masterNodeTimeout, TimeValue ackTimeout, Collection<String> names, ActionListener<AcknowledgedResponse> listener)	Delete datasets by name.
protected DatasetMetadata	getMetadata(ProjectMetadata projectMetadata)
void	putDataset(ProjectId projectId, PutDatasetAction.Request request, ActionListener<AcknowledgedResponse> listener)	Create or replace a dataset.

Methods inherited from class java.lang.Object

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

Field Details

MAX_DATASETS_COUNT_SETTING

public static final Setting<Integer> MAX_DATASETS_COUNT_SETTING

clusterService

protected final ClusterService clusterService

Constructor Details

DatasetService

public DatasetService(ClusterService clusterService,
 Map<String,DataSourceValidator> validatorsByType)

Method Details

getMetadata

protected DatasetMetadata getMetadata(ProjectMetadata projectMetadata)

putDataset

public void putDataset(ProjectId projectId,
 PutDatasetAction.Request request,
 ActionListener<AcknowledgedResponse> listener)

Create or replace a dataset. Validation is expected to have run on the coordinator (via validatePutDataset(org.elasticsearch.cluster.metadata.ProjectMetadata, org.elasticsearch.xpack.esql.datasources.dataset.PutDatasetAction.Request)); the task re-validates under CAS to guard against the parent being delete-recreated between coord-validate and task-execute.

deleteDatasets

public void deleteDatasets(ProjectId projectId,
 TimeValue masterNodeTimeout,
 TimeValue ackTimeout,
 Collection<String> names,
 ActionListener<AcknowledgedResponse> listener)

Delete datasets by name. Fails with 404 if any name doesn't exist.