JP7784209B2 - 分散型データベース・システムにおけるテーブルの行を分散させること - Google Patents

Description

本発明は、デジタル・コンピュータ・システムの分野に関し、より詳細には、分散型データベース・システムにおけるテーブルの行を分散させるための方法に関する。

分散型データベース・システムにテーブルを格納することは、テーブルの行が格納されなければならない論理ノードにテーブルの行を割り当てることによって実施され得る。論理ノードに行を割り当てた後、行は、それぞれの論理ノードに格納されてもよい。それでも、このプロセスは、リソース負荷の大きなタスクになり得る。

本発明の実施形態は、分散型データベース・システムにおけるテーブルの行を分散させるためのコンピュータ実行方法、コンピュータ・プログラム製品、およびシステムを含む。第１の実施形態では、複数の論理ノードのうちの各論理ノードについて、複数の論理ノードのうちの現在の論理ノードへの接続が行われる。１つまたは複数の行は、現在の論理ノード上のターゲット・テーブルに格納されることになる論理ノードのうちのソース・ノードから選択され、ここで、１つまたは複数の行は、分散型データベース・システムにおけるデータを分散させるための分散ルールに基づいて選択される。行は、ターゲット・テーブルに格納され、ここで、行は、ソース・ノードからプルされ、現在の論理ノードに格納される。

別の態様では、本発明は、コンピュータ可読プログラム・コードが組み込まれたコンピュータ可読ストレージ媒体を備えるコンピュータ・プログラム製品に関し、コンピュータ可読プログラム・コードは、前述の実施態様による方法のステップのすべてを実行するように構成される。

別の態様では、本発明は、複数の論理ノードを備える分散型データベース・システムのためのコンピュータ・システムに関する。コンピュータ・システムは、分散型データベース・システムの各論理ノードに接続すること、並びに、論理ノード上のターゲット・テーブルに格納されることになる複数の論理ノードのうちのソース・ノードから行を識別または選択すること、および識別された行を取り出してこれらをターゲット・テーブルに格納することを行うように、接続先論理ノード（connected-to-logical node）のそれぞれを制御することを行うように構成される。

以下では、図面を参照しながら、本発明の実施形態が、ほんの一例として、より詳細に説明される。

本主題の例による分散型データベース・システムの図である。 本主題の例による、分散型データベース・システムにおけるテーブルの行を分散させるための方法のフローチャートである。 本主題の実例の分散方法による分散型データベース・システムにおけるデータ・フローである。 本主題の実例の分散方法による分散型データベース・システムにおけるデータ・フローである。 本主題の実例の分散方法による分散型データベース・システムにおけるデータ・フローである。 本主題の例による方法のフローチャートである。 本主題の例による方法のフローチャートである。 本開示に含まれるような、１つまたは複数の方法ステップを実行するのに適したコンピュータ化システムの図である。

本発明の様々な実施形態の説明は、例証のために提示されることになるが、網羅的であること、または開示の実施形態に限定的であることを意図するものではない。説明された実施形態の範囲および思想から逸脱することなく、多くの変更形態および変形形態が当業者には明らかであろう。本明細書で使用される専門用語は、実施形態の原理、実用的用途、もしくは市場で見つかる技術に対する技術的改善を最もよく説明するように、または、本明細書で開示された実施形態を他の当業者が理解できるように選ばれた。

分散型データベース・システムは、複数のコンピュータまたは機械を備えてもよい。分散型データベース・システムの同じ機械に２つ以上の論理ノードが共存してもよい。同じ機械に共存する論理ノードは、ＣＰＵなどの処理リソースを共有してもよく、データを格納するための独自または別個のストレージ・エリアを有してもよい。これは、２つ以上の独立した機械であるかのように、機械を動かすことができる。論理ノードは、数字などの識別子に関連付けられてもよい。

分散型データベース・システムは、分散型データベース・システムの論理ノードに１つまたは複数のテーブルを格納するように構成されてもよい。このために、テーブルの各行が格納されることになる論理ノードのうちの１つにテーブルの各行を割り当てるための分散ルールが使用されてもよい。それぞれのノードに行を割り当てた後、それぞれの論理ノードに行を格納するための格納方法が使用されてもよい。行またはレコードは、特定のユーザの名前、生年月日、およびクラスなど、関連するデータ項目の集合体である。行は、エンティティを表し、エンティティは、ユーザ、オブジェクト、または概念を指し、これらについての情報がレコードに格納される。

例えば、テーブルが、分散型データベース・システムにまだ格納されていない場合、分散ルールは、テーブルに適用されてもよく、格納方法は、テーブルが現在格納されている場所からそれぞれの論理ノードに行をコピーすることを必要とする。この初期の格納により、複数の論理ノードの少なくとも一部の各論理ノードが、テーブルの行を格納する初期のまたは元のテーブルを有することになり得る。初期の格納方法の分散ルールは、初期の分散ルールと呼ばれてもよい。

別の例では、テーブルが、例えば、初期の格納の後、分散型ストレージ・システムに既に格納されており、初期の分散ルールが変化した場合、新しい分散ルールが、論理ノードのそれぞれに格納された元のテーブルに適用されてもよく、格納方法は、都合のよいことに、行がそれぞれの論理ノードにコピーされるように実施されてもよい。このケースでは、新たに分散された行は、新しいテーブルと呼ばれるテーブルに格納される。すなわち、論理ノードは、初期の分散方法による行を備える元のテーブル、および、初期の分散方法とは異なり得る別の分散方法による行を備える新しいテーブルを備えてもよい。分散方法は、分散ルールの適用および格納方法の実行から成ってもよい。テーブルの初期の分散の後またはテーブルの再分散の後に適用された分散方法の分散ルールは、新しい分散ルールと呼ばれてもよい。

分散ルールは、分散型ストレージ・システムに格納されることになるテーブルの１つまたは複数の属性についての１つまたは複数の条件を含んでもよい。１つまたは複数の属性は、分散キーと呼ばれてもよい。例えば、分散ルールは、文字Ａで始まる名前を有するエンティティを表す行が、論理ノード番号１に格納されることなどを求めることとしてもよい。

本主題は、以下のような分散された行を効率的に格納することができる。すべてのローカルに格納された行を処理して、これらを所望のターゲット・ノードに分散させるのではなく、現在のノードに格納されることになる行が、すべての論理ノードから選択され、次いで、現在のノードにプルされる。言い換えれば、行をすべての論理ノードから現在のノードにプッシュするのではなく、行は、ソース・ノードからプルされ、現在の論理ノードが、ターゲット・ノードである。本主題は、プッシュするアプローチに比べて、リソースを節約することができる。例えば、プッシュするアプローチは、１つの論理ノードが再分散をハンドリングする必要がある場合がある。この１つのノードは、すべての論理ノードからすべての行を取り出す。この１つのノードは、各行に対して、ターゲット・ノードを計算し、このターゲット・ノードに行を送る。したがって、ソース・ノード、再分散をハンドリングする現在のノード、およびターゲット・ノードという、３つの論理ノードが、各行に対して関係している。本方法は、ターゲット・ノードと、再分散をハンドリングする現在のノードとが、同じノードであり、行を現在のノードからターゲット・ノードに送る必要がもはやないので、このプッシュするアプローチを改善することができる。行は既に、ターゲット・ノードにある。結果は、再分散をハンドリングする現在のノードが、すべての行を処理せず、このノードにおいて、格納されることになる行のサブセットだけを処理することになり得る。

