public DiffCluster()

in spark-job/src/main/java/org/apache/cassandra/diff/DiffCluster.java [87:108]

• 21 lines of code
• 1 McCabe index (conditional complexity)

    public DiffCluster(Type clusterId,
                       Cluster cluster,
                       ConsistencyLevel consistencyLevel,
                       RateLimiter getPartitionRateLimiter,
                       int tokenScanFetchSize,
                       int partitionReadFetchSize,
                       int readTimeoutMillis,
                       RetryStrategyProvider retryStrategyProvider)

    {
        this.consistencyLevel = consistencyLevel;
        this.cluster = cluster;
        this.tokenHelper = TokenHelper.forPartitioner(cluster.getMetadata().getPartitioner());
        this.clusterId = clusterId;
        this.tokenList = Collections.emptyList();
        this.getPartitionRateLimiter = getPartitionRateLimiter;
        this.session = cluster.connect();
        this.tokenScanFetchSize = tokenScanFetchSize;
        this.partitionReadFetchSize = partitionReadFetchSize;
        this.readTimeoutMillis = readTimeoutMillis;
        this.retryStrategyProvider = retryStrategyProvider;
    }