Uses of Class
org.hibernate.search.engine.backend.work.execution.OperationSubmitter
-
-
Uses of OperationSubmitter in org.hibernate.search.backend.elasticsearch.orchestration.impl
Methods in org.hibernate.search.backend.elasticsearch.orchestration.impl with parameters of type OperationSubmitter Modifier and Type Method Description protected voidElasticsearchBatchingWorkOrchestrator. doSubmit(org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchBatchedWork<?> work, OperationSubmitter operationSubmitter)protected voidElasticsearchSimpleWorkOrchestrator. doSubmit(org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?> work, OperationSubmitter ignore)<T> CompletableFuture<T>ElasticsearchBatchingWorkOrchestrator. submit(IndexingWork<T> work, OperationSubmitter operationSubmitter)<T> CompletableFuture<T>ElasticsearchParallelWorkOrchestrator. submit(NonBulkableWork<T> work, OperationSubmitter operationSubmitter)default <T> voidElasticsearchSerialWorkOrchestrator. submit(CompletableFuture<T> future, IndexingWork<T> work, OperationSubmitter operationSubmitter)voidElasticsearchSerialWorkOrchestrator. submit(org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchBatchedWork<?> work, OperationSubmitter operationSubmitter)default <T> CompletableFuture<T>ElasticsearchSerialWorkOrchestrator. submit(IndexingWork<T> work, OperationSubmitter operationSubmitter)<T> CompletableFuture<T>ElasticsearchSimpleWorkOrchestrator. submit(NonBulkableWork<T> work, OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.backend.elasticsearch.schema.management.impl
Methods in org.hibernate.search.backend.elasticsearch.schema.management.impl with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<?>ElasticsearchIndexSchemaManager. createIfMissing(OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexSchemaManager. createOrUpdate(OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexSchemaManager. createOrValidate(ContextualFailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexSchemaManager. dropAndCreate(OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexSchemaManager. dropIfExisting(OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexSchemaManager. validate(ContextualFailureCollector failureCollector, OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.backend.elasticsearch.work.execution.impl
Methods in org.hibernate.search.backend.elasticsearch.work.execution.impl with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<?>ElasticsearchIndexIndexer. add(DocumentReferenceProvider referenceProvider, DocumentContributor documentContributor, DocumentCommitStrategy commitStrategy, DocumentRefreshStrategy refreshStrategy, OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexIndexer. addOrUpdate(DocumentReferenceProvider referenceProvider, DocumentContributor documentContributor, DocumentCommitStrategy commitStrategy, DocumentRefreshStrategy refreshStrategy, OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexIndexer. delete(DocumentReferenceProvider referenceProvider, DocumentCommitStrategy commitStrategy, DocumentRefreshStrategy refreshStrategy, OperationSubmitter operationSubmitter)CompletableFuture<MultiEntityOperationExecutionReport>ElasticsearchIndexIndexingPlan. executeAndReport(OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexWorkspace. flush(OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexWorkspace. mergeSegments(OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexWorkspace. purge(Set<String> routingKeys, OperationSubmitter operationSubmitter)CompletableFuture<?>ElasticsearchIndexWorkspace. refresh(OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.backend.lucene.index
Methods in org.hibernate.search.backend.lucene.index with parameters of type OperationSubmitter Modifier and Type Method Description CompletionStage<Long>LuceneIndexManager. computeSizeInBytesAsync(OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.backend.lucene.index.impl
Methods in org.hibernate.search.backend.lucene.index.impl with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<Long>LuceneIndexManagerImpl. computeSizeInBytesAsync(OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.backend.lucene.orchestration.impl
Methods in org.hibernate.search.backend.lucene.orchestration.impl with parameters of type OperationSubmitter Modifier and Type Method Description protected voidLuceneParallelWorkOrchestratorImpl. doSubmit(org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestratorImpl.WorkExecution<?> workExecution, OperationSubmitter operationSubmitter)protected voidLuceneSerialWorkOrchestratorImpl. doSubmit(LuceneBatchedWork<?> work, OperationSubmitter operationSubmitter)protected voidLuceneSyncWorkOrchestratorImpl. doSubmit(org.hibernate.search.backend.lucene.orchestration.impl.LuceneSyncWorkOrchestratorImpl.WorkExecution<?> work, OperationSubmitter operationSubmitter)<T> voidLuceneParallelWorkOrchestrator. submit(CompletableFuture<T> future, IndexManagementWork<T> work, OperationSubmitter operationSubmitter)default <T> CompletableFuture<T>LuceneParallelWorkOrchestrator. submit(IndexManagementWork<T> work, OperationSubmitter operationSubmitter)<T> voidLuceneParallelWorkOrchestratorImpl. submit(CompletableFuture<T> future, IndexManagementWork<T> work, OperationSubmitter operationSubmitter)default <T> voidLuceneSerialWorkOrchestrator. submit(CompletableFuture<T> future, IndexingWork<T> work, OperationSubmitter operationSubmitter)voidLuceneSerialWorkOrchestrator. submit(LuceneBatchedWork<?> work, OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.backend.lucene.schema.management.impl
Methods in org.hibernate.search.backend.lucene.schema.management.impl with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<Long>LuceneIndexSchemaManager. computeSizeInBytes(OperationSubmitter operationSubmitter)CompletableFuture<?>LuceneIndexSchemaManager. createIfMissing(OperationSubmitter operationSubmitter)CompletableFuture<?>LuceneIndexSchemaManager. createOrUpdate(OperationSubmitter operationSubmitter)CompletableFuture<?>LuceneIndexSchemaManager. createOrValidate(ContextualFailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>LuceneIndexSchemaManager. dropAndCreate(OperationSubmitter operationSubmitter)CompletableFuture<?>LuceneIndexSchemaManager. dropIfExisting(OperationSubmitter operationSubmitter)CompletableFuture<?>LuceneIndexSchemaManager. validate(ContextualFailureCollector failureCollector, OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.backend.lucene.work.execution.impl
-
Uses of OperationSubmitter in org.hibernate.search.engine.backend.orchestration.spi
Methods in org.hibernate.search.engine.backend.orchestration.spi with parameters of type OperationSubmitter Modifier and Type Method Description protected abstract voidAbstractWorkOrchestrator. doSubmit(W work, OperationSubmitter operationSubmitter)voidAbstractWorkOrchestrator. submit(W work, OperationSubmitter operationSubmitter)voidBatchingExecutor. submit(W work, OperationSubmitter operationSubmitter)Submit a work for execution. -
Uses of OperationSubmitter in org.hibernate.search.engine.backend.schema.management.spi
Methods in org.hibernate.search.engine.backend.schema.management.spi with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<?>IndexSchemaManager. createIfMissing(OperationSubmitter operationSubmitter)Creates the schema if it doesn't already exist.CompletableFuture<?>IndexSchemaManager. createOrUpdate(OperationSubmitter operationSubmitter)Creates the schema if it doesn't already exist, or updates the existing schema to match requirements expressed by the mapper.CompletableFuture<?>IndexSchemaManager. createOrValidate(ContextualFailureCollector failureCollector, OperationSubmitter operationSubmitter)Creates the schema if it doesn't already exist, or validates the existing schema against requirements expressed by the mapper.CompletableFuture<?>IndexSchemaManager. dropAndCreate(OperationSubmitter operationSubmitter)Drops the schema and all indexed data if it exists, then creates the schema.CompletableFuture<?>IndexSchemaManager. dropIfExisting(OperationSubmitter operationSubmitter)Drops the schema and all indexed data if it exists.CompletableFuture<?>IndexSchemaManager. validate(ContextualFailureCollector failureCollector, OperationSubmitter operationSubmitter)Validates the existing schema against requirements expressed by the mapper. -
Uses of OperationSubmitter in org.hibernate.search.engine.backend.work.execution
Methods in org.hibernate.search.engine.backend.work.execution that return OperationSubmitter Modifier and Type Method Description static OperationSubmitterOperationSubmitter. blocking()When using this submitter, dding a new element will block the thread when the underlying queue is aBlockingQueueand it is at its maximum capacity, until some elements are removed from the queuestatic OperationSubmitterOperationSubmitter. offloading(Consumer<Runnable> executor)Creates an operation submitter that would attempt to submit work to a queue, but in case the queue is full it would offload the submitting of the operation to provided executor.static OperationSubmitterOperationSubmitter. rejecting()When using this submitter adding a new element will cause aRejectedExecutionExceptionwhen the underlying queue is aBlockingQueueand it is at its maximum capacity. -
Uses of OperationSubmitter in org.hibernate.search.engine.backend.work.execution.spi
Methods in org.hibernate.search.engine.backend.work.execution.spi with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<?>IndexIndexer. add(DocumentReferenceProvider referenceProvider, DocumentContributor documentContributor, DocumentCommitStrategy commitStrategy, DocumentRefreshStrategy refreshStrategy, OperationSubmitter operationSubmitter)Add a document to the index, assuming that the document is absent from the index.CompletableFuture<?>IndexIndexer. addOrUpdate(DocumentReferenceProvider referenceProvider, DocumentContributor documentContributor, DocumentCommitStrategy commitStrategy, DocumentRefreshStrategy refreshStrategy, OperationSubmitter operationSubmitter)Update a document in the index, or add it if it's absent from the index.CompletableFuture<?>IndexIndexer. delete(DocumentReferenceProvider referenceProvider, DocumentCommitStrategy commitStrategy, DocumentRefreshStrategy refreshStrategy, OperationSubmitter operationSubmitter)Delete a document from the index.default CompletableFuture<?>IndexIndexingPlan. execute(OperationSubmitter operationSubmitter)Start executing all the works in this plan, and clear the plan so that it can be re-used.CompletableFuture<MultiEntityOperationExecutionReport>IndexIndexingPlan. executeAndReport(OperationSubmitter operationSubmitter)Start executing all the works in this plan, and clear the plan so that it can be re-used.CompletableFuture<?>IndexWorkspace. flush(OperationSubmitter operationSubmitter)CompletableFuture<?>IndexWorkspace. mergeSegments(OperationSubmitter operationSubmitter)CompletableFuture<?>IndexWorkspace. purge(Set<String> routingKeys, OperationSubmitter operationSubmitter)CompletableFuture<?>IndexWorkspace. refresh(OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.mapper.orm.automaticindexing.impl
Methods in org.hibernate.search.mapper.orm.automaticindexing.impl with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<MultiEntityOperationExecutionReport>AutomaticIndexingQueueEventProcessingPlanImpl. executeAndReport(OperationSubmitter operationSubmitter)CompletableFuture<MultiEntityOperationExecutionReport>HibernateOrmIndexingQueueEventSendingPlan. sendAndReport(OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.mapper.orm.automaticindexing.session
Methods in org.hibernate.search.mapper.orm.automaticindexing.session with parameters of type OperationSubmitter Modifier and Type Method Description voidAutomaticIndexingSynchronizationConfigurationContext. operationSubmitter(OperationSubmitter operationSubmitter)Deprecated.Set operation submitter to be applied while executing underlying plans. -
Uses of OperationSubmitter in org.hibernate.search.mapper.orm.automaticindexing.spi
Methods in org.hibernate.search.mapper.orm.automaticindexing.spi with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<MultiEntityOperationExecutionReport>AutomaticIndexingQueueEventProcessingPlan. executeAndReport(OperationSubmitter operationSubmitter)Writes all pending changes to the index now, and clears the plan so that it can be re-used.CompletableFuture<MultiEntityOperationExecutionReport>AutomaticIndexingQueueEventSendingPlan. sendAndReport(OperationSubmitter operationSubmitter)Sends the events to the queue. -
Uses of OperationSubmitter in org.hibernate.search.mapper.pojo.schema.management.impl
Methods in org.hibernate.search.mapper.pojo.schema.management.impl with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<?>PojoScopeSchemaManagerImpl. createIfMissing(FailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeSchemaManagerImpl. createOrUpdate(FailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeSchemaManagerImpl. createOrValidate(FailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeSchemaManagerImpl. dropAndCreate(FailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeSchemaManagerImpl. dropIfExisting(FailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeSchemaManagerImpl. validate(FailureCollector failureCollector, OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.mapper.pojo.schema.management.spi
Methods in org.hibernate.search.mapper.pojo.schema.management.spi with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<?>PojoScopeSchemaManager. createIfMissing(FailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeSchemaManager. createOrUpdate(FailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeSchemaManager. createOrValidate(FailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeSchemaManager. dropAndCreate(FailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeSchemaManager. dropIfExisting(FailureCollector failureCollector, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeSchemaManager. validate(FailureCollector failureCollector, OperationSubmitter operationSubmitter) -
Uses of OperationSubmitter in org.hibernate.search.mapper.pojo.work
Methods in org.hibernate.search.mapper.pojo.work with parameters of type OperationSubmitter Modifier and Type Method Description voidIndexingPlanSynchronizationStrategyConfigurationContext. operationSubmitter(OperationSubmitter operationSubmitter)Set operation submitter to be applied while executing underlying plans. -
Uses of OperationSubmitter in org.hibernate.search.mapper.pojo.work.impl
-
Uses of OperationSubmitter in org.hibernate.search.mapper.pojo.work.spi
Methods in org.hibernate.search.mapper.pojo.work.spi with parameters of type OperationSubmitter Modifier and Type Method Description CompletableFuture<?>PojoIndexer. add(PojoRawTypeIdentifier<?> typeIdentifier, Object providedId, DocumentRoutesDescriptor providedRoutes, Object entity, DocumentCommitStrategy commitStrategy, DocumentRefreshStrategy refreshStrategy, OperationSubmitter operationSubmitter)Add an entity to the index, assuming that the entity is absent from the index.CompletableFuture<?>PojoIndexer. addOrUpdate(PojoRawTypeIdentifier<?> typeIdentifier, Object providedId, DocumentRoutesDescriptor providedRoutes, Object entity, DocumentCommitStrategy commitStrategy, DocumentRefreshStrategy refreshStrategy, OperationSubmitter operationSubmitter)Update an entity in the index, or add it if it's absent from the index.CompletableFuture<?>PojoIndexer. delete(PojoRawTypeIdentifier<?> typeIdentifier, Object providedId, DocumentRoutesDescriptor providedRoutes, Object entity, DocumentCommitStrategy commitStrategy, DocumentRefreshStrategy refreshStrategy, OperationSubmitter operationSubmitter)Delete an entity from the index.CompletableFuture<?>PojoIndexer. delete(PojoRawTypeIdentifier<?> typeIdentifier, Object providedId, DocumentRoutesDescriptor providedRoutes, DocumentCommitStrategy commitStrategy, DocumentRefreshStrategy refreshStrategy, OperationSubmitter operationSubmitter)Purge an entity from the index.CompletableFuture<MultiEntityOperationExecutionReport>PojoIndexingPlan. executeAndReport(OperationSubmitter operationSubmitter)Write all pending changes to the index now, without waiting for a Hibernate ORM flush event or transaction commit, and clear the plan so that it can be re-used.CompletableFuture<MultiEntityOperationExecutionReport>PojoIndexingQueueEventProcessingPlan. executeAndReport(OperationSubmitter operationSubmitter)Writes all pending changes to the index now, and clears the plan so that it can be re-used.CompletableFuture<?>PojoScopeWorkspace. flush(OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeWorkspace. mergeSegments(OperationSubmitter operationSubmitter)voidConfiguredIndexingPlanSynchronizationStrategy.Builder. operationSubmitter(OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeWorkspace. purge(Set<String> routingKeys, OperationSubmitter operationSubmitter)CompletableFuture<?>PojoScopeWorkspace. refresh(OperationSubmitter operationSubmitter)CompletableFuture<MultiEntityOperationExecutionReport>PojoIndexingQueueEventSendingPlan. sendAndReport(OperationSubmitter operationSubmitter)Sends the events to the queue.
-