private void maybeRebuildClusteringKeys()

in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/sparksql/SparkCellIterator.java [364:383]

• 19 lines of code
• 7 McCabe index (conditional complexity)

    private void maybeRebuildClusteringKeys(@NotNull ByteBuffer columnNameBuf)
    {
        List<CqlField> clusteringKeys = cqlTable.clusteringKeys();
        if (clusteringKeys.isEmpty())
        {
            return;
        }

        int index = 0;
        for (CqlField field : clusteringKeys)
        {
            Object newObj = deserialize(field, ColumnTypes.extractComponent(columnNameBuf, index++));
            Object oldObj = values[field.position()];
            if (newRow || oldObj == null || newObj == null || !field.equals(newObj, oldObj))
            {
                newRow = true;
                values[field.position()] = newObj;
            }
        }
    }