１つの実施形態によれば、テーブルの行は、初期の分散ルールに従って、複数のノードの少なくとも一部の各ノードに関連付けられる。方法は、前記各ノードに関連付けられた行を格納するための物理的なターゲット・テーブルを、複数の論理ノードの少なくとも一部の各ノードにおいて作成することをさらに含み、識別された行を取り出すことは、元のテーブルから実施される。

１つの実施形態によれば、初期の分散ルールは、新しい分散ルールとは異なるか、新しい分散ルールと同じである。新しい分散ルールが初期の分散ルールと同じであることは、分散型データベース・システムの構造が変化した場合に有利になることがあり、例えば、初期の分散ルールが、既存のノードにわたる行の均等な分散を必要とする場合、例えば追加のノードによる、変化したシステムに対するこのルールの再適用は、行の異なる分散につながり得る。

１つの実施形態によれば、行を識別することは、行を格納することなく、複数の論理ノードの少なくとも一部に関連付けられた行を判定するために、初期の分散ルールを適用することを含む。すなわち、論理ノードのそれぞれの元のテーブルへのテーブルの初期の格納は必要とされなくてもよい。例えば、データが他のテーブルから収集され、新しいテーブルに（新しい分散ルールで）直接格納されてもよいので、第１の場所での物理的な元のテーブルを作成する必要がなくてもよい。

１つの実施形態によれば、分散型データベース・システムは、分散方法に従って、複数の論理ノードにわたってテーブル行を分散させるように構成される。分散方法は、複数の論理ノードの各固有の論理ノードにおいて、ターゲット・ノードおよびターゲット・ノードにコピーされることになる固有の論理ノードの行を分散ルールに従って識別することを含む、行をノードに割り当てるステップ、および、行を固有の論理ノードからそれぞれの識別されたターゲット・ノードにコピーすることを含む、プッシュするステップを含む。方法は、分散方法が、各現在の論理ノードにおいて、複数の論理ノードのうちの候補ソース・ノードを判定することと、各候補ソース・ノード上で、行をノードに割り当てるステップの実行をトリガすることであって、識別されたソース・ノードが、現在の論理ノードをターゲット・ノードとして識別した候補ソース・ノードのノードである、トリガすることと、プッシュするステップを、プルするステップで置き換えることであって、プルするステップが、取り出すことを実施するために現在の論理ノードで実行される、置き換えることとを含むように、分散方法を適合させることをさらに含む。

本実施形態は、候補ノードのそれぞれの元のテーブルに新しい分散ルールを適用して、どの行がどのノードに行くかを識別することを可能にすることができ、格納方法は、分散方法に従ってデータをコピーするために、（ソース・ノード上ではなく）ターゲット・ノード上で実行される。本実施形態は、既存のシステムにおいてシームレスに統合され得るので、有利な場合がある。例えば、分散ルールが変更されずに維持され、格納方法を適合させることによって、本主題による、改善された分散に従って、既存の分散方法を適合させることができる。

１つの実施形態によれば、候補ソース・ノードは、複数の論理ノードのうちのすべての論理ノード、または、分散ルールに従って現在の論理ノードにデータを提供することが予測される複数の論理ノードのうちのノードである。現在の論理ノードは、どの行が現在の論理ノードにコピーされることになるかを識別するために、候補ソース・ノードに問い合わせることができる。候補論理ノードは、分散型データベース・システムのすべての論理ノードであり得る。これは、現在の論理ノードにコピーされることになるデータを有するノードを見落とす確率がほぼゼロになることにより、分散の効率が改善され得るので有利な場合がある。別の例では、候補論理ノードは、現在の論理ノードにコピーされることになるデータを含むことが予想される複数の論理ノードのうちのノードでもよく、例えば、これは、元のテーブルが、すべての論理ノード上に存在するわけではなくが、その真のサブセットにだけ存在し得るということによる。これは、例えば、前のテーブルに対する分散方法の実行から生じたログ・データを含む履歴データを使用することによって、予測され得る。これは、現在の論理ノードにコピーされることになるデータを含まないいくつかのノードに対して分散ルールを不必要に適用するのに別途必要とされる処理リソースを節約し得るので、有利になり得る。

１つの実施形態によれば、行をノードに割り当てるステップの実行は、分散ルールの分散キーの別個の値および関連付けられたターゲット・ノードを備えるルックアップ・テーブルを作成することと、ターゲット・ノードおよび対応する行を識別するために、作成されたテーブルを使用することとを含む。例えば、ルックアップ・テーブルは、一度作成されて、その後、各ノードは、これを使用することができる。

本実施形態は、ルックアップ・テーブルがずっと少ない列を有することにより、ルックアップ・テーブルを構築することが、すべての行を元のテーブルから新しいテーブルにコピーすることよりずっと速くなり得るので、有利な場合がある。したがって、ルックアップ・テーブルのデータ量は、著しく小さくなり、これは、（２倍のネットワーク通信が各ルックアップ行に対して必要になるとしても）ルックアップ・テーブルを構築するのに必要なリソースが少なくなることを意味する。ルックアップ・テーブルは、新しいテーブルの分散ルールに使用される値が一意ではなく、重複がある場合、著しく少ない行になる場合がある。例えば、各別個の値に対してただ１つの行がルックアップ・テーブルにおいて作成されてもよい。例えば、元のテーブルの列Ｃにインデックスがあり、この列Ｃが、新しい分散ルールに使用される場合、インデックスだけをスキャンすることで十分な場合があり、これは、テーブル全体をスキャンするよりずっと速くなり得る。したがって、ルックアップ・テーブル自体を構築することが、全体的に非常に速くなり得る。

１つの実施形態によれば、方法は、取り出された行をソートすることと、取り出された行をソート順に従ってターゲット・テーブルに格納することとをさらに含む。本実施形態は、格納レイアウトを最適化するために、行を物理的にソートする／並べることを可能にし得る。本実施形態は、すべてのプルされた行に対して一度にソートが実施されるので、さらに有利になり得る。これは、格納されることになる同じ数の行に対してソートが複数回繰り返されるプッシュ型アプローチとは対照的である。

１つの実施形態によれば、分散型データベース・システムは、第１の分散方法に従って複数の論理ノードにわたってテーブル行を分散させるように構成される。方法は、分散ルールを含む第２の分散方法に従って行を再分散させたいというリクエストを受け取ることに応答して実施される。

