MaxCompute:Java 用 SDK

Maven を使用して、使用する SDK のバージョンを構成できます。 たとえば、使用する odps-sdk-core のバージョンを指定するには、次の Maven 依存関係を追加します。

<dependency>
  <groupId>com.aliyun.odps</groupId>
  <artifactId>odps-sdk-core</artifactId>
  <version>X.X.X-public</version>
</dependency>

次の表に、Java 用 MaxCompute SDK が提供するパッケージを示します。

Odps クラスは、Java 用 MaxCompute SDK のエントリポイントです。 Odps クラスを使用すると、プロジェクト、テーブル、リソース、関数、インスタンス など、MaxCompute 内のすべてのタイプのオブジェクトにアクセスできます。

AliyunAccount オブジェクトを Odps クラスのコンストラクターに渡して、Odps オブジェクトを作成できます。 次のコードは例を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、Resource Access Management (RAM) コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
odps.setDefaultProject("my_project");
for (Table t : odps.tables()) {
    ....
}              

Projects クラスは、MaxCompute 内のすべてのプロジェクトのコレクションを定義します。 各 MaxCompute プロジェクトは、コレクション内の要素です。 次のコードは例を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
Project p = odps.projects().get("my_exists");
p.reload();
...

run メソッドは、Instance オブジェクトを返します。 Instance オブジェクトから、SQL 文のステータスと実行結果を取得できます。 次のコードは例を示しています。

import java.util.List;
import com.aliyun.odps.Instance;
import com.aliyun.odps.Odps;
import com.aliyun.odps.OdpsException;
import com.aliyun.odps.account.Account;
import com.aliyun.odps.account.AliyunAccount;
import com.aliyun.odps.data.Record;
import com.aliyun.odps.task.SQLTask;
public class TestSql {
        // Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
				// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
				// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
				private static String accessId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
				private static String accessKey = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");     
        private static final String endPoint = "http://service.odps.aliyun.com/api";
        private static final String project = "";
        private static final String sql = "select category from iris;";
    public static void
        main(String[] args) {
        Account account = new AliyunAccount(accessId, accessKey);
        Odps odps = new Odps(account);
        odps.setEndpoint(endPoint);
        odps.setDefaultProject(project);
        Instance i;
        try {
            i = SQLTask.run(odps, sql);
            i.waitForSuccess();
            List<Record> records = SQLTask.getResult(i);
            for(Record r:records){
                System.out.println(r.get(0).toString());
            }
        } catch (OdpsException e) {
            e.printStackTrace();
        }
    }
}

Instances クラスは、MaxCompute 内のすべてのインスタンスのコレクションを定義します。 各インスタンスは、コレクション内の要素です。 次のコードは例を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
odps.setDefaultProject("my_project");
for (Instance i : odps.instances()) {
    ....
}

Instance クラスは、インスタンスの詳細を定義します。 Instances クラスの get メソッドを呼び出すことで、指定されたインスタンスを取得できます。 次のコードは例を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
Instance instance= odps.instances().get("instance id");
Date startTime = instance.getStartTime();
Date endTime = instance.getEndTime();
...
    Status instanceStatus = instance.getStatus();
String instanceStatusStr = null;
if (instanceStatus == Status.TERMINATED) {
    instanceStatusStr = TaskStatus.Status.SUCCESS.toString();
    Map<String, TaskStatus> taskStatus = instance.getTaskStatus();
    for (Entry<String, TaskStatus> status : taskStatus.entrySet()) {
        if (status.getValue().getStatus() != TaskStatus.Status.SUCCESS) {
            instanceStatusStr = status.getValue().getStatus().toString();
            break;
        }
    }
} else {
    instanceStatusStr = instanceStatus.toString();
}
...
    TaskSummary summary = instance.getTaskSummary("task name");
String s = summary.getSummaryText();

