多方式寫入__高級特性_DataHub實時數據通道_大數據計算服務-阿裏雲

按PartitionKey寫入

指定一個String類型參數作為PartitionKey,係統根據該String的MD5值以及Shard的beginHashKey與endHashKey決定寫入的Shard。

該種方式的應用場景與按HashKey寫入方式類似，區別在於用戶不需要提供固定範圍的HashKey，而是通過一個字符串Key，係統會計算出其對應的HashKey進行寫入。

// 新建client
Account account = new AliyunAccount("your access id", "your access key");
DatahubConfiguration conf = new DatahubConfiguration(account, "datahub endpoint");
DatahubClient client = new DatahubClient(conf);
// 構造需要上傳的records
RecordSchema schema = client.getTopic("projectName", "topicName").getRecordSchema();
List<RecordEntry> recordEntries = new ArrayList<~>();
RecordEntry entry = new RecordEntry(schema);
for (int i=0; i<entry.getFieldCount(); i++) {
    entry.setBigint(i, 1);
}
entry.setPartitionKey("TestPartitionKey");
recordEntries.add(entry);
// 數據寫入
client.putRecords("projectName", "topicName", recordEntries);