図１は、本主題の例による分散型データベース・システム１００を例証的に示す。分散型データベース・システム１００は、論理ノード１０１．１、１０１．２、および１０１．３（まとめて、ノード１０１と呼ばれる）を備える。ノード１０１は、コンピュータ・ネットワーク（図示せず）を介して互いに通信連結されてもよい。図１には３つのノードが示されているが、図１は、例示的なものにすぎない。実際には、何百ものノードがあってもよい。ノードは、また、論理データベース区画と呼ばれてもよく、データベース区画は、独自のデータ、インデックス、構成ファイル、およびトランザクション・ログから成るデータベースの一部である。したがって、分散型データベース・システム１００は、区画化されたデータベース環境を可能にする。論理データベース区画は、機械全体の制御権を与えられないという点で、物理区画とは異なる。機械には共有リソースがあるが、データベース区画は、リソースを共有しなくてもよい。プロセッサは共有されるが、ディスクおよびメモリは共有されない。例えば、２つ以上のデータベース区画が、（プロセッサの数に関わらず）同じ機械上に共存してもよい。

分散型データベース・システム１００は、IBM Db2(R) AnalyticsAccelerator（ＩＤＡＡ）アプライアンスなどの、アプリケーション１０３のテーブルＴのデータを格納するように構成されてもよい。分散型データベース・システム１００は、１つまたは複数のテーブル列の値に応じてテーブルＴの行がノード１０１にわたって分割される初期の分散方法に従って、データ編成スキームを実施するように構成されてもよい。図１に示されているように、ノード１０１のそれぞれは、初期の分散方法に従ってこのノードに最初に割り当てられた行を格納する（「元のテーブル」と名付けられた）元のテーブルを有する。データの区画化または分散は、性能を改善し、データ管理を簡素化し得る。アプリケーション１０３は、分散型データベース・システム１００におけるデータの格納、管理、およびアクセスを行うように構成されてもよい。例えば、分散型データベース・システム１００内で最初に分散されたテーブルは、例えば他の既存のテーブルから、オン・ザ・フライで作成されてもよい。各論理ノードの元のテーブルは、例えば、INSERT INTO <元のテーブル>; SELECT *; FROM (SELECT データ FROM 他のテーブル１, 他のテーブル２ WHERE... ); WHERE <現在の接続先ノードに格納されることになる行を識別する述語>; ORDER BY....というＳＱＬ文を使用して、プルするアプローチに基づいて、そのそれぞれの行のセットが入力されてもよい。

論理ノードのそれぞれの元のテーブルへのテーブルＴのこの初期の格納は、任意選択でもよい。例えば、第１の場所での物理的な「元のテーブル」の作成は、以下で説明されるように、データが他のテーブルから収集され、「新しいテーブル」に（所望の分散で）直接格納され得るので、必要でなくてもよい。このような状況では、「元のテーブル」は仮想でもよく、そのデータは、「(SELECT データ FROM... WHERE...)」という文の結果のセットである。これは、「元のテーブル」を実際のテーブルとして作成させず、これにデータを格納することをさせない。

分散型データベース・システム１００におけるテーブルＴの初期の格納の後、分散型データベース・システム１００は、第２の分散方法に従って、複数の論理ノード１０１．１から１０１．３にわたってテーブルＴの行を（再）分散させるように構成されてもよい。第２の分散方法は、複数の論理ノード１０１．１から１０１．３のうちの各論理ノードにおいて実行されてもよい。図１は、論理ノード１０１．１における第２の分散方法の実行を示しており、論理ノード１０１．１は、したがって、コーディネータ・ノードと考えられる。第２の分散方法は、行をノードに割り当てるステップおよびプッシュするステップを含んでもよい。固有の論理ノードにおける、行をノードに割り当てるステップの実行は、分散ルールによる、ターゲット・ノードと、ターゲット・ノードにコピーされることになる固有の論理ノードの元のテーブルの行との識別を備える。分散ルールは、例えば、テーブルＴの分散キーについての条件を含んでもよい。分散キーは、テーブルＴの１つまたは複数の属性を有してもよい。第２の分散方法の分散キーは、初期の分散方法の分散キーとは異なってもよい。プッシュするステップは、元のテーブルの行を固有の論理ノードからそれぞれの識別されたターゲット・ノードにコピーすることを含む。これは、コーディネータ・ノード１０１．１から新しいテーブルへの３つの矢印で指示されている。したがって、ノード１０１．１から１０１．３のそれぞれにおいて第２の分散方法を実行した後、テーブル行は、（「新しいテーブル」とそれぞれ名付けられた）新しいテーブルに、分散ルールに従ってノード１０１．１から１０１．３までにわたって格納されてもよい。したがって、論理ノードは、初期の分散方法に従って分散されたテーブルＴの行を有する元のテーブル、および、別の異なる分散方法に従って分散されたテーブルＴの行を有する新しいテーブルを有してもよい。

例えば、第２の分散方法の分散キーが、テーブルＴの属性ＩＤであると仮定する。分散ルールは、以下の関数ＭＯＤ（ＩＤ，３）を使用して、分散キーの各値に対してラウンド・ロビン・アルゴリズムを適用してもよく、関数ＭＯＤ（ＩＤ，３）は、属性ＩＤの値と３の割り算の余りを提供し、ここで、３は、ノード１０１．１から１０１．３の数を指す。関数ＭＯＤ（ＩＤ，３）の結果は、ノード１０１．１から１０１．３のうちの１つを識別する数でもよい。例えば、ノード１０１．１での第２の分散方法の実行は、ノード１０１．１、１０１．２、および１０１．３に格納される必要がある行の３つのグループをそれぞれ識別することができる。次いで、ノード１０１．１は、例えばＩＮＳＥＲＴ文を使用して、行の２つのグループを、格納のためのそれぞれのノードに送り、ノード１０１．１に割り当てられた行の第３のグループを、新しいテーブルにローカルに格納してもよい。同様に、ノード１０１．２での第２の分散方法の実行は、ノード１０１．１、１０１．２、および１０１．３に格納される必要がある行の３つのグループをそれぞれ識別することができる、などである。図１に指示されたように、再分散された行は、ノード１０１内の新しいテーブルに格納される。したがって、再分散の後、ノードのそれぞれは、それぞれがテーブルＴの異なる行を有する１つの元のテーブルおよび１つの新しいテーブルを備えてもよく、元のおよび新しいテーブルは、例えば、異なる分散キーに関連付けられてもよい。それでも、これらの分散方法は、各ノードへの接続および各ノード上でのＩＮＳＥＲＴ文の実行が、各ノード上でＩＮＳＥＲＴ文をｎ個同時に動かすことになるので、困難な場合があり、これらのＩＮＳＥＲＴ文のそれぞれが、書き込まれることになる行を格納するために空間（データ・ページ／エクステント）を必要とする。テーブルＴの行のこの分散は、図２Ａ、図２Ｂ、図２Ｃ、および図２Ｄを参照しながら説明されるような、別の分散方法を使用することによって、本主題によってさらに改善され得る。

図２Ａは、分散型データベース・システムにおけるテーブルの行を分散させるための方法のフローチャートである。図２Ａで説明される方法は、図１に示されたシステムで実行されてもよいが、この実装形態に限定されない。図２Ａの方法は、論理ノード１０１．１、１０１．２、および１０１．３の各論理ノードに対して実施されてもよい。これらの実行の結果は、図２Ｂ、図２Ｃ、および図２Ｄを用いて示されている。図２Ａの方法は、例えば、上記で説明された初期または第２の分散方法の代替実装形態を提供することができる。

