src/java/org/apache/cassandra/tools/SSTableImport.java
/**
     * Add super columns to a column family.
     *
     * @param row the super columns associated with a row
     * @param cfamily the column family to add columns to
     */
Add super columns to a column family.
@param row the super columns associated with a row
@param cfamily the column family to add columns to
Add super columns to a column family . @param row the super columns associated with a row @param cfamily the column family to add columns to
private static void addToSuperCF(Map<?, ?> row, ColumnFamily cfamily)
    {
        CFMetaData metaData = cfamily.metadata();
        assert metaData != null;
        AbstractType comparator = metaData.comparator;
        for (Map.Entry<?, ?> entry : row.entrySet())
        {
            Map<?, ?> data = (Map<?, ?>) entry.getValue();
            addColumnsToCF((List<?>) data.get("subColumns"), stringAsType((String) entry.getKey(), comparator), cfamily);
        }
    }
private static void addToSuperCF ( Map < ? , ? > row , ColumnFamily cfamily ) { CFMetaData metaData = cfamily . metadata ( ) ; assert metaData != null ; AbstractType comparator = metaData . comparator ; for ( Map . Entry < ? , ? > entry : row . entrySet ( ) ) { Map < ? , ? > data = ( Map < ? , ? > ) entry . getValue ( ) ; addColumnsToCF ( ( List < ? > ) data . get ( "subColumns" ) , stringAsType ( ( String ) entry . getKey ( ) , comparator ) , cfamily ) ; } }
Add super columns to a column family.
Add super columns to a column family .
// Super columns // *WARNING* markForDeleteAt has been DEPRECATED at Cassandra side //BigInteger deletedAt = (BigInteger) data.get("deletedAt"); //SuperColumn superColumn = (SuperColumn) cfamily.getColumn(superName); //superColumn.markForDeleteAt((int) (System.currentTimeMillis()/1000), deletedAt);