Kueri informasi tugas pengiriman - Tablestore SDK untuk Java - Tablestore

Tablestore SDK untuk Java memungkinkan Anda mengkueri konfigurasi pengiriman OSS, jenis tugas, dan status sinkronisasi suatu tugas pengiriman.

Prasyarat

Instal Tablestore SDK untuk Java dan inisialisasi client. Fitur pengiriman data memerlukan versi 5.10.3 atau lebih baru. Disarankan untuk menggunakan versi terbaru.

Deskripsi

Panggil metode describeDeliveryTask untuk mengkueri konfigurasi dan status berjalan suatu tugas pengiriman.

public DescribeDeliveryTaskResponse describeDeliveryTask(DescribeDeliveryTaskRequest request)
        throws TableStoreException, ClientException

Contoh berikut mengkueri tugas pengiriman example_task pada tabel data example_table, lalu mencetak jenis tugas, awalan direktori OSS, dan fase sinkronisasi. Variabel client merupakan client yang telah diinisialisasi.

String tableName = "example_table";
String taskName = "example_task";
DescribeDeliveryTaskRequest request =
        new DescribeDeliveryTaskRequest(tableName, taskName);

DescribeDeliveryTaskResponse response = client.describeDeliveryTask(request);
System.out.println("taskType: " + response.getTaskType());
System.out.println("ossPrefix: " + response.getTaskConfig().getOssPrefix());
System.out.println("taskSyncPhase: "
        + response.getTaskSyncStat().getTaskSyncPhase());

Parameter

Parameter request bertipe DescribeDeliveryTaskRequest dan mencakup informasi berikut.

Name	Type	Description
tableName (required)	String	Nama tabel data.
taskName (required)	String	Nama tugas pengiriman.

Respons

Metode ini mengembalikan objek DescribeDeliveryTaskResponse yang berisi bidang-bidang bisnis berikut.

Name	Type	Description
taskConfig	OSSTaskConfig	Konfigurasi pengiriman OSS.
taskSyncStat	TaskSyncStat	Status sinkronisasi tugas pengiriman.
taskType	DeliveryTaskType	Jenis tugas pengiriman. Nilai yang valid: `BASE` untuk pengiriman penuh, `INC` untuk pengiriman inkremental, dan `BASE_INC` untuk pengiriman penuh diikuti oleh pengiriman inkremental berkelanjutan.

Konfigurasi pengiriman OSS

Bidang taskConfig bertipe OSSTaskConfig dan mencakup elemen-elemen berikut.

Name	Type	Description
ossPrefix	String	Awalan direktori dalam Bucket OSS.
ossBucket	String	Nama Bucket OSS.
ossEndpoint	String	Titik akhir Wilayah tempat Bucket OSS berada.
ossStsRole	String	ARN dari role terkait layanan `AliyunServiceRoleForOTSDataDelivery`.
parquetSchema	List<ParquetSchema>	Bidang yang dikirimkan. Urutan elemen sama dengan urutan bidang dalam file Parquet.
eventTimeColumn	EventColumn	Kolom waktu event. Bidang ini kosong jika tidak ada kolom waktu event yang dikonfigurasi.
format	OSSFileFormat	Format file OSS. Nilai saat ini: `Parquet`.
timeFormatter	TimeFormatter	Format partisi OSS. Nilai saat ini: `YDMFormatter`, yang merepresentasikan format tahun-bulan-hari.

Bidang yang dikirimkan

Setiap elemen dalam larik taskConfig.parquetSchema[] bertipe ParquetSchema dan mencakup bidang-bidang berikut.

Name	Type	Description
columnName	String	Nama bidang sumber dalam tabel data Tablestore.
ossColumnName	String	Nama bidang setelah dikirimkan ke OSS.
type	DataType	Jenis tujuan bidang dalam file Parquet.
encode	OSSFileEncoding	Encoding Parquet.
typeExtend	String	Jenis ekstensi Parquet. Fitur ini tidak didukung, sehingga bidang ini kosong.

Kolom waktu event

Bidang taskConfig.eventTimeColumn bertipe EventColumn dan mencakup elemen-elemen berikut.

Name	Type	Description
columnName	String	Nama bidang sumber yang digunakan sebagai waktu event.
timeFormat	EventTimeFormat	Format waktu event. Nilai yang valid: `RFC822`, `RFC850`, `RFC1123`, `RFC3339`, dan `Unix`.

Status sinkronisasi

Bidang taskSyncStat bertipe TaskSyncStat dan mencakup elemen-elemen berikut.

Name	Type	Description
taskSyncPhase	TaskSyncPhase	Fase sinkronisasi. Nilai yang valid: `INIT` untuk inisialisasi, `FULL` untuk sinkronisasi penuh, dan `INCR` untuk sinkronisasi inkremental.
currentSyncPoint	Date	Titik waktu sinkronisasi saat ini.
errorType	DeliveryErrorType	Jenis error. Nilai yang valid: `OK` untuk tidak ada error, `UNAUTHORIZED` untuk kegagalan otorisasi, dan `INVALID_OSS_BUCKET` untuk Bucket OSS yang tidak valid.
detail	String	Detail mengenai status sinkronisasi atau error.