アプリケーション１０３は、ステップ２０１において、現在の論理ノードに接続してもよい。したがって、現在の論理ノードは、コーディネータ・ノードでもよい。すべての論理ノードが、同じデータベース・システムの一部なので、コーディネータ・ノードは、例えばＳＱＬ文の一部を他のノードに任せることによって、ＳＱＬ文の処理全体を担当してもよい。

例えば、固有のノードへの接続は、属性「ConnectNode=X」を用いてＯＤＢＣにおいて達成されることが可能であり、ここで、Ｘは、固有のノードの数字の識別子である。アプリケーション１０３からのデータベース・リクエストは、分散型データベース・システム１００で使用するのに適した通信プロトコルに変換されてもよい。これらのリクエストは、接続の他のエンドにあるノードによって受け取られ、処理される。これは、アプリケーション１０３が、ローカル・データベースにアクセスするかのように動作するのを可能にすることができる。

現在の論理ノードは、ステップ２０３において、固有の分散ルールに従って現在の論理ノード上の新しいテーブルに格納されることになる複数の論理ノードのうちのソース・ノードからの行を識別してもよい。例えば、ステップ２０３は、固有の分散ルールに従って現在の論理ノードに格納されることになる行をすべての論理ノードから選択するだけのＳＱＬ文を実行してもよい。図１の例に続いて、各論理ノード内の元のテーブルは、ＭＯＤ関数を含む分散ルールに従って現在の論理ノードにコピーされる必要がある行を選択するために使用されてもよい。

識別された行は、ステップ２０５において、元のテーブルから取り出され、現在の論理ノードの新しいテーブルに格納されてもよい。これは、ソース・ノードから現在の論理ノードに行をプルすることを可能にすることができる。ステップ２０３および２０５の実行は、アプリケーション１０３によってトリガまたは開始されてもよい。例えば、アプリケーション１０３は、ステップ２０３および２０５を実施するように、（例えば制御信号を通じて）現在の論理ノードを制御してもよい。

２つのステップ２０３および２０５は、例えば、INSERT INTO 「新しいテーブル」; SELECT * FROM 「元のテーブル」; WHERE <現在の接続先ノードに格納されることになる行を識別する述語>; ORDER BY…というＳＱＬ文を使用して実行されてもよい。

ORDER BYという最後の文は、ソート順に従って新しいテーブルに挿入または格納される前に、選択された行をソートすることを可能にする。コーディネータ・ノードは、ＳＱＬ文を準備し、ＳＱＬ文のクエリ部分（すなわち、ＷＨＥＲＥ文を含むＳＥＬＥＣＴ文）を各論理ノードに送ってもよい。各論理ノードは、このＳＥＬＥＣＴ文を実行し、データ自体を格納したデータの（部分的な）結果のセットを生み出す。各論理ノードは、その（部分的な）結果のセットをコーディネータ・ノードに送り返す。これらは、図２Ｂ、図２Ｃ、および図２Ｄの、元のテーブルからコーディネータ・ノードへと指し示す黒い矢印によって指示されている。コーディネータ・ノードは、（自体を生み出したものを含む）すべて部分的な結果のセットを組み合わせ、すべての行をソートし、次いで、すべての行を新しいテーブルに書き出す。

ＷＨＥＲＥ文の述語は、現在の論理ノードにおいてコピーされることになる行を選択することを可能にする。ＷＨＥＲＥ文の述語は、現在の論理ノードに格納されることになる行すべてを識別する。

第１の述語の例では、述語は、以下のような分散ルールを使用して定義されてもよい。ＭＯＤ関数を含む上記の分散ルールに続いて、述語（およびしたがって、ＷＨＥＲＥ文）は、WHERE MOD(ID,3) = CURRENT DBPARTITIONNUMのように定義され、ここで、CURRENT DBPARTITIONNUMは、現在の論理ノードの識別子を指す。

第２の述語の例では、述語は、以下のように定義されてもよい。ルックアップ・テーブルは、CREATETABLE 「ルックアップ・テーブル」 (<新しい分散キー列>) DISTRIBUTE BY (...); INSERT INTO 「ルックアップ・テーブル」; SELECT UNIQUE <新しい分散キー列>; FROM 「元のテーブル」のように、ノードのそれぞれにおいて構築されてもよい。

ルックアップ・テーブルは、行分散が基づく値すべてを含む。ルックアップ・テーブルは、規則的なテーブルであり、同じ分散キーを新しいテーブルとして使用するので、ルックアップ・テーブルに挿入されたすべての行が、ターゲット分散を既に使用することになる。恩恵は、ルックアップ・テーブルは、ずっと少ない列を有するので、ルックアップ・テーブルを構築することは、すべての行を元のテーブルから新しいテーブルにコピーするよりもずっと速くなり得ることである。したがって、ルックアップ・テーブルのデータ量は著しく小さくなり、これは、２倍のネットワーク通信が各ルックアップ行に対して必要になり得るとしても、ルックアップ・テーブルを構築するのに必要なリソースが少なくなることを意味する。

ルックアップ・テーブルが存在する場合、ＷＨＥＲＥ節は、WHERE <分散キー列> IN; (SELECT *; FROM 「ルックアップ・テーブル」;WHERE DBPARTITITONNUM(id) = CURRENT DBPARTITIONNUM)のように定義されてもよい。

ここで、ｉｄという引数は、「ルックアップ・テーブル」内の列のうちの１つを指す。ＷＨＥＲＥ節は、新しい分散ルールに従って現在の論理ノードに格納されることになる「元のテーブル」内のすべての行を識別する。これは、現在のノードに実際に格納された分散キーのすべての値（またはその組合せ）を識別することによって行われる。したがって、分散キーに同じ値を有する「元のテーブル」内のすべての行も、現在の論理ノードに格納されることになる。これらの行のそれぞれが、（新しい）分散キーのこれらの列を単に備えるので、これらの行のそれぞれは、現在の論理ノードにコピーされることになる元のテーブル内のすべての行を識別するために使用されることが可能である。

ステップ２０３および２０５を実行するためのアルゴリズムが、より複雑になる場合、アルゴリズムは、ネイティブＳＱＬではなく、ユーザ定義関数で実行するものと考えられてもよい。したがって、第３の述語の例では、（例えば、getTargetLogicalNodeと名付けられた）ユーザ定義関数が使用されてもよい。分散型データベース・システム１００は、既に、分散方法の実行を行っていてもよい。ユーザ定義関数は、これを活用するように書かれることが可能である。ユーザ定義関数は、新しい分散キーに関与する列の値を入力として受け取ってもよい。ユーザ定義関数は、分散キー列のリストと一緒に、値をデータベース・システムに渡す。データベース・システムは、受け取られた値のためのターゲット・ノードを判定する。ターゲット・ノードは、関数によって返される。このケースでは、ＳＱＬ文は、INSERT INTO 「新しいテーブル」; SELECT * FROM 「元のテーブル」; WHERE getTargetLogicalNode(<分散キー列>)= CURRENT DBPARTITIONNUM; ORDER BY...になる。

