Compilar aplicativos Java para Apache HBase

Artigo
10/17/2023

Saiba como criar um aplicativo Apache HBase em Java. Depois, use o aplicativo com o HBase no Azure HDInsight.

As etapas deste documento usam o Apache Maven para criar e construir o projeto. Maven é uma ferramenta de software para compreensão e gerenciamento de projetos que permite a você compilar software, documentação e relatórios para projetos Java.

Pré-requisitos

Um cluster do Apache HBase no HDInsight. Consulte Introdução ao Apache HBase.
Java Developer Kit (JDK) versão 8.
Apache Maven corretamente instalado de acordo com o Apache. O Maven é um sistema de construção de projetos para projetos Java.
Um cliente SSH. Para saber mais, confira Conectar-se ao HDInsight (Apache Hadoop) usando SSH.
Se estiver usando o PowerShell, você precisará do Módulo AZ.
Um editor de texto. Este artigo usa o Microsoft Notepad.

Ambiente de teste

O ambiente usado para este artigo foi um computador que executa o Windows 10. Os comandos foram executados em um prompt de comando, e os diversos arquivos foram editados com o Bloco de Notas. Modifique de acordo com o seu ambiente.

Em um prompt de comando, insira os seguintes comandos para criar um ambiente de trabalho:

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

Criar um projeto Maven

Digite o seguinte comando para criar um projeto Maven chamado hbaseapp:
```
mvn archetype:generate -DgroupId=com.microsoft.examples -DartifactId=hbaseapp -DarchetypeArtifactId=maven-archetype-quickstart -DinteractiveMode=false

cd hbaseapp
mkdir conf
```
Esse comando cria um diretório chamado hbaseapp no local atual, que contém um projeto básico do Maven. O segundo comando altera o diretório de trabalho para hbaseapp. O terceiro comando cria um novo diretório, conf, que pode ser usado posteriormente. O diretório hbaseapp contém os seguintes itens:
- pom.xml: O Modelo de Objeto do Projeto (POM) contém informações e detalhes da configuração usados para compilar o projeto.
- src\main\java\com\microsoft\examples: contém o código do aplicativo.
- src\test\java\com\microsoft\examples: contém testes para o seu aplicativo.
Remover o exemplo de código gerado. Exclua os arquivos de teste e de aplicativo gerados AppTest.java, e App.java inserindo os seguintes comandos:
```
DEL src\main\java\com\microsoft\examples\App.java
DEL src\test\java\com\microsoft\examples\AppTest.java
```

Atualize o modelo do objeto do projeto

Para obter uma referência completa do arquivo pom.xml, consulte https://maven.apache.org/pom.html. Abra pom.xml inserindo o seguinte comando:

notepad pom.xml

Adicionar dependências

Ainda no arquivo pom.xml, adicione o seguinte texto à seção <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>

Esta seção indica que o projeto precisa dos componentes hbase-client e phoenix-core. Em tempo de compilação, essa dependência será baixada do repositório padrão do Maven. Você pode usar a Pesquisa de repositório central do Maven para saber mais sobre essa dependência.

Importante

O número da versão do hbase-client deve corresponder à versão do Apache HBase que é fornecida com o cluster do HDInsight. Use a tabela a seguir para localizar o número da versão correta.

Versão do cluster HDInsight	Apache HBase versão a ser usada
3,6	1.1.2
4,0	2.0.0

Para saber mais sobre as versões e os componentes do HDInsight, consulte Quais são os diferentes componentes do Apache Hadoop disponíveis com o HDInsight?.

Configuração de compilação

Plug-ins do Maven permitem que você personalize os estágios de compilação do projeto. Esta seção será usada para adicionar plug-ins, recursos e outras opções de configuração de compilação.

Adicione o código a seguir ao arquivo pom.xml e depois salve e feche o arquivo. Esse texto deve estar dentro das marcas <project>...</project> no arquivo, por exemplo, entre </dependencies> e </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>

Esta seção configura um recurso (conf/hbase-site.xml), que contém informações de configuração para o HBase.

Observação

