public class

ThrifeKeyspaceImplTest

extends Object
java.lang.Object
   ↳ com.netflix.astyanax.thrift.ThrifeKeyspaceImplTest

Summary

Fields
public static ColumnFamily<String, SessionEvent> CF_CLICK_STREAM
public static ColumnFamily<String, MockCompositeType> CF_COMPOSITE
public static ColumnFamily<ByteBuffer, ByteBuffer> CF_COMPOSITE_CSV
public static ColumnFamily<MockCompositeType, String> CF_COMPOSITE_KEY
public static ColumnFamily<String, String> CF_COUNTER1
public static ColumnFamily<String, UUID> CF_EMAIL_UNIQUE_UUID
public static ColumnFamily<String, String> CF_EMPTY
public static ColumnFamily<String, Long> CF_LONGCOLUMN
public static ColumnFamily<String, String> CF_NOT_DEFINED
public static ColumnFamily<String, String> CF_STANDARD1
public static ColumnFamily<String, String> CF_STANDARD2
public static ColumnFamily<String, UUID> CF_TIME_UUID
public static ColumnFamily<String, UUID> CF_USER_UNIQUE_UUID
public static AnnotatedCompositeSerializer<SessionEvent> SE_SERIALIZER
Public Constructors
ThrifeKeyspaceImplTest()
Public Methods
static void createKeyspace()
void example()
void getAll()
void getAllWithCallback()
void paginateColumns()
void paginateLongColumns()
static void setup()
static void teardown()
void testChangeConsistencyLevel()
void testClickStream()
void testCluster()
void testColumnFamilyDoesntExist()
void testColumnRangeSlice()
void testColumnSlice()
void testComposite()
void testCompositeKey()
void testCompositeSlice()
void testCopy()
void testCql()
void testCqlCount()
void testCsvLoader()
void testCsvLoaderComposite()
void testCsvLoaderWithCustomSerializers()
void testDelete()
void testDeleteCounter()
void testDeleteLotsOfColumns()
void testDeleteMultipleKeys()
void testFunctionalQuery()
void testGetAllKeysPath()
void testGetAllKeysRoot()
void testGetColumnSlice()
void testGetColumnsWithPrefix()
void testGetCounters()
void testGetSingleColumn()
void testGetSingleColumnNotExists()
void testGetSingleColumnNotExistsAsync()
void testGetSingleKey()
void testGetSingleKeyAsync()
void testGetSingleKeyNotExists()
void testIncrementCounter()
void testIndexQuery()
void testIndexQueryWithPagination()
void testKeyspaceDoesntExist()
void testMultiRowUniqueness()
void testMutationMerge()
void testPrefixedSerializer()
void testPreparedIndexQuery()
void testSerializedClassValue()
void testSingleOps()
void testTimeUUID()
void testTimeUUID2()
void testTimeUUIDUnique()
void testWithRetry()
[Expand]
Inherited Methods
From class java.lang.Object

Fields

public static ColumnFamily<String, SessionEvent> CF_CLICK_STREAM

public static ColumnFamily<String, MockCompositeType> CF_COMPOSITE

public static ColumnFamily<ByteBuffer, ByteBuffer> CF_COMPOSITE_CSV

public static ColumnFamily<MockCompositeType, String> CF_COMPOSITE_KEY

public static ColumnFamily<String, String> CF_COUNTER1

public static ColumnFamily<String, UUID> CF_EMAIL_UNIQUE_UUID

public static ColumnFamily<String, String> CF_EMPTY

public static ColumnFamily<String, Long> CF_LONGCOLUMN

public static ColumnFamily<String, String> CF_NOT_DEFINED

public static ColumnFamily<String, String> CF_STANDARD1

public static ColumnFamily<String, String> CF_STANDARD2

public static ColumnFamily<String, UUID> CF_TIME_UUID

public static ColumnFamily<String, UUID> CF_USER_UNIQUE_UUID

public static AnnotatedCompositeSerializer<SessionEvent> SE_SERIALIZER

Public Constructors

public ThrifeKeyspaceImplTest ()

Public Methods

public static void createKeyspace ()

Throws
Exception

public void example ()

public void getAll ()

public void getAllWithCallback ()

public void paginateColumns ()

public void paginateLongColumns ()

public static void setup ()

Throws
Exception

public static void teardown ()

public void testChangeConsistencyLevel ()

public void testClickStream ()

public void testCluster ()

public void testColumnFamilyDoesntExist ()

public void testColumnRangeSlice ()

Throws
ConnectionException

public void testColumnSlice ()

Throws
ConnectionException

public void testComposite ()

public void testCompositeKey ()

public void testCompositeSlice ()

Throws
ConnectionException

public void testCopy ()

public void testCql ()

public void testCqlCount ()

public void testCsvLoader ()

public void testCsvLoaderComposite ()

public void testCsvLoaderWithCustomSerializers ()

public void testDelete ()

public void testDeleteCounter ()

public void testDeleteLotsOfColumns ()

public void testDeleteMultipleKeys ()

public void testFunctionalQuery ()

Throws
ConnectionException

public void testGetAllKeysPath ()

public void testGetAllKeysRoot ()

public void testGetColumnSlice ()

public void testGetColumnsWithPrefix ()

Throws
ConnectionException

public void testGetCounters ()

Throws
ConnectionException

public void testGetSingleColumn ()

public void testGetSingleColumnNotExists ()

public void testGetSingleColumnNotExistsAsync ()

public void testGetSingleKey ()

public void testGetSingleKeyAsync ()

public void testGetSingleKeyNotExists ()

public void testIncrementCounter ()

public void testIndexQuery ()

public void testIndexQueryWithPagination ()

public void testKeyspaceDoesntExist ()

public void testMultiRowUniqueness ()

public void testMutationMerge ()

public void testPrefixedSerializer ()

public void testPreparedIndexQuery ()

public void testSerializedClassValue ()

public void testSingleOps ()

public void testTimeUUID ()

public void testTimeUUID2 ()

public void testTimeUUIDUnique ()

public void testWithRetry ()