Solr リファレンスの Cross Collection Join の項に以下の説明があります。
If the local index is sharded according to the join key field, the cross collection join can leverage a secondary query parser called the “hash_range” query parser. The hash_range query parser is responsible for returning only the documents that hash to a given range of values. This allows the CrossCollectionQuery to query the remote Solr collection and return only the join keys that would match a specific shard in the local Solr collection. This has the benefit of making sure that network traffic doesn’t increase as the number of shards increases and allows for much greater scalability.
https://solr.apache.org/guide/8_9/other-parsers.html#cross-collection-join
意訳
ローカルインデックスが join key フィールドでシャードに分けられている場合、Cross Collection Join はHash Range クエリパーザという補助的なクエリパーザを利用できます。Hash Range クエリパーザは、そのハッシュが指定された範囲に収まるドキュメントだけを返す役目を持っています。これにより、CrossCollectionQuery はリモートの Solr コレクションにクエリを投げたときにローカル側のコレクションの特定のシャードにだけマッチする join key を受け取ることができます。この機能にはシャード数が増加してもネットワークトラフィックが増えないという利点があり、非常に優れたスケーラビリティを実現します。
この動作を確認してみます。前回同様
ローカルインデックス: http://localhost:8983/solr/collection1
リモートインデックス: http://localhost:7574/solr/collection2
です。それぞれ以下のようなデータが入っています。
$ curl -s 'http://localhost:8983/solr/collection1/select?q.op=AND&q=*%3A*&rows=5'
{
"responseHeader":{
"zkConnected":true,
"status":0,
"QTime":4,
"params":{
"q":"*:*",
"q.op":"AND",
"rows":"5"}},
"response":{"numFound":9238,"start":0,"maxScore":1.0,"numFoundExact":true,"docs":[
{
"id":"名所・旧跡!4548",
"type_str":"名所・旧跡",
"name_str":"高砂神社",
"_version_":1706788558129332224},
{
"id":"名所・旧跡!4549",
"type_str":"名所・旧跡",
"name_str":"高崎神社",
"_version_":1706788558131429376},
{
"id":"名所・旧跡!4550",
"type_str":"名所・旧跡",
"name_str":"大阪護国神社",
"_version_":1706788558131429377},
{
"id":"名所・旧跡!4551",
"type_str":"名所・旧跡",
"name_str":"極楽寺",
"_version_":1706788558131429378},
{
"id":"名所・旧跡!4552",
"type_str":"名所・旧跡",
"name_str":"あびこ観音",
"_version_":1706788558131429379}]
}}
$ curl -s 'http://localhost:7574/solr/collection2/select?q.op=AND&q=*%3A*&rows=5'
{
"responseHeader":{
"zkConnected":true,
"status":0,
"QTime":5,
"params":{
"q":"*:*",
"q.op":"AND",
"rows":"5"}},
"response":{"numFound":9238,"start":0,"maxScore":1.0,"numFoundExact":true,"docs":[
{
"id":"名所・旧跡!4548",
"area_str":"住之江区",
"address_str":"住之江区北島3-14-12",
"address_p":"34.6003421111111,135.477833138888",
"_version_":1706808733657464832},
{
"id":"名所・旧跡!4549",
"area_str":"住之江区",
"address_str":"住之江区南加賀屋4-15-3",
"address_p":"34.6014560555555,135.474182833333",
"_version_":1706808733658513408},
{
"id":"名所・旧跡!4550",
"area_str":"住之江区",
"address_str":"住之江区南加賀屋1-1-77",
"address_p":"34.6102029722222,135.473905944444",
"_version_":1706808733659561984},
{
"id":"名所・旧跡!4551",
"area_str":"住吉区",
"address_str":"住吉区遠里小野5丁目",
"address_p":"34.6003890555555,135.495708055555",
"_version_":1706808733659561985},
{
"id":"名所・旧跡!4552",
"area_str":"住吉区",
"address_str":"住吉区我孫子4丁目",
"address_p":"34.5989438333333,135.508442333333",
"_version_":1706808733659561986}]
}}
idフィールドが CompositId になっており、type_str の値でシャーディングされます。
シャードが4つの場合、以下のような配置となっています。
$ curl -s 'http://localhost:8983/solr/collection1/select?facet.field=type_str&facet=on&q=*:*&rows=0&shards=shard1'|jq .facet_counts.facet_fields.type_str
[
"名所・旧跡",
561,
"環境・リサイクル",
53
]
$ curl -s 'http://localhost:8983/solr/collection1/select?facet.field=type_str&facet=on&q=*:*&rows=0&shards=shard2'|jq .facet_counts.facet_fields.type_str
[
"駐車場・駐輪場",
1049,
"学校・保育所",
1045,
"医療・福祉",
840,
"会館・ホール",
642,
"官公庁",
301,
"その他",
141
]
$ curl -s 'http://localhost:8983/solr/collection1/select?facet.field=type_str&facet=on&q=*:*&rows=0&shards=shard3'|jq .facet_counts.facet_fields.type_str
[
"駅・バス停",
2574,
"警察・消防",
330,
"文化・観光",
290
]
$ curl -s 'http://localhost:8983/solr/collection1/select?facet.field=type_str&facet=on&q=*:*&rows=0&shards=shard4'|jq .facet_counts.facet_fields.type_str
[
"公園・スポーツ",
1090,
"公衆トイレ",
322
]
それぞれのシャードのハッシュの値の範囲は以下の通りです。
$ curl -s 'http://localhost:8983/solr/admin/collections?action=COLSTATUS&collection=collection1&coreInfo=true' |jq '.collection1.shards | {(keys[0]):[.[].range][0],(keys[1]):[.[].range][1],(keys[2]):[.[].range][2],(keys[3]):[.[].range][3]}'
{
"shard1": "80000000-bfffffff",
"shard2": "c0000000-ffffffff",
"shard3": "0-3fffffff",
"shard4": "40000000-7fffffff"
}
ここで type_str:文化・観光 で area_type:中央区 のデータを Cross Collection Join で検索してみます。
type_str:文化・観光 {!join ttl=1 routed=\"true\" method=\"crossCollection\" fromIndex=\"collection2\" from=\"id\" to=\"id\" solrUrl=\"http://localhost:7574/solr\" v=\"area_str:中央区\"}
routed=true を指定して、Range Hash クエリを有効にしています。
この検索におけるリモートインデックス側(7574のSolr)のログを確認すると、以下のような検索クエリが来ていることが分かります。
2021-07-31 16:52:56.699 INFO (qtp1620529408-898) [c:collection2 s:shard1 r:core_node3 x:collection2_shard1_replica_n1] o.a.s.c.S.Request [collection2_shard1_replica_n1] webapp=/solr path=/stream params={indent=off&expr=unique(search(collection2,q%3D"area_str:中央区",fq%3D"{!hash_range+f%3Did+l%3D0+u%3D1073741823}",fl%3Did,sort%3D"id+asc",qt%3D"/export",method%3DcrossCollection),over%3Did)&wt=javabin&version=2.2} status=0 QTime=0
Hash Range を指定しているのは以下の部分です。
{!hash_range f:id l:0 u:1073741823}
idフィールドのハッシュ値の下限が0,上限が1073741823と指定されています。1073741823を16進数に直すと3FFFFFFFです。type_str:文化・観光 が属する shard3 にマッチするものだけが要求されていることが分かります。