Você também pode definir valores de configuração via código. Veja os comentários no exemplo CreateTable.

Essa seção também configura o Plug-in Compiler do Apache Maven e o Plug-in Shade do Apache Maven. O plug-in compilador é usado para compilar a topologia. O plug-in de tonalidade é usado para evitar a duplicação de licenças no pacote JAR que é criado pelo Maven. O plug-in serve para evitar o erro de arquivos de licença duplicados no momento da execução no cluster do HDInsight. Utilize o plug-in de tonalidade do Maven com a implementação ApacheLicenseResourceTransformer para isso.

O plug-in de tonalidade do Maven também produzirá um uber jar, que contém todas as dependências exigidas pelo aplicativo.

Baixar o arquivo hbase-site.xml

Use o seguinte comando para copiar a configuração HBase do cluster HBase para o diretório conf. Substitua CLUSTERNAME pelo nome do cluster HDInsight e, em seguida, digite o seguinte comando:

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

Criar o aplicativo

Implementar uma classe CreateTable

Insira o comando a seguir para criar e abrir um novo arquivo CreateTable.java. Selecione Sim no prompt para criar um novo arquivo.

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

Em seguida, copie e cole o código Java a seguir no novo arquivo. Feche o arquivo.

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();
    }
}

Esse código é a classe CreateTable, que cria uma tabela chamada people e a preenche com alguns usuários predefinidos.

Implementar uma classe SearchByEmail

Insira o comando a seguir para criar e abrir um novo arquivo SearchByEmail.java. Selecione Sim no prompt para criar um novo arquivo.

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

Em seguida, copie e cole o código Java a seguir no novo arquivo. Feche o arquivo.

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();
    }
}

A classe SearchByEmail pode ser usada para consultar por linhas, por endereço de email. Já que ele utiliza um filtro de expressão comum, você pode fornecer uma cadeia de caracteres ou então uma expressão comum ao utilizar a classe.

Implementar uma classe DeleteTable

Insira o comando a seguir para criar e abrir um novo arquivo DeleteTable.java. Selecione Sim no prompt para criar um novo arquivo.

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

Em seguida, copie e cole o código Java a seguir no novo arquivo. Feche o arquivo.

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");
    }
}

A classe DeleteTable limpa as tabelas HBase criadas nesse exemplo, desabilitando e eliminando a tabela criada pela classe CreateTable.

Compilar e criar o pacote do aplicativo

Use o diretório hbaseapp, use o comando a seguir para compilar um arquivo JAR que contém o aplicativo:
```
mvn clean package
```
Este comando compila e empacota o aplicativo em um arquivo .jar.
Após a conclusão do comando, o diretório hbaseapp/target conterá um arquivo chamado hbaseapp-1.0-SNAPSHOT.jar.

Observação

O arquivo hbaseapp-1.0-SNAPSHOT.jar é um uber jar. Ele contém todas as dependências exigidas para executar o aplicativo.

Carregue o arquivo JAR e execute trabalhos (SSH)

As etapas a seguir usam scp para copiar o JAR para o nó principal primário de seu Apache HBase no cluster HDInsight. Então, o comando ssh será utilizado para se conectar ao cluster e executar o exemplo diretamente no nó principal.

Carregue o jar no cluster. Substitua CLUSTERNAME pelo nome do cluster HDInsight e, em seguida, digite o seguinte comando:
```
scp ./target/hbaseapp-1.0-SNAPSHOT.jar sshuser@CLUSTERNAME-ssh.azurehdinsight.net:hbaseapp-1.0-SNAPSHOT.jar
```
Conecte-se ao cluster HBase. Substitua CLUSTERNAME pelo nome do cluster HDInsight e, em seguida, digite o seguinte comando:
```
ssh sshuser@CLUSTERNAME-ssh.azurehdinsight.net
```
Para criar uma tabela do HBase usando o aplicativo Java, use o seguinte comando em sua conexão SSH aberta:
```
yarn jar hbaseapp-1.0-SNAPSHOT.jar com.microsoft.examples.CreateTable
```
Esse comando cria uma nova tabela do HBase chamada people e a preenche com dados.

