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

[アーティクル]
10/17/2024

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 プロジェクトを作成する

次のコマンドを使用して、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: アプリケーションのテストが含まれます。
生成されたコード例の削除次のコマンドを入力して、生成されたテストとアプリケーションファイル 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 クラスで作成されたテーブルを無効にし、次にそれを削除します。

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

hbaseapp ディレクトリで次のコマンドを使用して、アプリケーションが含まれた JAR ファイルをビルドします。
```
mvn clean package
```
このコマンドは、アプリケーションを .jar ファイルにビルドしてパッケージ化します。
コマンドが完了すると、hbaseapp/target ディレクトリに hbaseapp-1.0-SNAPSHOT.jar という名前のファイルが格納されます。

Note

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

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

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

クラスターに jar をアップロードします。 CLUSTERNAMEを HDInsight クラスター名と置換し、次のコマンドを入力します。
```
scp ./target/hbaseapp-1.0-SNAPSHOT.jar sshuser@CLUSTERNAME-ssh.azurehdinsight.net:hbaseapp-1.0-SNAPSHOT.jar
```
HBase クラスターに接続します。 CLUSTERNAMEを HDInsight クラスター名と置換し、次のコマンドを入力します。
```
ssh sshuser@CLUSTERNAME-ssh.azurehdinsight.net
```
Java アプリケーションを使用する HBase テーブルを作成するには、open ssh 接続で次のコマンドを使用します。
```
yarn jar hbaseapp-1.0-SNAPSHOT.jar com.microsoft.examples.CreateTable
```
このコマンドは、people という名前の HBase テーブルを作成してデータを設定します。

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

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

テーブルを削除するには、次のコマンドを使用します。
```
yarn jar hbaseapp-1.0-SNAPSHOT.jar com.microsoft.examples.DeleteTable
```

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

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

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 - 前に作成されたクラスの実行に使用されます

hbaseappディレクトリ内のhbase-runner.psm1ファイルを保存します。
Azure PowerShell を使用したモジュールを登録します。 Azure PowerShell の新規ウィンドウを開き、次のコマンドを編集して CLUSTERNAME をクラスター名に置き換えます。次のコマンドを入力します。
```
cd C:\HDI\hbaseapp
$myCluster = "CLUSTERNAME"
Import-Module .\hbase-runner.psm1
```
次のコマンドを使用して、クラスターに 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 の場所にアップロードします。
hbaseapp を使用してテーブルを作成するには、次のコマンドを使用します。
```
Start-HBaseExample -className com.microsoft.examples.CreateTable -clusterName $myCluster
```
プロンプトが表示されたら、クラスターのログイン (管理者) 名とパスワードを入力します。

このコマンドにより、HDInsight クラスターでの HBase に people という名前のテーブルが作成されます。このコマンドを実行しても、コンソールウィンドウに出力結果は表示されません。
テーブル内のエントリを検索するには、次のコマンドを使用します。
```
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' から始まる電子メールアドレスが返されます。

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

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

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

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

次のステップ

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

次の方法で共有

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

前提条件

テスト環境

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

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

依存関係を追加する

[ビルド構成]

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

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

CreateTable クラスを実装します。

SearchByEmail クラスを実装します。

DeleteTable クラスを実装します。

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

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

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

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

次のステップ

フィードバック

その他のリソース

次の方法で共有

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

前提条件

テスト環境

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

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

依存関係を追加する

[ビルド構成]

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

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

CreateTable クラスを実装します。

SearchByEmail クラスを実装します。

DeleteTable クラスを実装します。

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

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

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

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

次のステップ

フィードバック

その他のリソース

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