src/java/org/apache/cassandra/db/transaction/PendingTransactionMutation.java
/* To mark columns as in a pending transaction, we'll apply the normal
     * mutation except we'll use PendingTransactionColumns instead of what's
     * ultimately intended
     */
To mark columns as in a pending transaction, we'll apply the normal
mutation except we'll use PendingTransactionColumns instead of what's
ultimately intended
To mark columns as in a pending transaction we ' ll apply the normal mutation except we ' ll use PendingTransactionColumns instead of what ' s ultimately intended
public void makePending(QueryPath path)
    {
        Integer id = Schema.instance.getId(table_, path.columnFamilyName);
        ColumnFamily columnFamily = modifications_.get(id);
        if (columnFamily == null)
        {
            columnFamily = ColumnFamily.create(table_, path.columnFamilyName);
            modifications_.put(id, columnFamily);
        }
        columnFamily.addPendingTransactionColumn(path, transactionId, pendingTime);
    }
public void makePending ( QueryPath path ) { Integer id = Schema . instance . getId ( table_ , path . columnFamilyName ) ; ColumnFamily columnFamily = modifications_ . get ( id ) ; if ( columnFamily == null ) { columnFamily = ColumnFamily . create ( table_ , path . columnFamilyName ) ; modifications_ . put ( id , columnFamily ) ; } columnFamily . addPendingTransactionColumn ( path , transactionId , pendingTime ) ; }
To mark columns as in a pending transaction, we'll apply the normal
 mutation except we'll use PendingTransactionColumns instead of what's
 ultimately intended
To mark columns as in a pending transaction we ' ll apply the normal mutation except we ' ll use PendingTransactionColumns instead of what ' s ultimately intended