図１の分散型データベース・システム１００の例に続いて、図２の方法は、３つの論理ノード１０１においてステップ２０１から２０５をそれぞれ３回実行することを可能にすることができ、すなわち、ステップ２０１から２０５は、３つの論理ノード１０１のそれぞれにおいて実行されてもよい。これは、図２Ｂ、図２Ｃ、および図２Ｄに指示されている。図２Ｂは、コーディネータ・ノードと考えられる論理ノード１０１．１のためにステップ２０１から２０５を実行した結果を指示する。図２Ｂの元のテーブルからコーディネータ・ノードへと指し示す矢印は、コーディネータ・ノード１０１．１に格納される必要がある各元のテーブルの選択された行の伝送を指示する。すべての受け取られた行が、コーディネータ・ノード１０１．１によってソートされ、次いで、コーディネータ・ノード１０１．１の新しいテーブルに格納される。同様に、図２Ｃは、コーディネータ・ノードと考えられる論理ノード１０１．２のためにステップ２０１から２０５を実行した結果を指示する。図２Ｃの元のテーブルからコーディネータ・ノードへと指し示す矢印は、コーディネータ・ノード１０１．２に格納される必要がある各元のテーブルの選択された行の伝送を指示する。すべての受け取られた行が、コーディネータ・ノード１０１．２によってソートされ、次いで、コーディネータ・ノード１０１．２の新しいテーブルに格納される。図２Ｄは、コーディネータ・ノードと考えられる論理ノード１０１．３のためにステップ２０１から２０５を実行した結果を指示する。図２Ｄの元のテーブルからコーディネータ・ノードへと指し示す矢印は、コーディネータ・ノード１０１．３に格納される必要がある各元のテーブルの選択された行の伝送を指示する。すべての受け取られた行が、コーディネータ・ノード１０１．３によってソートされ、次いで、コーディネータ・ノード１０１．３の新しいテーブルに格納される。

図３は、分散型データベース・システムにおけるテーブルの行を分散させるための方法のフローチャートである。図３で説明される方法は、図１に示されたシステムで実行されてもよいが、この実装形態に限定されない。図３の方法は、論理ノード１０１．１から１０１．３の各論理ノードによって実施されてもよく、各論理ノードは、被コーディネート・ノード（coordinated node）と呼ばれてもよい。

ステップ３０１において、被コーディネート・ノードは、コーディネータ・ノードに格納されることになる行を選択したいというリクエストをコーディネータ・ノードから受け取ってもよい。リクエストを受け取ると、被コーディネート・ノードは、ステップ３０３において、コーディネータ・ノードに格納されることになる行を、被コーディネート・ノードの元のテーブルから選択してもよい。このために、コーディネータ・ノードに割り当てられる行を識別するために、分散方法の分散ルールが元のテーブルの行に適用されてもよい。被コーディネート・ノードは、ステップ３０５において、選択された行をコーディネータ・ノードに送ってもよい。

図４は、分散型データベース・システムにおけるテーブルの行を分散させるための方法のフローチャートである。図４で説明される方法は、図１に示されたシステムで実行されてもよいが、この実装形態に限定されない。図４の方法は、論理ノード１０１．１から１０１．３の各論理ノードによって実施されてもよく、各論理ノードは、コーディネータ・ノードと呼ばれてもよい。

ステップ４０１では、コーディネータ・ノードは、アプリケーション１０３からリクエストを受け取ってもよい。リクエストは、分散方法に従って、コーディネータ・ノードにテーブルの行を格納したいというものでよい。受け取られたリクエストは、例えば、INSERT INTO <新しいテーブル>; SELECT * FROM<古いテーブル>; WHERE <現在の接続先ノードに格納されることになる行を識別する述語>; ORDER BY...というＳＱＬ文を含んでもよい。

コーディネータ・ノードは、ステップ４０３において、ＳＱＬ文を実行してもよい。すべての論理ノードが、同じデータベース・システムの一部なので、コーディネータ・ノードは、ＳＱＬ文の全体処理を担当する。コーディネータ・ノードは、他のノードにこの一部を任せる。より詳細には、コーディネータ・ノードは、ＳＱＬ文を準備し、クエリ部分（「SELECT * FROM... WHERE...」というラインだけ）を各論理ノードに送る。各論理ノードは、このＳＥＬＥＣＴ文を実行し、これ自体を格納したデータのための（部分的な）結果のセットを生み出す。各ノードは、その（部分的な）結果のセットをコーディネータ・ノードに送り返す。コーディネータは、また、独自の部分的な結果を生み出すために、ＳＥＬＥＣＴ文をローカルに実行してもよい。

コーディネータ・ノードは、ステップ４０５において、（これ自体を生み出したものを含む）すべての部分的な結果のセットを組み合わせ、すべての行をソートし、次いで、すべての行を新しいテーブルに書き出す。

図５は、本開示に含まれるような、方法ステップの少なくとも一部を実行するのに適した一般的なコンピュータ化システム７００を表す。

本明細書で説明された方法は、少なくとも部分的に双方向ではなく、サーバまたは組込みシステムなどの、コンピュータ化システムによって自動化されることが理解されよう。だが、例示的な実施形態では、本明細書で説明された方法は、（部分的に）双方向システムにおいて実行されることが可能である。これらの方法は、さらに、ソフトウェア７１２、７２２（ファームウェア７２２を含む）、ハードウェア（プロセッサ）７０５、または、その組合せで実行されることが可能である。例示的な実施形態では、本明細書で説明された方法は、実行可能プログラムのようなソフトウェアで実行され、パーソナル・コンピュータ、ワークステーション、ミニコンピュータ、またはメインフレーム・コンピュータなどの、特殊または汎用デジタル・コンピュータによって実行される。したがって、最も一般的なシステム７００は、汎用コンピュータ７０１を含む。

例示的な実施形態では、図５に示されているような、ハードウェア・アーキテクチャの観点から、コンピュータ７０１は、プロセッサ７０５、メモリ・コントローラ７１５に連結されたメモリ（メイン・メモリ）７１０、および、ローカル入出力コントローラ７３５を介して通信するように連結された１つまたは複数の入出力（Ｉ／Ｏ）デバイス１０、７４５を含む。入出力コントローラ７３５は、当技術分野で知られているような、１つまたは複数のバスまたは他の有線もしくはワイヤレス接続であることが可能であるがこれらに限定されない。入出力コントローラ７３５は、通信を可能にするために、コントローラ、バッファ（キャッシュ）、ドライバ、リピータ、およびレシーバなどの追加の要素を有してもよいが、これらの要素は、簡潔さのために省略される。さらに、ローカル・インターフェースは、前述の構成要素間の適切な通信を可能にするための、アドレス、制御、またはデータ接続、あるいはその組合せを含む。本明細書で説明されるように、Ｉ／Ｏデバイス１０、７４５は、一般に、当技術分野で知られた任意の一般的な暗号カードまたはスマート・カードを含んでもよい。

