一硬贯、添加自定義參數(shù)
在KuduClientConfig中富雅,添加自定義參數(shù)掸驱,如下
public long getSplitSize()
{
return splitSize;
}
@Config("kudu.split-size")
public KuduClientConfigsetSplitSize(long splitSize)
{
this.splitSize = splitSize;
return this;
}
二、引用自定義參數(shù)
KuduClientSession 在獲取kuduSplit是添加參數(shù)
在方法buildKuduSplits中 添加如下代碼:
KuduScanToken.KuduScanTokenBuilder builder = client.newScanTokenBuilder(table);
builder.setSplitSizeBytes(100);