Apache HBase 向けの Java アプリケーションの構築

Java で Apache HBase アプリケーションを作成する方法を説明します。 その後、このアプリケーションを Azure HDInsight での HBase で使用します。

このドキュメントの手順では、Apache Maven を使用して、プロジェクトを作成およびビルドします。 Maven は、Java プロジェクトのソフトウェア、ドキュメント、レポートを作成するためのソフトウェア プロジェクト管理および包含ツールです。

前提条件

• HDInsight 内の Apache HBase クラスター 「Apache HBase の使用」を参照してください。

• Java Developer キット (JDK) バージョン 8

• Apache に従って適切にインストールされた Apache Maven。 Maven は Java プロジェクトのプロジェクト ビルド システムです。

• SSH クライアント 詳細については、SSH を使用して HDInsight (Apache Hadoop) に接続する方法に関するページを参照してください。

• PowerShell を使用している場合は、AZ モジュールが必要です。

• テキスト エディター。 この記事では、Microsoft Notepad を使用します。

テスト環境

この記事で使用された環境は、Windows 10 を実行しているコンピューターです。 コマンドはコマンド プロンプトで実行され、さまざまなファイルがメモ帳で編集されています。 ご使用の環境に応じて変更します。

コマンド プロンプトで次のコマンドを入力して、作業環境を作成します。

IF NOT EXIST C:\HDI MKDIR C:\HDI
cd C:\HDI

Maven プロジェクトを作成する

1. 次のコマンドを使用して、hbaseapp という名前の Maven プロジェクトを作成します。

   mvn archetype:generate -DgroupId=com.microsoft.examples -DartifactId=hbaseapp -DarchetypeArtifactId=maven-archetype-quickstart -DinteractiveMode=false
   
   cd hbaseapp
   mkdir conf
   

   このコマンドは、基本的な Maven プロジェクトを含む hbaseapp という名前のディレクトリを現在の場所に作成します。 2 番目のコマンドでは、作業ディレクトリを hbaseapp に変更します。 3 番目のコマンドでは、後で使用できる新しいディレクトリ (conf) を作成します。 hbaseapp ディレクトリには、次の項目が含まれます。

   • pom.xml: プロジェクト オブジェクト モデル (POM) には、プロジェクトのビルドに使用される情報と構成の詳細が含まれています。
   • src\main\java\com\microsoft\examples: アプリケーション コードが含まれます。
   • src\test\java\com\microsoft\examples: アプリケーションのテストが含まれます。

2. 生成されたコード例の削除 次のコマンドを入力して、生成されたテストとアプリケーション ファイル AppTest.java と App.java を削除します。

   DEL src\main\java\com\microsoft\examples\App.java
   DEL src\test\java\com\microsoft\examples\AppTest.java
   

プロジェクト オブジェクト モデルを更新する

pom.xml ファイルの完全なリファレンスについては、https://maven.apache.org/pom.htmlを参照してください。 次のコマンドを入力して、pom.xml を開きます。

notepad pom.xml

依存関係を追加する

pom.xml で、<dependencies> セクションの次のテキストを追加します。

<dependency>
    <groupId>org.apache.hbase</groupId>
    <artifactId>hbase-shaded-client</artifactId>
    <version>1.1.2</version>
</dependency>
<dependency>
    <groupId>org.apache.phoenix</groupId>
    <artifactId>phoenix-core</artifactId>
    <version>4.14.1-HBase-1.1</version>
</dependency>

このセクションは、プロジェクトに hbase-client および phoenix-core コンポーネントが必要であることを示しています。 この依存関係は、コンパイル時に既定の Maven リポジトリからダウンロードされます。 Maven セントラル リポジトリ検索 を使用して、この依存関係についての詳細を確認できます。

重要

hbase-client のバージョン番号は、HDInsight クラスターに付属の Apache HBase のバージョンと一致する必要があります。 次の表を使用して、正しいバージョン番号を調べてください。

HDInsight クラスターのバージョン	使用する Apache HBase のバージョン
3.6	1.1.2
4.0	2.0.0

HDInsight のバージョンとコンポーネントの詳細については、HDInsight で使用できるさまざまな Apache Hadoop コンポーネントに関するページを参照してください。

[ビルド構成]

Maven プラグインでは、プロジェクトのビルド ステージをカスタマイズできます。 このセクションは、プラグインやリソース、他のビルド構成オプションを追加する際に使用します。

pom.xml ファイルに次のコードを追加し、ファイルを保存し閉じます。 このテキストは、ファイルの <project>...</project> タグ内に配置する必要があります (たとえば </dependencies> と </project> の間)。

<build>
    <sourceDirectory>src</sourceDirectory>
    <resources>
    <resource>
        <directory>${basedir}/conf</directory>
        <filtering>false</filtering>
        <includes>
        <include>hbase-site.xml</include>
        </includes>
    </resource>
    </resources>
    <plugins>
    <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
                <version>3.8.1</version>
        <configuration>
            <source>1.8</source>
            <target>1.8</target>
        </configuration>
        </plugin>
    <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-shade-plugin</artifactId>
        <version>3.2.1</version>
        <configuration>
        <transformers>
            <transformer implementation="org.apache.maven.plugins.shade.resource.ApacheLicenseResourceTransformer">
            </transformer>
        </transformers>
        </configuration>
        <executions>
        <execution>
            <phase>package</phase>
            <goals>
            <goal>shade</goal>
            </goals>
        </execution>
        </executions>
    </plugin>
    </plugins>
</build>

このセクションにより、HBase の構成情報が含まれたリソース (conf/hbase-site.xml) が構成されます。

Note

コードを介して構成値を設定することもできます。 CreateTable サンプル内のコメントをご覧ください。

このセクションによって、Apache Maven Compiler Plugin と Apache Maven Shade Plugin も構成されます。 トポロジのコンパイルにはコンパイラ プラグインが使用されます。 シャードのプラグインは、Maven でビルドされる JAR パッケージ内のライセンスの重複を防ぐために使用されます。 このプラグインは、HDInsight クラスターでの実行時に発生する "ライセンス ファイルの重複" エラーを回避するために使用されます。 maven-shade-plugin を ApacheLicenseResourceTransformer 実装で使用すると、エラーを回避できます。

また、maven-shade-plugin は、アプリケーションで必要とされるすべての依存関係を含む uber jar も生成します。

hbase-site.xml のダウンロード

次のコマンドを使用して、HBase クラスターから conf ディレクトリに HBase の構成をコピーします。 CLUSTERNAMEを HDInsight クラスター名と置換し、コマンドを入力します。

scp sshuser@CLUSTERNAME-ssh.azurehdinsight.net:/etc/hbase/conf/hbase-site.xml ./conf/hbase-site.xml

アプリケーションを作成する

CreateTable クラスを実装します。

次のコマンドを入力して、新しいファイル CreateTable.java を作成して開きます。 プロンプトが表示されたら [YES] を選択して新しいファイルを作成します。

notepad src\main\java\com\microsoft\examples\CreateTable.java

次に、次の Java コードをコピーして新しいファイルに貼り付けます。 その後、ファイルを閉じます。

package com.microsoft.examples;
import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;

public class CreateTable {
    public static void main(String[] args) throws IOException {
    Configuration config = HBaseConfiguration.create();

    // Example of setting zookeeper values for HDInsight
    // in code instead of an hbase-site.xml file
    //
    // config.set("hbase.zookeeper.quorum",
    //            "zookeepernode0,zookeepernode1,zookeepernode2");
    //config.set("hbase.zookeeper.property.clientPort", "2181");
    //config.set("hbase.cluster.distributed", "true");
    //
    //NOTE: Actual zookeeper host names can be found using Ambari:
    //curl -u admin:PASSWORD -G "https://CLUSTERNAME.azurehdinsight.net/api/v1/clusters/CLUSTERNAME/hosts"

    //Linux-based HDInsight clusters use /hbase-unsecure as the znode parent
    config.set("zookeeper.znode.parent","/hbase-unsecure");

    // create an admin object using the config
    HBaseAdmin admin = new HBaseAdmin(config);

    // create the table...
    HTableDescriptor tableDescriptor = new HTableDescriptor(TableName.valueOf("people"));
    // ... with two column families
    tableDescriptor.addFamily(new HColumnDescriptor("name"));
    tableDescriptor.addFamily(new HColumnDescriptor("contactinfo"));
    admin.createTable(tableDescriptor);

    // define some people
    String[][] people = {
        { "1", "Marcel", "Haddad", "marcel@fabrikam.com"},
        { "2", "Franklin", "Holtz", "franklin@contoso.com" },
        { "3", "Dwayne", "McKee", "dwayne@fabrikam.com" },
        { "4", "Rae", "Schroeder", "rae@contoso.com" },
        { "5", "Rosalie", "burton", "rosalie@fabrikam.com"},
        { "6", "Gabriela", "Ingram", "gabriela@contoso.com"} };

    HTable table = new HTable(config, "people");

    // Add each person to the table
    //   Use the `name` column family for the name
    //   Use the `contactinfo` column family for the email
    for (int i = 0; i< people.length; i++) {
        Put person = new Put(Bytes.toBytes(people[i][0]));
        person.add(Bytes.toBytes("name"), Bytes.toBytes("first"), Bytes.toBytes(people[i][1]));
        person.add(Bytes.toBytes("name"), Bytes.toBytes("last"), Bytes.toBytes(people[i][2]));
        person.add(Bytes.toBytes("contactinfo"), Bytes.toBytes("email"), Bytes.toBytes(people[i][3]));
        table.put(person);
    }
    // flush commits and close the table
    table.flushCommits();
    table.close();
    }
}

このコードは、CreateTable クラスであり、people という名前のテーブルを作成し定義済みユーザーで値を入力します。

SearchByEmail クラスを実装します。

次のコマンドを入力して、新しいファイル SearchByEmail.java を作成して開きます。 プロンプトが表示されたら [YES] を選択して新しいファイルを作成します。

notepad src\main\java\com\microsoft\examples\SearchByEmail.java

次に、次の Java コードをコピーして新しいファイルに貼り付けます。 その後、ファイルを閉じます。

package com.microsoft.examples;
import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.filter.RegexStringComparator;
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.util.GenericOptionsParser;

public class SearchByEmail {
    public static void main(String[] args) throws IOException {
    Configuration config = HBaseConfiguration.create();

    // Use GenericOptionsParser to get only the parameters to the class
    // and not all the parameters passed (when using WebHCat for example)
    String[] otherArgs = new GenericOptionsParser(config, args).getRemainingArgs();
    if (otherArgs.length != 1) {
        System.out.println("usage: [regular expression]");
        System.exit(-1);
    }

    // Open the table
    HTable table = new HTable(config, "people");

    // Define the family and qualifiers to be used
    byte[] contactFamily = Bytes.toBytes("contactinfo");
    byte[] emailQualifier = Bytes.toBytes("email");
    byte[] nameFamily = Bytes.toBytes("name");
    byte[] firstNameQualifier = Bytes.toBytes("first");
    byte[] lastNameQualifier = Bytes.toBytes("last");

    // Create a regex filter
    RegexStringComparator emailFilter = new RegexStringComparator(otherArgs[0]);
    // Attach the regex filter to a filter
    //   for the email column
    SingleColumnValueFilter filter = new SingleColumnValueFilter(
        contactFamily,
        emailQualifier,
        CompareOp.EQUAL,
        emailFilter
    );

    // Create a scan and set the filter
    Scan scan = new Scan();
    scan.setFilter(filter);

    // Get the results
    ResultScanner results = table.getScanner(scan);
    // Iterate over results and print  values
    for (Result result : results ) {
        String id = new String(result.getRow());
        byte[] firstNameObj = result.getValue(nameFamily, firstNameQualifier);
        String firstName = new String(firstNameObj);
        byte[] lastNameObj = result.getValue(nameFamily, lastNameQualifier);
        String lastName = new String(lastNameObj);
        System.out.println(firstName + " " + lastName + " - ID: " + id);
        byte[] emailObj = result.getValue(contactFamily, emailQualifier);
        String email = new String(emailObj);
        System.out.println(firstName + " " + lastName + " - " + email + " - ID: " + id);
    }
    results.close();
    table.close();
    }
}

SearchByEmail クラスを使用し、メール アドレスによって行を照会できます。 正規表現フィルターが使用されるため、このクラスを使用するときに文字列または正規表現を指定できます。

DeleteTable クラスを実装します。

次のコマンドを入力して、新しいファイル DeleteTable.java を作成して開きます。 プロンプトが表示されたら [YES] を選択して新しいファイルを作成します。

notepad src\main\java\com\microsoft\examples\DeleteTable.java

次に、次の Java コードをコピーして新しいファイルに貼り付けます。 その後、ファイルを閉じます。