プロセッサ７０５は、特にメモリ７１０に格納されたソフトウェアを実行するためのハードウェア・デバイスである。プロセッサ７０５は、任意の特注もしくは市販のプロセッサ、中央処理ユニット（ＣＰＵ）、コンピュータ７０１に関連付けられたいくつかのプロセッサ間の補助プロセッサ、半導体ベースのマイクロプロセッサ（マイクロチップもしくはチップ・セットの形式）、または、一般にソフトウェア命令を実行するための任意のデバイスであることが可能である。

メモリ７１０は、揮発性メモリ要素（例えば、ランダム・アクセス・メモリ（ＤＲＡＭ、ＳＲＡＭ、ＳＤＲＡＭなどの、ＲＡＭ））および不揮発性メモリ要素（例えば、ＲＯＭ、消去可能プログラマブル・リード・オンリ・メモリ（ＥＰＲＯＭ）、電子的消去可能プログラマブル・リード・オンリ・メモリ（ＥＥＰＲＯＭ）、プログラマブル・リード・オンリ・メモリ（ＰＲＯＭ））のうちのいずれか１つまたは組合せを含むことができる。メモリ７１０は、様々な構成要素が互いにリモートに置かれる分散型アーキテクチャを有することができるが、プロセッサ７０５によってアクセスされることが可能であることに留意されたい。

メモリ７１０内のソフトウェアは、１つまたは複数の別個のプログラムを含んでもよく、プログラムのそれぞれは、特に本発明の実施形態に含まれる機能といった、論理機能を実行するための実行可能命令の並べられたリストを備える。図５の例では、メモリ７１０内のソフトウェアは、例えばデータベース管理システムなどのデータベースを管理するための命令といった、命令を含む。

メモリ７１０内のソフトウェアは、また、典型的には、適切なオペレーティング・システム（ＯＳ）７１１を含むことになる。ＯＳ７１１は、本質的に、場合によっては本明細書で説明されるような方法を実行するためのソフトウェア７１２などの、他のコンピュータ・プログラムの実行を制御する。

ソフトウェア７１２での本明細書で説明された方法は、ソース・プログラム、実行可能プログラム（オブジェクト・コード）、スクリプト、または、実施されることになる命令のセットを備える任意の他のエンティティの形式でもよい。ソース・プログラムのとき、プログラムは、ＯＳ７１１と接続して適切に動作するように、コンパイラ、アセンブラ、インタープリタ、または同様のものを介して翻訳される必要があり、これらは、メモリ７１０内に含まれても含まれなくてもよい。さらに、方法は、データおよび方法のクラスを有するオブジェクト指向プログラミング言語、あるいは、ルーチン、サブルーチン、もしくは関数、またはその組合せを有する手続き型プログラミング言語として書かれることが可能である。

例示的な実施形態では、従来のキーボード７５０およびマウス７５５は、入出力コントローラ７３５に連結されることが可能である。Ｉ／Ｏデバイス７４５などの他の出力デバイスは、例えば、プリンタ、スキャナ、マイクロフォン、および同様のものであるがこれらに限定されない、入力デバイスを含んでもよい。最終的に、Ｉ／Ｏデバイス１０、７４５は、例えば、（他のファイル、デバイス、システム、またはネットワークにアクセスするための）ネットワーク・インターフェース・カード（ＮＩＣ）または変調器／復調器、無線周波数（ＲＦ）または他のトランシーバ、電話インターフェース、ブリッジ、ルータ、および同様のものであるがこれらに限定されない、入力と出力両方を通信するデバイスをさらに含んでもよい。Ｉ／Ｏデバイス１０、７４５は、当技術分野で知られた任意の一般的な暗号カードまたはスマート・カードであることが可能である。システム７００は、ディスプレイ７３０に連結されたディスプレイ・コントローラ７２５をさらに含むことができる。例示的な実施形態では、システム７００は、ネットワーク７６５に連結するためのネットワーク・インターフェースをさらに含むことができる。ネットワーク７６５は、ブロードバンド接続を介して、コンピュータ７０１と、任意の外部サーバ、クライアント、および同様のものとの間の通信のための、ＩＰベースのネットワークであることが可能である。ネットワーク７６５は、本明細書で論じられる方法のステップの一部またはすべてを実施するために含まれることが可能な、コンピュータ７０１と外部システム３０との間でデータを送受信する。例示的な実施形態では、ネットワーク７６５は、サービス・プロバイダによって運営された、管理されたＩＰネットワークであることが可能である。ネットワーク７６５は、例えば、ＷｉＦｉ、ＷｉＭＡＸなどの、ワイヤレス・プロトコルおよび技術を使用して、ワイヤレスで実行されてもよい。ネットワーク７６５は、また、ローカル・エリア・ネットワーク、ワイド・エリア・ネットワーク、メトロポリタン・エリア・ネットワーク、インターネット・ネットワーク、または他の類似のタイプのネットワーク環境などの、パケット交換型ネットワークであることが可能である。ネットワーク７６５は、固定型ワイヤレス・ネットワーク、ワイヤレス・ローカル・エリア・ネットワーク（ＷＬＡＮ）、ワイヤレス・ワイド・エリア・ネットワーク（ＷＷＡＮ）、パーソナル・エリア・ネットワーク（ＰＡＮ）、仮想プライベート・ネットワーク（ＶＰＮ）、イントラネットまたは他の適切なネットワーク・システムでもよく、信号を送受信するための機器を含む。

コンピュータ７０１が、ＰＣ、ワークステーション、インテリジェント・デバイス、または同様のものである場合、メモリ７１０内のソフトウェアは、ファームウェア７２２に含まれる基本入出力システム（ＢＩＯＳ：basic input output system）をさらに含んでもよい。ＢＩＯＳは、スタート・アップ時にハードウェアを初期化およびテストし、ＯＳ７１１をスタートし、ハードウェア・デバイス間のデータ転送をサポートする、根本的なソフトウェア・ルーチンのセットである。ＢＩＯＳは、コンピュータ７０１がアクティブにされたときにＢＩＯＳを実行できるようにＲＯＭに格納される。

コンピュータ７０１が動作中のとき、プロセッサ７０５は、メモリ７１０内に格納されたソフトウェア７１２を実行し、メモリ７１０との間でデータを通信し、ソフトウェアに従ってコンピュータ７０１の動作を全体的に制御するように構成される。本明細書で説明された方法およびＯＳ７１１は、全体的または部分的に、しかし典型的には後者で、プロセッサ７０５によって読み込まれ、場合によってはプロセッサ７０５内にバッファされ、その後実行される。

本明細書で説明されるシステムおよび方法が、図５に示されたように、ソフトウェア７１２で実装されるとき、方法は、任意のコンピュータ関連のシステムもしくは方法によってまたはこれらと共に使用するために、ストレージ７２０などの任意のコンピュータ可読媒体に格納されることが可能である。ストレージ７２０は、ＨＤＤストレージなどのディスク・ストレージを含めてもよい。

本発明は、統合の任意の可能な技術詳細レベルにおける、システム、方法、またはコンピュータ・プログラム製品、あるいはその組合せでもよい。コンピュータ・プログラム製品は、本発明の態様をプロセッサに実行させるためのコンピュータ可読プログラム命令を有するコンピュータ可読ストレージ媒体（または複数の媒体）を含んでもよい。

