TableComparatorFactory.java 文件源码

@Autowired
TableComparatorFactory(
    HiveEndpoint source,
    HiveEndpoint replica,
    ComparatorRegistry comparatorRegistry,
    DiffListener diffListener,
    @Value("${sourcePartitionBatchSize:1000}") short sourcePartitionBatchSize,
    @Value("${replicaPartitionBufferSize:1000}") short replicaPartitionBufferSize) {
  this.sourcePartitionBatchSize = sourcePartitionBatchSize;
  this.replicaPartitionBufferSize = replicaPartitionBufferSize;
  this.source = source;
  this.replica = replica;
  this.comparatorRegistry = comparatorRegistry;
  this.diffListener = diffListener;
}