org.apache.cassandra.db
Class ColumnFamily

java.lang.Object
  extended by org.apache.cassandra.db.ColumnFamily
All Implemented Interfaces:
IColumnContainer

public final class ColumnFamily
extends java.lang.Object
implements IColumnContainer


Field Summary
static short utfPrefix_
           
 
Constructor Summary
ColumnFamily(java.lang.String cfName, java.lang.String columnType, AbstractType comparator, AbstractType subcolumnComparator)
           
 
Method Summary
 void addColumn(IColumn column)
           
 void addColumn(QueryPath path, byte[] value, long timestamp)
           
 void addColumn(QueryPath path, byte[] value, long timestamp, boolean deleted)
          In most places the CF must be part of a QueryPath but here it is ignored.
 void clear()
           
 ColumnFamily cloneMeShallow()
           
static ColumnFamily create(java.lang.String tableName, java.lang.String cfName)
           
 void delete(ColumnFamily cf2)
           
 void delete(int localtime, long timestamp)
           
 boolean equals(java.lang.Object o)
           
 IColumn getColumn(byte[] name)
           
 java.util.SortedSet<byte[]> getColumnNames()
           
 ICompactSerializer2<IColumn> getColumnSerializer()
           
 java.util.Map<byte[],IColumn> getColumnsMap()
           
static java.lang.String getColumnType(java.lang.String key)
           
 AbstractType getComparator()
           
static AbstractType getComparatorFor(java.lang.String table, java.lang.String columnFamilyName, byte[] superColumnName)
           
 int getLocalDeletionTime()
           
 long getMarkedForDeleteAt()
           
 java.util.Collection<IColumn> getSortedColumns()
           
 int hashCode()
           
 boolean isMarkedForDelete()
           
 boolean isSuper()
           
 java.lang.String name()
           
 void remove(byte[] columnName)
           
 int serializedSize()
           
static ColumnFamilySerializer serializer()
           
 java.lang.String toString()
           
 java.lang.String type()
           
 void updateDigest(java.security.MessageDigest digest)
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Field Detail

utfPrefix_

public static final short utfPrefix_
See Also:
Constant Field Values
Constructor Detail

ColumnFamily

public ColumnFamily(java.lang.String cfName,
                    java.lang.String columnType,
                    AbstractType comparator,
                    AbstractType subcolumnComparator)
Method Detail

serializer

public static ColumnFamilySerializer serializer()

getColumnType

public static java.lang.String getColumnType(java.lang.String key)

create

public static ColumnFamily create(java.lang.String tableName,
                                  java.lang.String cfName)

cloneMeShallow

public ColumnFamily cloneMeShallow()

name

public java.lang.String name()

getColumnSerializer

public ICompactSerializer2<IColumn> getColumnSerializer()

isSuper

public boolean isSuper()

addColumn

public void addColumn(QueryPath path,
                      byte[] value,
                      long timestamp)

addColumn

public void addColumn(QueryPath path,
                      byte[] value,
                      long timestamp,
                      boolean deleted)
In most places the CF must be part of a QueryPath but here it is ignored.


clear

public void clear()

addColumn

public void addColumn(IColumn column)
Specified by:
addColumn in interface IColumnContainer

getColumn

public IColumn getColumn(byte[] name)

getColumnNames

public java.util.SortedSet<byte[]> getColumnNames()

getSortedColumns

public java.util.Collection<IColumn> getSortedColumns()

getColumnsMap

public java.util.Map<byte[],IColumn> getColumnsMap()

remove

public void remove(byte[] columnName)

delete

public void delete(int localtime,
                   long timestamp)

delete

public void delete(ColumnFamily cf2)

isMarkedForDelete

public boolean isMarkedForDelete()
Specified by:
isMarkedForDelete in interface IColumnContainer

getComparator

public AbstractType getComparator()
Specified by:
getComparator in interface IColumnContainer

hashCode

public int hashCode()
Overrides:
hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object o)
Overrides:
equals in class java.lang.Object

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

updateDigest

public void updateDigest(java.security.MessageDigest digest)

getMarkedForDeleteAt

public long getMarkedForDeleteAt()
Specified by:
getMarkedForDeleteAt in interface IColumnContainer

getLocalDeletionTime

public int getLocalDeletionTime()

type

public java.lang.String type()

serializedSize

public int serializedSize()

getComparatorFor

public static AbstractType getComparatorFor(java.lang.String table,
                                            java.lang.String columnFamilyName,
                                            byte[] superColumnName)


Copyright © 2009 The Apache Software Foundation