多方式写入__高级特性_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);