public Iterator getPartition()

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

• 15 lines of code
• 2 McCabe index (conditional complexity)

    public Iterator<Row> getPartition(TableSpec table, PartitionKey key, boolean shouldReverse) {
        try {
            RetryStrategy retryStrategy = retryStrategyProvider.get();
            return retryStrategy.retry(
                () -> readPartition(table.getTable(), key, shouldReverse)
                          .getUninterruptibly()
                          .iterator()
            );
        }
        catch (Exception ex) {
            throw new RuntimeException(String.format("Unable to get partition (%s) in table (%s) from cluster (%s)",
                                                     key.getTokenAsBigInteger(), table, clusterId.name()),
                                       ex);
        }
    }