Tables クラスは、MaxCompute 内のすべてのテーブルのコレクションを定義します。 各テーブルは、コレクション内の要素です。 次のコードは例を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
odps.setDefaultProject("my_project");
for (Table t : odps.tables()) {
    ....
}

Table クラスは、テーブルの詳細を定義します。 Tables クラスの get メソッドを呼び出すことで、指定されたテーブルを取得できます。 次のコードは例を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
odps.setDefaultProject("my_project");

Table table = odps.tables().get("tablename");
for(Column c : table.getSchema().getColumns()) 
{
String name = c.getName();
TypeInfo type = c.getTypeInfo();
 }

次のコードは、テーブルのパーティション内のデータを取得する方法を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
Table t = odps.tables().get("table name");
t.reload();
Partition part = t.getPartition(new PartitionSpec("partition_col=partition_col_value"));
part.reload();
...

Resources クラスは、MaxCompute 内のすべてのリソースのコレクションを定義します。 各リソースは、コレクション内の要素です。 次のコードは例を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
odps.setDefaultProject("my_project");
for (Resource r : odps.resources()) {
    ....
}

Resource クラスは、各リソースの詳細を定義します。 Resources クラスの get メソッドを呼び出すことで、指定されたリソースを取得できます。 次のコードは例を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
Resource r = odps.resources().get("resource name");
r.reload();
if (r.getType() == Resource.Type.TABLE) {
    TableResource tr = new TableResource(r);
    String tableSource = tr.getSourceTable().getProject() + "."
        + tr.getSourceTable().getName();
    if (tr.getSourceTablePartition() != null) {
        tableSource += " partition(" + tr.getSourceTablePartition().toString()
            + ")";
    }
    ....
}

次のコードは、ファイルリソースを作成する方法を示しています。

String projectName = "my_porject";
String source = "my_local_file.txt";
File file = new File(source);
InputStream is = new FileInputStream(file);
FileResource resource = new FileResource();
String name = file.getName();
resource.setName(name);
odps.resources().create(projectName, resource, is);

次のコードは、テーブルリソースを作成する方法を示しています。

TableResource resource = new TableResource(tableName, tablePrj, partitionSpec);
//resource.setName(INVALID_USER_TABLE);
resource.setName("table_resource_name");
odps.resources().update(projectName, resource);

Functions クラスは、MaxCompute 内のすべての関数のコレクションを定義します。 各関数は、コレクション内の要素です。 次のコードは例を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
odps.setDefaultProject("my_project");
for (Function f : odps.functions()) {
    ....
}                

Function クラスは、関数の詳細を定義します。 Functions クラスの get メソッドを呼び出すことで、指定された関数を取得できます。 次のコードは例を示しています。

// Alibaba Cloud アカウントの AccessKey ペアには、すべての API 操作に対する権限があります。 AccessKey ペアを使用して API 操作を呼び出すと、リスクが発生する可能性があります。 API 操作の呼び出しや日常的な O&M の実行には、RAM ユーザーを作成して使用することをお勧めします。 RAM ユーザーを作成するには、RAM コンソールにログインします。
// この例では、AccessKey ID と AccessKey シークレットは環境変数として構成されています。 ビジネス要件に基づいて、構成ファイルに AccessKey ペアを保存することもできます。
// AccessKey ペアの漏洩を防ぐため、コード内で AccessKey ID と AccessKey シークレットを直接指定しないことをお勧めします。
Account account = new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Odps odps = new Odps(account);
String odpsUrl = "<your odps endpoint>";
odps.setEndpoint(odpsUrl);
Function f = odps.functions().get("function name");
List<Resource> resources = f.getResources();               

次のコードは、関数を作成する方法を示しています。

String resources = "xxx:xxx";
String classType = "com.aliyun.odps.mapred.open.example.WordCount";
ArrayList<String> resourceList = new ArrayList<String>();
for (String r : resources.split(":")) {
    resourceList.add(r);
}
Function func = new Function();
func.setName(name);
func.setClassType(classType);
func.setResources(resourceList);
odps.functions().create(projectName, func);