package com.microsoft.examples;
import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HBaseAdmin;

public class DeleteTable {
    public static void main(String[] args) throws IOException {
    Configuration config = HBaseConfiguration.create();

    // Create an admin object using the config
    HBaseAdmin admin = new HBaseAdmin(config);

    // Disable, and then delete the table
    admin.disableTable("people");
    admin.deleteTable("people");
    }
}

DeleteTable クラスは、このサンプルの HBase テーブルをクリーンアップするため、最初にCreateTable クラスで作成されたテーブルを無効にし、次にそれを削除します。

アプリケーションをビルドおよびパッケージ化する

1. hbaseapp ディレクトリで次のコマンドを使用して、アプリケーションが含まれた JAR ファイルをビルドします。

   mvn clean package
   

   このコマンドは、アプリケーションを .jar ファイルにビルドしてパッケージ化します。

2. コマンドが完了すると、hbaseapp/target ディレクトリに hbaseapp-1.0-SNAPSHOT.jar という名前のファイルが格納されます。

   Note

   hbaseapp-1.0-SNAPSHOT.jar ファイルは、uber jar です。 これには、アプリケーションを実行するために必要なすべての依存関係が含まれます。

JAR をアップロードしてジョブを実行する (SSH)

次の手順では、scp を使用して、HDInsight クラスターの Apache HBase のプライマリ ヘッドノードに JAR をコピーします。 その後、ssh コマンドを使用してクラスターに接続し、ヘッド ノードで例を直接実行します。

1. クラスターに jar をアップロードします。 CLUSTERNAMEを HDInsight クラスター名と置換し、次のコマンドを入力します。

   scp ./target/hbaseapp-1.0-SNAPSHOT.jar sshuser@CLUSTERNAME-ssh.azurehdinsight.net:hbaseapp-1.0-SNAPSHOT.jar
   

2. HBase クラスターに接続します。 CLUSTERNAMEを HDInsight クラスター名と置換し、次のコマンドを入力します。

   ssh sshuser@CLUSTERNAME-ssh.azurehdinsight.net
   

3. Java アプリケーションを使用する HBase テーブルを作成するには、open ssh 接続で次のコマンドを使用します。

   yarn jar hbaseapp-1.0-SNAPSHOT.jar com.microsoft.examples.CreateTable
   

   このコマンドは、people という名前の HBase テーブルを作成してデータを設定します。

4. テーブルに格納されている電子メール アドレスを検索するには、次のコマンドを使用します。

   yarn jar hbaseapp-1.0-SNAPSHOT.jar com.microsoft.examples.SearchByEmail contoso.com
   

   次の結果が表示されます。

   Franklin Holtz - ID: 2
   Franklin Holtz - franklin@contoso.com - ID: 2
   Rae Schroeder - ID: 4
   Rae Schroeder - rae@contoso.com - ID: 4
   Gabriela Ingram - ID: 6
   Gabriela Ingram - gabriela@contoso.com - ID: 6
   

5. テーブルを削除するには、次のコマンドを使用します。

   yarn jar hbaseapp-1.0-SNAPSHOT.jar com.microsoft.examples.DeleteTable
   

JAR をアップロードしてジョブを実行する (PowerShell)

次の手順では、Azure PowerShell AZ モジュールを使用して、JAR を Apache HBase クラスターの既定のストレージにアップロードします。 その後、HDInsight コマンドレットを使用して、例をリモートで実行します。

1. AZ モジュール をインストールし、構成した後で、hbase-runner.psm1 という名前のファイルを作成します。 このファイルの内容として、次のテキストを使用します。

    <#
    .SYNOPSIS
    Copies a file to the primary storage of an HDInsight cluster.
    .DESCRIPTION
    Copies a file from a local directory to the blob container for
    the HDInsight cluster.
    .EXAMPLE
    Start-HBaseExample -className "com.microsoft.examples.CreateTable"
    -clusterName "MyHDInsightCluster"
   
    .EXAMPLE
    Start-HBaseExample -className "com.microsoft.examples.SearchByEmail"
    -clusterName "MyHDInsightCluster"
    -emailRegex "contoso.com"
   
    .EXAMPLE
    Start-HBaseExample -className "com.microsoft.examples.SearchByEmail"
    -clusterName "MyHDInsightCluster"
    -emailRegex "^r" -showErr
    #>
   
    function Start-HBaseExample {
    [CmdletBinding(SupportsShouldProcess = $true)]
    param(
    #The class to run
    [Parameter(Mandatory = $true)]
    [String]$className,
   
    #The name of the HDInsight cluster
    [Parameter(Mandatory = $true)]
    [String]$clusterName,
   
    #Only used when using SearchByEmail
    [Parameter(Mandatory = $false)]
    [String]$emailRegex,
   
    #Use if you want to see stderr output
    [Parameter(Mandatory = $false)]
    [Switch]$showErr
    )
   
    Set-StrictMode -Version 3
   
    # Is the Azure module installed?
    FindAzure
   
    # Get the login for the HDInsight cluster
    $creds=Get-Credential -Message "Enter the login for the cluster" -UserName "admin"
   
    # The JAR
    $jarFile = "wasb:///example/jars/hbaseapp-1.0-SNAPSHOT.jar"
   
    # The job definition
    $jobDefinition = New-AzHDInsightMapReduceJobDefinition `
        -JarFile $jarFile `
        -ClassName $className `
        -Arguments $emailRegex
   
    # Get the job output
    $job = Start-AzHDInsightJob `
        -ClusterName $clusterName `
        -JobDefinition $jobDefinition `
        -HttpCredential $creds
    Write-Host "Wait for the job to complete ..." -ForegroundColor Green
    Wait-AzHDInsightJob `
        -ClusterName $clusterName `
        -JobId $job.JobId `
        -HttpCredential $creds
    if($showErr)
    {
    Write-Host "STDERR"
    Get-AzHDInsightJobOutput `
                -Clustername $clusterName `
                -JobId $job.JobId `
                -HttpCredential $creds `
                -DisplayOutputType StandardError
    }
    Write-Host "Display the standard output ..." -ForegroundColor Green
    Get-AzHDInsightJobOutput `
                -Clustername $clusterName `
                -JobId $job.JobId `
                -HttpCredential $creds
    }
   
    <#
    .SYNOPSIS
    Copies a file to the primary storage of an HDInsight cluster.
    .DESCRIPTION
    Copies a file from a local directory to the blob container for
    the HDInsight cluster.
    .EXAMPLE
    Add-HDInsightFile -localPath "C:\temp\data.txt"
    -destinationPath "example/data/data.txt"
    -ClusterName "MyHDInsightCluster"
    .EXAMPLE
    Add-HDInsightFile -localPath "C:\temp\data.txt"
    -destinationPath "example/data/data.txt"
    -ClusterName "MyHDInsightCluster"
    -Container "MyContainer"
    #>
   
    function Add-HDInsightFile {
        [CmdletBinding(SupportsShouldProcess = $true)]
        param(
            #The path to the local file.
            [Parameter(Mandatory = $true)]
            [String]$localPath,
   
            #The destination path and file name, relative to the root of the container.
            [Parameter(Mandatory = $true)]
            [String]$destinationPath,
   
            #The name of the HDInsight cluster
            [Parameter(Mandatory = $true)]
            [String]$clusterName,
   
            #If specified, overwrites existing files without prompting
            [Parameter(Mandatory = $false)]
            [Switch]$force
        )
   
        Set-StrictMode -Version 3
   
        # Is the Azure module installed?
        FindAzure
   
        # Get authentication for the cluster
        $creds=Get-Credential
   
        # Does the local path exist?
        if (-not (Test-Path $localPath))
        {
            throw "Source path '$localPath' does not exist."
        }
   
        # Get the primary storage container
        $storage = GetStorage -clusterName $clusterName
   
        # Upload file to storage, overwriting existing files if -force was used.
        Set-AzStorageBlobContent -File $localPath `
            -Blob $destinationPath `
            -force:$force `
            -Container $storage.container `
            -Context $storage.context
    }
   
    function FindAzure {
        # Is there an active Azure subscription?
        $sub = Get-AzSubscription -ErrorAction SilentlyContinue
        if(-not($sub))
        {
            Connect-AzAccount
        }
    }
   
    function GetStorage {
        param(
            [Parameter(Mandatory = $true)]
            [String]$clusterName
        )
        $hdi = Get-AzHDInsightCluster -ClusterName $clusterName
        # Does the cluster exist?
        if (!$hdi)
        {
            throw "HDInsight cluster '$clusterName' does not exist."
        }
        # Create a return object for context & container
        $return = @{}
        $storageAccounts = @{}
   
        # Get storage information
        $resourceGroup = $hdi.ResourceGroup
        $storageAccountName=$hdi.DefaultStorageAccount.split('.')[0]
        $container=$hdi.DefaultStorageContainer
        $storageAccountKey=(Get-AzStorageAccountKey `
            -Name $storageAccountName `
        -ResourceGroupName $resourceGroup)[0].Value
        # Get the resource group, in case we need that
        $return.resourceGroup = $resourceGroup
        # Get the storage context, as we can't depend
        # on using the default storage context
        $return.context = New-AzStorageContext -StorageAccountName $storageAccountName -StorageAccountKey $storageAccountKey
        # Get the container, so we know where to
        # find/store blobs
        $return.container = $container
        # Return storage accounts to support finding all accounts for
        # a cluster
        $return.storageAccount = $storageAccountName
        $return.storageAccountKey = $storageAccountKey
   
        return $return
    }
    # Only export the verb-phrase things
    export-modulemember *-*
   

   このファイルには 2 つのモジュールが含まれます。

   • Add-HDInsightFile - クラスターへのファイルのアップロードに使用されます
   • Start-HBaseExample - 前に作成されたクラスの実行に使用されます