コンピュータ可読ストレージ媒体は、命令実行デバイスによる使用のための命令を保持し、格納することができる有形デバイスであることが可能である。コンピュータ可読ストレージ媒体は、例えば、電子ストレージ・デバイス、磁気ストレージ・デバイス、光ストレージ・デバイス、電磁気ストレージ・デバイス、半導体ストレージ・デバイス、または前述の任意の適切な組合せでもよいがこれらに限定されない。コンピュータ可読ストレージ媒体のより具体的な例の完全に網羅されていないリストは、ポータブル・コンピュータ・ディスケット、ハードディスク、ランダム・アクセス・メモリ（ＲＡＭ）、リード・オンリ・メモリ（ＲＯＭ）、消去可能プログラマブル・リード・オンリ・メモリ（ＥＰＲＯＭまたはフラッシュ・メモリ）、スタティック・ランダム・アクセス・メモリ（ＳＲＡＭ）、ポータブル・コンパクト・ディスク・リード・オンリ・メモリ（ＣＤ－ＲＯＭ）、デジタル・バーサタイル・ディスク（ＤＶＤ）、メモリ・スティック、フロッピー（Ｒ）・ディスク、命令を記録したパンチ・カードまたは溝内隆起構造などの機械的にエンコードされたデバイス、および前述の任意の適切な組合せを含む。本明細書で使用されるようなコンピュータ可読ストレージ媒体は、電波もしくは他の自由に伝搬する電磁波、導波路もしくは他の伝送媒体を通じて伝搬する電磁波（例えば、光ファイバ・ケーブルを通過する光パルス）、またはワイヤを通じて伝送される電気信号などの、本質的に一時的な信号であると解釈されるべきではない。

本明細書で説明されるコンピュータ可読プログラム命令は、コンピュータ可読ストレージ媒体からそれぞれの計算／処理デバイスに、あるいは、例えば、インターネット、ローカル・エリア・ネットワーク、ワイド・エリア・ネットワーク、もしくはワイヤレス・ネットワーク、またはその組合せといったネットワークを介して、外部コンピュータまたは外部ストレージ・デバイスに、ダウンロードされることが可能である。ネットワークは、銅伝送ケーブル、光伝送ファイバ、ワイヤレス伝送、ルータ、ファイアウォール、スイッチ、ゲートウェイ・コンピュータ、またはエッジ・サーバ、あるいはその組合せを備えてもよい。各計算／処理デバイス内のネットワーク・アダプタ・カードまたはネットワーク・インターフェースは、コンピュータ可読プログラム命令をネットワークから受け取り、それぞれの計算／処理デバイス内のコンピュータ可読ストレージ媒体に格納するためにコンピュータ可読プログラム命令を転送する。

本発明の動作を実行するためのコンピュータ可読プログラム命令は、アセンブラ命令、インストラクション・セット・アーキテクチャ（ＩＳＡ）命令、機械語命令、機械依存命令、マイクロコード、ファームウェア命令、状態設定データ、集積回路機器用の構成データ、または、Ｓｍａｌｌｔａｌｋ（Ｒ）、Ｃ＋＋、もしくは同様のものなどのオブジェクト指向プログラミング言語、および「Ｃ」プログラミング言語もしくは類似のプログラミング言語などの手続き型プログラミング言語を含む、１つもしくは複数のプログラミング言語の任意の組合せで書かれたソース・コードもしくはオブジェクト・コードでもよい。コンピュータ可読プログラム命令は、全面的にユーザのコンピュータ上で、または部分的にユーザのコンピュータ上で、スタンド・アロンのソフトウェア・パッケージとして、あるいは、部分的にユーザのコンピュータ上かつ部分的にリモート・コンピュータ上で、または全面的にリモート・コンピュータもしくはサーバ上で実行することができる。後者のシナリオでは、リモート・コンピュータは、ローカル・エリア・ネットワーク（ＬＡＮ）もしくはワイド・エリア・ネットワーク（ＷＡＮ）を含む任意のタイプのネットワークを通じてユーザのコンピュータに接続されてもよく、または、接続は、（例えば、インターネット・サービス・プロバイダを使用してインターネットを通じて）外部コンピュータに対して行われてもよい。いくつかの実施形態では、例えば、プログラム可能論理回路機器、フィールド・プログラマブル・ゲート・アレイ（ＦＰＧＡ）、またはプログラマブル・ロジック・アレイ（ＰＬＡ）を含む電子回路機器は、本発明の態様を実施するために、コンピュータ可読プログラム命令の状態情報を利用して電子回路機器を個別化することによって、コンピュータ可読プログラム命令を実行することができる。

本発明の態様は、本発明の実施形態による、方法、装置（システム）、およびコンピュータ・プログラム製品の流れ図またはブロック図あるいはその両方を参照しながら本明細書で説明される。流れ図またはブロック図あるいはその両方の各ブロック、および流れ図またはブロック図あるいはその両方におけるブロックの組合せは、コンピュータ可読プログラム命令によって実行可能であることが理解されよう。

これらのコンピュータ可読プログラム命令は、コンピュータまたは他のプログラム可能データ処理装置のプロセッサによって実行する命令が、流れ図またはブロック図あるいはその両方の１つまたは複数のブロックで指定された機能／行為を実行するための手段を作り出すべく、機械を生み出すためにコンピュータまたは他のプログラム可能データ処理装置のプロセッサに提供されてもよい。これらのコンピュータ可読プログラム命令は、また、流れ図またはブロック図あるいはその両方の１つまたは複数のブロックで指定された機能／行為の態様を実行する命令を含む製品を、命令を格納したコンピュータ可読ストレージ媒体が備えるべく、コンピュータ可読ストレージ媒体に格納されてもよく、特定の様式で機能するように、コンピュータ、プログラム可能データ処理装置、または他のデバイス、あるいはその組合せに指図することができる。

コンピュータ可読プログラム命令は、また、コンピュータ、他のプログラム可能装置、または他のデバイス上で実行する命令が、流れ図またはブロック図あるいはその両方の１つまたは複数のブロックで指定された機能／行為を実行するべく、コンピュータ実行処理を生み出すために、コンピュータ、他のプログラム可能装置、または他のデバイス上で一連の動作ステップが実施されるように、コンピュータ、他のプログラム可能データ処理装置、または他のデバイスにロードされてもよい。

図中の流れ図およびブロック図は、本発明の様々な実施形態によるシステム、方法、およびコンピュータ・プログラム製品の可能な実装形態のアーキテクチャ、機能、および動作を示す。この点に関して、流れ図またはブロック図の中の各ブロックは、指定の論理機能を実行するための１つまたは複数の実行可能命令を含む、命令のモジュール、セグメント、または一部を表すことができる。いくつかの代替実装形態では、ブロックに記された機能は、図に記された順序からはずれて行われてもよい。例えば、連続して示された２つのブロックは、実際には、同時に、実質的に同時に、部分的もしくは全面的に時間重複した様式で実行される１つのステップとして遂行されてもよく、または、ブロックは、時には、含まれる機能に応じて、逆の順序で実行されてもよい。ブロック図または流れ図あるいはその両方の各ブロック、および、ブロック図または流れ図あるいはその両方におけるブロックの組合せは、指定の機能もしくは行為を行うか、または、専用ハードウェアとコンピュータ命令との組合せを実行する専用ハードウェア・ベースのシステムによって実行できることも指摘されることになる。