Use o seguinte comando para procurar endereços de email armazenados na tabela:

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

Você receberá as resultados a seguir:

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

Para excluir a tabela, use o seguinte comando:

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

Carregue o arquivo JAR e execute trabalhos (PowerShell)

As etapas a seguir usam o Módulo AZ do Azure PowerShell para carregar o JAR no armazenamento padrão do cluster do Apache HBase. Os cmdlets do HDInsight serão usados para executar os exemplos remotamente.

Depois de instalar e configurar o módulo AZ, crie um arquivo chamado hbase-runner.psm1. Use o seguinte texto como o conteúdo deste arquivo:

 <#
 .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 *-*

Esse arquivo contém dois módulos:

Add-HDInsightFile – utilizado para carregar arquivos no cluster
Start-HBaseExample - utilizado para executar as classes criadas anteriormente

Salve o arquivo hbase-runner.psm1 no diretório hbaseapp.
Registre os módulos com o Azure PowerShell. Abra uma nova janela do Azure PowerShell e edite o comando a seguir substituindo CLUSTERNAME pelo nome do cluster. Digite os seguintes comandos:
```
cd C:\HDI\hbaseapp
$myCluster = "CLUSTERNAME"
Import-Module .\hbase-runner.psm1
```
Use o comando a seguir para carregar o hbaseapp-1.0-SNAPSHOT.jar em seu cluster.
```
Add-HDInsightFile -localPath target\hbaseapp-1.0-SNAPSHOT.jar -destinationPath example/jars/hbaseapp-1.0-SNAPSHOT.jar -clusterName $myCluster
```
Quando solicitado, insira o nome e a senha do logon do cluster (admin). O comando carrega o hbaseapp-1.0-SNAPSHOT.jar no local example/jars no armazenamento primário do cluster.
Para criar uma tabela usando hbaseapp, use o seguinte comando:
```
Start-HBaseExample -className com.microsoft.examples.CreateTable -clusterName $myCluster
```
Quando solicitado, insira o nome e a senha do logon do cluster (admin).

Esse comando cria uma tabela chamada people no HBase em seu cluster HDInsight. Este comando não mostra nenhuma saída na janela do console.
Para procurar por entradas na tabela, use o comando a seguir:
```
Start-HBaseExample -className com.microsoft.examples.SearchByEmail -clusterName $myCluster -emailRegex contoso.com
```
Quando solicitado, insira o nome e a senha do logon do cluster (admin).

Esse comando usa a classe SearchByEmail para procurar por quaisquer linhas nas quais a família de colunas contactinformation e a coluna email contenham a cadeia de caracteres contoso.com. Você deve receber os seguintes resultados:
```
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
```
Usar fabrikam.com como o valor de -emailRegex retornará os usuários que tenham fabrikam.com no campo de email. Você também pode usar expressões regulares como o termo de pesquisa. Por exemplo, ^ r retorna endereços que começam com a letra 'r'.

Para excluir a tabela, use o seguinte comando:

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

Nenhum resultado ou resultados inesperados ao usar o Start-HBaseExample

Utilize o parâmetro -showErr para exibir o erro padrão (STDERR) produzido durante a execução do trabalho.

Próximas etapas

Aprenda a usar o SQLLINE com o Apache HBase

Compartilhar via

Compilar aplicativos Java para Apache HBase

Pré-requisitos

Ambiente de teste

Criar um projeto Maven

Atualize o modelo do objeto do projeto

Adicionar dependências

Configuração de compilação

Baixar o arquivo hbase-site.xml

Criar o aplicativo

Implementar uma classe CreateTable

Implementar uma classe SearchByEmail

Implementar uma classe DeleteTable

Compilar e criar o pacote do aplicativo

Carregue o arquivo JAR e execute trabalhos (SSH)

Carregue o arquivo JAR e execute trabalhos (PowerShell)

Nenhum resultado ou resultados inesperados ao usar o Start-HBaseExample

Próximas etapas

Comentários

Recursos adicionais