2. hbaseappディレクトリ内のhbase-runner.psm1ファイルを保存します。

3. Azure PowerShell を使用したモジュールを登録します。 Azure PowerShell の新規ウィンドウを開き、次のコマンドを編集して CLUSTERNAME をクラスター名に置き換えます。 次のコマンドを入力します。

   cd C:\HDI\hbaseapp
   $myCluster = "CLUSTERNAME"
   Import-Module .\hbase-runner.psm1
   

4. 次のコマンドを使用して、クラスターに hbaseapp-1.0-SNAPSHOT.jar をアップロードします。

   Add-HDInsightFile -localPath target\hbaseapp-1.0-SNAPSHOT.jar -destinationPath example/jars/hbaseapp-1.0-SNAPSHOT.jar -clusterName $myCluster
   

   プロンプトが表示されたら、クラスターのログイン (管理者) 名とパスワードを入力します。 このコマンドは、hbaseapp-1.0-SNAPSHOT.jar をクラスターのプライマリ ストレージの example/jars の場所にアップロードします。

5. hbaseapp を使用してテーブルを作成するには、次のコマンドを使用します。

   Start-HBaseExample -className com.microsoft.examples.CreateTable -clusterName $myCluster
   

   プロンプトが表示されたら、クラスターのログイン (管理者) 名とパスワードを入力します。

   このコマンドにより、HDInsight クラスターでの HBase に people という名前のテーブルが作成されます。 このコマンドを実行しても、コンソール ウィンドウに出力結果は表示されません。

6. テーブル内のエントリを検索するには、次のコマンドを使用します。

   Start-HBaseExample -className com.microsoft.examples.SearchByEmail -clusterName $myCluster -emailRegex contoso.com
   

   プロンプトが表示されたら、クラスターのログイン (管理者) 名とパスワードを入力します。

   このコマンドは SearchByEmail クラスを使用して、contactinformation の列ファミリの email 列に文字列 contoso.com が含まれている行を検索します。 次の結果が表示されます。

   Franklin Holtz - ID: 2
   Franklin Holtz - franklin@contoso.com - ID: 2
   Rae Schroeder - ID: 4
   Rae Schroeder - rae@contoso.com - ID: 4
   Gabriela Ingram - ID: 6
   Gabriela Ingram - gabriela@contoso.com - ID: 6
   

   -emailRegex の値に fabrikam.com を使用すると、メール フィールドに fabrikam.com が含まれているユーザーが返されます。 検索用語に正規表現を使用することもできます。 たとえば、^r で検索すると、'r' から始まる電子メール アドレスが返されます。

7. テーブルを削除するには、次のコマンドを使用します。

   Start-HBaseExample -className com.microsoft.examples.DeleteTable -clusterName $myCluster
   

Start-HBaseExample を使用したときに、結果が表示されないか、予期しない結果が表示される

-showErr パラメーターを使用して、ジョブの実行中に生成された標準エラー (STDERR) を表示します。

次のステップ

Apache HBase と SQLLine を使用する方法を確認する