adb3client/src/main/java/com/alibaba/cloud/analyticdb/adb3client/impl/collector/shard/DistributionKeyShardPolicy.java [17:25]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private int threadCount;

	@Override
	public void init(int threadCount) {
		this.threadCount = threadCount;
	}

	@Override
	public int locate(Record record) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



adb3client/src/main/java/com/alibaba/cloud/analyticdb/adb3client/impl/collector/shard/RandomShardPolicy.java [16:24]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private int threadCount;

	@Override
	public void init(int threadCount) {
		this.threadCount = threadCount;
	}

	@Override
	public int locate(Record record) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -