一、添加自定义参数
在KuduClientConfig中,添加自定义参数,如下
public long getSplitSize()
{
return splitSize;
}
@Config("kudu.split-size")
public KuduClientConfigsetSplitSize(long splitSize)
{
this.splitSize = splitSize;
return this;
}
二、引用自定义参数
KuduClientSession 在获取kuduSplit是添加参数
在方法buildKuduSplits中 添加如下代码:
KuduScanToken.KuduScanTokenBuilder builder = client.newScanTokenBuilder(table);
builder.setSplitSizeBytes(100);