クラス ReactiveElasticsearchTemplate

方法の詳細

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware 内の setApplicationContext 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の setApplicationContext 

  例外:

  BeansException

• setObservationConvention

  public void setObservationConvention(@Nullable ElasticsearchObservationConvention observationConvention)

  デフォルトの規約を上書きするには、カスタムの ElasticsearchObservationConvention を設定します。

  パラメーター:

  observationConvention - null でもかまいません。

  導入:

  6.1

• save

  public <T> Mono<T> save(T entity, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  指定されたインデックス内の指定された型のエンティティをインデックスします。インデックスが null または空の場合は、エンティティメタデータを介して提供されるインデックス名が使用されます。型についても同様です。

  次で指定:

  インターフェース ReactiveDocumentOperations 内の save 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の save 

  型パラメーター:

  T -

  パラメーター:

  entity - null であってはなりません。

  index - ターゲットインデックスは null であってはなりません

  戻り値:

  保存されたエンティティを発行する Mono。

• exists

  public Mono<BooleanSE> exists(StringSE id, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  指定された ID を持つエンティティが存在するかどうかを確認します。

  次で指定:

  インターフェース ReactiveDocumentOperations 内の exists 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の exists 

  パラメーター:

  id - 検索するドキュメントの _id。

  index - ターゲットインデックスは null であってはなりません

  戻り値:

  一致するドキュメントが存在する場合は true を、そうでない場合は false を発行する Mono です。

• delete

  public Mono<StringSE> delete(ObjectSE entity, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  エンティティメタデータから指定されたエンティティ抽出インデックスを削除します。

  次で指定:

  インターフェース ReactiveDocumentOperations 内の delete 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の delete 

  パラメーター:

  entity - null であってはなりません。

  index - ターゲットインデックスは null であってはなりません

  戻り値:

  削除されたドキュメントの ID を発行する Mono。

• delete

  public Mono<StringSE> delete(StringSE id, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  指定された ID を持つエンティティを削除します。

  次で指定:

  インターフェース ReactiveDocumentOperations 内の delete 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の delete 

  パラメーター:

  id - null であってはなりません。

  index - ターゲットインデックスは null であってはなりません

  戻り値:

  削除されたドキュメントの ID を発行する Mono。

• search

  public <T> Flux<SearchHit<T>> search(Query query, ClassSE<?> entityType, ClassSE<T> resultType, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveSearchOperations

  指定された query に一致するエンティティをインデックスで検索します。

  次で指定:

  インターフェース ReactiveSearchOperations 内の search 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の search 

  型パラメーター:

  T -

  パラメーター:

  query - null であってはなりません。

  entityType - null であってはなりません。

  resultType - 射影結果の型。

  index - ターゲットインデックスは null であってはなりません

  戻り値:

  SearchHit でラップされた一致するエンティティを 1 つずつ発行する Flux。

• count

  public Mono<LongSE> count(Query query, ClassSE<?> entityType, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveSearchOperations

  指定された Query に一致するドキュメントの数をカウントします。

  次で指定:

  インターフェース ReactiveSearchOperations 内の count 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の count 

  パラメーター:

  query - null であってはなりません。

  entityType - null であってはなりません。

  index - ターゲットインデックスは null であってはなりません

  戻り値:

  一致するドキュメントの番号を発行する Mono。

• doIndex

  protected <T> Mono<Tuple2<T, AbstractReactiveElasticsearchTemplate.IndexResponseMetaData>> doIndex(T entity, IndexCoordinates index)

  次で指定:

  クラス AbstractReactiveElasticsearchTemplate の doIndex 

• saveAll

  public <T> Flux<T> saveAll(Mono<? extends CollectionSE<? extends T>> entitiesPublisher, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  指定されたインデックス内のインデックスエンティティ。インデックスが null または空の場合は、エンティティメタデータを介して提供されるインデックス名が使用されます。

  型パラメーター:

  T -

  パラメーター:

  entitiesPublisher - null であってはなりません。

  index - ターゲットインデックスは null であってはなりません

  戻り値:

  保存されたエンティティを送信する Flux。

• doExists

  protected Mono<BooleanSE> doExists(StringSE id, IndexCoordinates index)

  次で指定:

  クラス AbstractReactiveElasticsearchTemplate の doExists 

• delete

  public Mono<ByQueryResponse> delete(DeleteQuery query, ClassSE<?> entityType, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  エンティティメタデータから指定された Query 抽出インデックスに一致するドキュメントを削除します。

  パラメーター:

  query - null であってはなりません。

  entityType - null であってはなりません。

  index - ターゲットインデックスは null であってはなりません

  戻り値:

  削除されたドキュメントの数を発行する Mono。

• get

  public <T> Mono<T> get(StringSE id, ClassSE<T> entityType, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  指定された ID を持つエンティティを取得します。

  型パラメーター:

  T -

  パラメーター:

  id - null であってはなりません。

  index - ターゲットインデックスは null であってはなりません

  戻り値:

  Mono はエンティティを送信するか、何も見つからない場合は完了を通知します。

• reindex

  public Mono<ReindexResponse> reindex(ReindexRequest reindexRequest)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  ソースから宛先にドキュメントをコピーします。ソースには、既存のインデックス、エイリアス、データストリームを使用できます。宛先はソースと異なる必要があります。例: データストリームをそれ自体に再インデックスすることはできません。(@see https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-reindex.html)

  パラメーター:

  reindexRequest - 再インデックスリクエストパラメーター

  戻り値:

  再インデックスレスポンスを発行する Mono

• submitReindex

  public Mono<StringSE> submitReindex(ReindexRequest reindexRequest)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  再インデックスタスクを送信します。(@see https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-reindex.html)

  パラメーター:

  reindexRequest - 再インデックスリクエストパラメーター

  戻り値:

  タスク ID を発行する Mono。

• update

  public Mono<UpdateResponse> update(UpdateQuery updateQuery, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  ドキュメントの部分的な更新。

  パラメーター:

  updateQuery - 更新を定義するクエリ

  index - レコードを更新するインデックス

  戻り値:

  更新レスポンスを送信する Mono

• updateByQuery

  public Mono<ByQueryResponse> updateByQuery(UpdateQuery updateQuery, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  クエリによってドキュメントを更新します。

  パラメーター:

  updateQuery - 更新を定義するクエリは null であってはなりません

  index - レコードを更新するインデックスは null であってはなりません

  戻り値:

  更新レスポンスを送信する Mono

• bulkUpdate

  public Mono<VoidSE> bulkUpdate(ListSE<UpdateQuery> queries, BulkOptions bulkOptions, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  すべてのオブジェクトを一括更新します。更新を実行します。

  パラメーター:

  queries - 一括で実行するクエリ

  bulkOptions - 一括リクエストに追加するオプション

• doDeleteById

  protected Mono<StringSE> doDeleteById(StringSE id, @Nullable StringSE routing, IndexCoordinates index)

  次で指定:

  クラス AbstractReactiveElasticsearchTemplate の doDeleteById 

• multiGet

  public <T> Flux<MultiGetItem<T>> multiGet(Query query, ClassSE<T> clazz, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveDocumentOperations

  指定された ID に対して elasticsearch に対して multiGet を実行します。

  パラメーター:

  query - 取得するオブジェクトの ID を定義するクエリ

  clazz - 返されるオブジェクトの型

  index - オブジェクトが読み取られるインデックス。

  戻り値:

  エンティティを含む MultiGetItem のリストを含む flux

  関連事項:

  • Query.multiGetQuery(Collection)
  • Query.multiGetQueryWithRouting(List)

• doCopy

  protected ReactiveElasticsearchTemplate doCopy()

  次で指定:

  クラス AbstractReactiveElasticsearchTemplate の doCopy 

• customizeCopy

  protected void customizeCopy(AbstractReactiveElasticsearchTemplate copy)

  クラスからコピーされた説明: AbstractReactiveElasticsearchTemplate

  AbstractReactiveElasticsearchTemplate.copy() 処理中にサブクラスが追加の状態をコピーするためのフック。すべての共通フィールドのコピーが完了した後に呼び出されます。デフォルトの実装では何も行いません。

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の customizeCopy 

  パラメーター:

  copy - カスタマイズする新しいテンプレートインスタンス

• doFind

  protected Flux<SearchDocument> doFind(Query query, ClassSE<?> clazz, IndexCoordinates index)

  次で指定:

  クラス AbstractReactiveElasticsearchTemplate の doFind 

• doCount

  protected Mono<LongSE> doCount(Query query, ClassSE<?> entityType, IndexCoordinates index)

  次で指定:

  クラス AbstractReactiveElasticsearchTemplate の doCount 

• doFindForResponse

  protected <T> Mono<SearchDocumentResponse> doFindForResponse(Query query, ClassSE<?> clazz, IndexCoordinates index)

  次で指定:

  クラス AbstractReactiveElasticsearchTemplate の doFindForResponse 

• aggregate

  public Flux<? extends AggregationContainer<?>> aggregate(Query query, ClassSE<?> entityType, IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveSearchOperations

  指定された query で指定された集計を実行します。
  

  パラメーター:

  query - null であってはなりません。

  entityType - null であってはなりません。

  index - ターゲットインデックスは null であってはなりません

  戻り値:

  一致する集約を 1 つずつ発行する Flux。

• openPointInTime

  public Mono<StringSE> openPointInTime(IndexCoordinates index, DurationSE keepAlive, BooleanSE ignoreUnavailable)

  インターフェースからコピーされた説明: ReactiveSearchOperations

  Elasticsearch に時点 (ピット) を開きます。

  次で指定:

  インターフェース ReactiveSearchOperations 内の openPointInTime 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の openPointInTime 

  パラメーター:

  index - 使用するインデックス名

  keepAlive - ピットを生かしておくべき期間

  ignoreUnavailable - {$literal true} の場合、インデックスのいずれかが欠落しているか閉じられていると呼び出しは失敗します。

  戻り値:

  ピット識別子

• closePointInTime

  public Mono<BooleanSE> closePointInTime(StringSE pit)

  インターフェースからコピーされた説明: ReactiveSearchOperations

  ある時点を閉じる

  次で指定:

  インターフェース ReactiveSearchOperations 内の closePointInTime 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の closePointInTime 

  パラメーター:

  pit - ReactiveSearchOperations.openPointInTime(IndexCoordinates, Duration, Boolean) によって返されるピット識別子

  戻り値:

  成功に関しては真実

• putScript

  public Mono<BooleanSE> putScript(Script script)

  インターフェースからコピーされた説明: ReactiveScriptOperations

  指定されたスクリプトを Elasticsearch クラスターに保存します。

  次で指定:

  インターフェース ReactiveScriptOperations 内の putScript 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の putScript 

  戻り値:

  { 成功した場合は true

• getScript

  public Mono<Script> getScript(StringSE name)

  インターフェースからコピーされた説明: ReactiveScriptOperations

  指定された名前のスクリプトを取得します。

  次で指定:

  インターフェース ReactiveScriptOperations 内の getScript 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の getScript 

  パラメーター:

  name - スクリプトの名前

  戻り値:

  この名前のスクリプトが存在しない場合はスクリプト、または null。

• deleteScript

  public Mono<BooleanSE> deleteScript(StringSE name)

  インターフェースからコピーされた説明: ReactiveScriptOperations

  指定された名前のスクリプトを削除します

  次で指定:

  インターフェース ReactiveScriptOperations 内の deleteScript 

  オーバーライド:

  クラス AbstractReactiveElasticsearchTemplate の deleteScript 

  パラメーター:

  name - スクリプトの名前。

  戻り値:

  リクエストがクラスターによって確認された場合は true です。

• getVendor

  public Mono<StringSE> getVendor()

  次で指定:

  クラス AbstractReactiveElasticsearchTemplate の getVendor 

  戻り値:

  使用されているクラスタとクライアントライブラリのベンダー名

• getRuntimeLibraryVersion

  public Mono<StringSE> getRuntimeLibraryVersion()

  次で指定:

  クラス AbstractReactiveElasticsearchTemplate の getRuntimeLibraryVersion 

  戻り値:

  使用されているクライアントランタイムライブラリのバージョン。

• getClusterVersion

  public Mono<StringSE> getClusterVersion()

  次で指定:

  クラス AbstractReactiveElasticsearchTemplate の getClusterVersion 

• indexOps

  public ReactiveIndexOperations indexOps(IndexCoordinates index)

  インターフェースからコピーされた説明: ReactiveElasticsearchOperations

  指定されたインデックスにバインドされた ReactiveIndexOperations を作成します

  パラメーター:

  index - インデックスを指定する IndexCoordinates

  戻り値:

  ReactiveIndexOperations の実装

• indexOps

  public ReactiveIndexOperations indexOps(ClassSE<?> clazz)

  インターフェースからコピーされた説明: ReactiveElasticsearchOperations

  指定されたクラスにバインドされた ReactiveIndexOperations を作成します

  パラメーター:

  clazz - インデックス情報を指定するエンティティ clazz

  戻り値:

  ReactiveIndexOperations の実装

• cluster

  public ReactiveClusterOperations cluster()

  インターフェースからコピーされた説明: ReactiveElasticsearchOperations

  この ElasticsearchOperations インスタンスと同じクライアント通信設定を使用する ReactiveClusterOperations インスタンスを返します。

  戻り値:

  ClusterOperations の実装

• matchAllQuery

  public Query matchAllQuery()

  インターフェースからコピーされた説明: ReactiveSearchOperations

  すべてのドキュメントを検索するための Query を作成します。それぞれのクライアントを使用して適切なクエリを提供するには、具体的な実装によって実装する必要があります。

  戻り値:

  すべてのドキュメントを検索するクエリ

• idsQuery

  public Query idsQuery(ListSE<StringSE> ids)

  インターフェースからコピーされた説明: ReactiveSearchOperations

  指定された ID を持つすべてのドキュメントを検索するための Query を作成します。それぞれのクライアントを使用して適切なクエリを提供するには、具体的な実装によって実装する必要があります。

  パラメーター:

  ids - ID のリストは null であってはなりません

  戻り値:

  指定された ID を持つドキュメントを返すクエリ

• queryBuilderWithIds

  public BaseQueryBuilder queryBuilderWithIds(ListSE<StringSE> ids)

  インターフェースからコピーされた説明: ReactiveSearchOperations

  指定された ID をパラメーター値に設定した BaseQueryBuilder を作成します。ビルダーの他のプロパティは設定されません。

  パラメーター:

  ids - ID のリストは null であってはなりません

  戻り値:

  指定された ID を持つドキュメントを返すクエリ

• search

  public Mono<SqlResponse> search(SqlQuery query)

  インターフェースからコピーされた説明: ReactiveSqlOperations

  elasticsearch に対して SQL query を実行し、結果を SqlResponse として返します。

  パラメーター:

  query - 実行するクエリ

  戻り値:

  見つかったオブジェクトのリストを含む SqlResponse

• execute

  public <T> Publisher<T> execute(ReactiveElasticsearchTemplate.ClientCallback<Publisher<T>> callback)

  ReactiveElasticsearchClient を使用してコールバックを実行し、例外変換を提供します。

  型パラメーター:

  T - コールバックから返される型

  パラメーター:

  callback - 実行するコールバック。null であってはなりません

  戻り値:

  コールバック結果