Claims (14)

1. 分散型データベース・システム内の論理ノードにわたってテーブルの行をコピーするためのコンピュータ実行方法であって、複数の論理ノードのうちの各論理ノードについて、１つまたは複数のコンピュータ・プロセッサによって、
   前記複数の論理ノードのうちの現在の論理ノードに接続することと、
   前記現在の論理ノード上のターゲット・テーブルに格納されることになる１つまたは複数の行を前記複数の論理ノードのうちの１つまたは複数のソース・ノードから選択することであって、前記１つまたは複数の行が、前記分散型データベース・システムにおけるデータを分散させるための分散ルールに基づいて選択される、前記選択することと、
   前記１つまたは複数の行を前記ターゲット・テーブルに格納することであって、前記１つまたは複数の行が、前記１つまたは複数のソース・ノードからプルされ、前記現在の論理ノードに格納される、前記格納することと
   を含み、
   前記複数の論理ノードのうちの前記１つまたは複数の候補ソース・ノードが、前記複数の論理ノードのうちのすべての論理ノード、および、前記現在の論理ノードにデータを提供することが予測される前記複数の論理ノードのうちのすべての予測されるノードからなるグループから選択され、さらに、前記複数の論理ノードのうちの前記１つまたは複数の候補ソース・ノードが、前記現在の論理ノードをターゲット・ノードとして識別した前記１つまたは複数の候補ソース・ノードの各ノードである、
   方法。
2. 前記選択することが、
   各ノードに関連付けられた前記複数の論理ノードのうちの前記１つまたは複数のソース・ノードからの前記１つまたは複数の行を格納するために、前記複数の論理ノードのうちの各現在の論理ノード内に元のテーブルを作成すること
   をさらに含む、請求項１に記載のコンピュータ実行方法。
3. 前記選択することが、
   前記１つまたは複数のコンピュータ・プロセッサによって、前記ターゲット・テーブルに格納されることになる前記１つまたは複数の行を前記複数の論理ノードのうちの前記１つまたは複数のソース・ノードから選択するための初期の分散ルールを適用することであって、前記１つまたは複数の行は、前記ターゲット・テーブルに格納されていない、前記適用すること
   をさらに含む、請求項１に記載のコンピュータ実行方法。
4. 前記分散ルールが、前記初期の分散ルールとは異なり、前記初期の分散ルールは、前記分散型データベース・システムの初期の格納に関連付けられている、請求項３に記載のコンピュータ実行方法。
5. 前記分散ルールは、前記初期の分散ルールと同じであり、前記初期の分散ルールは、前記分散型データベース・システムの初期の格納に関連付けられている、請求項３に記載のコンピュータ実行方法。
6. 前記選択することが、
   前記複数の論理ノードのうちの１つまたは複数の候補ソース・ノードを判定することであって、前記候補ソース・ノードが、前記複数の論理ノードのうちのすべての論理ノード、および、前記現在の論理ノードにデータを提供することが予測される前記複数の論理ノードのうちのすべての予測されるノードを含むグループから選択され、さらに、前記複数の論理ノードのうちの前記１つまたは複数の候補ソース・ノードが、前記現在の論理ノードを前記ターゲット・ノードとして識別した、前記判定することと、
   前記１つまたは複数の行のそれぞれの行を、前記１つまたは複数の行のそれぞれの行が格納されることになる前記複数の論理ノードのうちの１つの論理ノードに割り当てることであって、前記１つまたは複数の行それぞれの行が、前記分散型データベース・システム内の前記データを分散させるための前記分散ルールを使用して割り当てられる、前記割り当てることと
   をさらに含む、請求項１に記載のコンピュータ実行方法。
7. 前記格納することが、
   前記分散ルールの分散キーの別個の値を含むルックアップ・テーブルを作成することと、
   前記ルックアップ・テーブルを使用して、前記ターゲット・ノードおよび１つまたは複数の対応する行を識別することと
   をさらに含む、請求項１に記載のコンピュータ実行方法。
8. 前記複数の論理ノードのうちの前記１つまたは複数のソース・ノードから選択された前記１つまたは複数の行をソートし、ソート順に従って前記１つまたは複数の行を前記ターゲット・テーブルに格納することをさらに含む、請求項１に記載のコンピュータ実行方法。
9. 前記分散型データベース・システムが、第１の分散方法に従って前記複数の論理ノードにわたって前記テーブルの前記１つまたは複数の行を分散させるように構成され、さらに、分散が、前記分散ルールを使用して第２の分散方法に従って行を再分散させたいというリクエストを受け取ることに応答して実施される、請求項１に記載のコンピュータ実行方法。
10. 前記第１の分散方法が、前記分散型データベース・システムにおける前記テーブルの行を最初に分散させるように構成された初期の分散方法であり、結果として、前記複数の論理ノードが、前記テーブルのそれぞれの行を有する、請求項９に記載のコンピュータ実行方法。
11. 前記選択することが、
    前記複数の論理ノードのうちの１つまたは複数の候補ソース・ノードを判定することと、
    前記現在の論理ノードに格納されることになる行を選択するための選択リクエストを前記複数の論理ノードのうちの各候補ソース・ノードに送ることと、
    前記選択リクエストが送られたことに応答して、１つまたは複数の識別された行を候補論理ノードから受け取ることと
    をさらに含む、請求項１に記載のコンピュータ実行方法。
12. 前記分散ルールが、前記複数の論理ノードにわたって行を均一に分散させること、同じ論理ノード内の分散キーの指定された範囲内のすべての行をグループ化すること、および前記同じ論理ノード内の前記分散キーの類似の値を有するすべての行をグループ化することのうちの少なくとも１つを含む、請求項１に記載のコンピュータ実行方法。
13. 分散型データベース・システム内の論理ノードにわたってテーブルの行をコピーするためのコンピュータ・プログラムであって、複数の論理ノードのうちの各論理ノードについて、１つまたは複数のコンピュータ・プロセッサに、請求項１ないし１２のいずれかに記載の方法の各手順を実行させるためのコンピュータ・プログラム。
14. １つまたは複数のコンピュータ・プロセッサと、１つまたは複数のコンピュータ可読ストレージ媒体とを含むコンピュータ・システムであって、
    前記１つまたは複数のコンピュータ可読ストレージ媒体に、請求項１３に記載のコンピュータ・プログラムが格納され、
    前記１つまたは複数のコンピュータ・プロセッサのうちの少なくとも１つによって、前記コンピュータ・プログラムの前記各手順が実行されて、前記分散型データベース・システム内の前記論理ノードにわたって前記テーブルの前記行がコピーされる、
    コンピュータ・システム。