src/java/org/apache/cassandra/tools/SSTableImport.java
/**
     * Add columns to a column family.
     *
     * @param row the columns associated with a row
     * @param superName name of the super column if any
     * @param cfamily the column family to add columns to
     */
Add columns to a column family.
@param row the columns associated with a row
@param superName name of the super column if any
@param cfamily the column family to add columns to
Add columns to a column family . @param row the columns associated with a row @param superName name of the super column if any @param cfamily the column family to add columns to
private static void addColumnsToCF(List<?> row, ByteBuffer superName, ColumnFamily cfamily)
    {
        CFMetaData cfm = cfamily.metadata();
        assert cfm != null;
        for (Object c : row)
        {
            JsonColumn col = new JsonColumn<List>((List) c, cfm, (superName != null));
            QueryPath path = new QueryPath(cfm.cfName, superName, col.getName());
            if (col.isExpiring())
            {
                cfamily.addColumn(null, new ExpiringColumn(col.getName(), col.getValue(), col.timestamp, col.ttl, col.localExpirationTime));
            }
            else if (col.isCounter())
            {
                cfamily.addColumn(null, new CounterColumn(col.getName(), col.getValue(), col.timestamp, col.timestampOfLastDelete));
            }
            else if (col.isDeleted())
            {
                cfamily.addTombstone(path, col.getValue(), col.timestamp);
            }
            else
            {
                cfamily.addColumn(path, col.getValue(), col.timestamp);
            }
        }
    }
private static void addColumnsToCF ( List < ? > row , ByteBuffer superName , ColumnFamily cfamily ) { CFMetaData cfm = cfamily . metadata ( ) ; assert cfm != null ; for ( Object c : row ) { JsonColumn col = new JsonColumn < List > ( ( List ) c , cfm , ( superName != null ) ) ; QueryPath path = new QueryPath ( cfm . cfName , superName , col . getName ( ) ) ; if ( col . isExpiring ( ) ) { cfamily . addColumn ( null , new ExpiringColumn ( col . getName ( ) , col . getValue ( ) , col . timestamp , col . ttl , col . localExpirationTime ) ) ; } else if ( col . isCounter ( ) ) { cfamily . addColumn ( null , new CounterColumn ( col . getName ( ) , col . getValue ( ) , col . timestamp , col . timestampOfLastDelete ) ) ; } else if ( col . isDeleted ( ) ) { cfamily . addTombstone ( path , col . getValue ( ) , col . timestamp ) ; } else { cfamily . addColumn ( path , col . getValue ( ) , col . timestamp ) ; } } }
Add columns to a column family.
Add columns to a column family .