private PreparedStatement getStatementForTable()

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

14 lines of code
3 McCabe index (conditional complexity)


    private PreparedStatement getStatementForTable(KeyspaceTablePair keyspaceTablePair, int index) {
        if (!preparedStatements.containsKey(keyspaceTablePair)) {
            synchronized (this) {
                if (!preparedStatements.containsKey(keyspaceTablePair)) {
                    PreparedStatement keyStatement = getKeyStatement(keyspaceTablePair);
                    PreparedStatement[] partitionReadStmts = getFullStatement(keyspaceTablePair);
                    preparedStatements.put(keyspaceTablePair, new PreparedStatement[]{ keyStatement ,
                                                                                       partitionReadStmts[0],
                                                                                       partitionReadStmts[1] });
                }
            }
        }
        return preparedStatements.get(keyspaceTablePair)[index];
    }