com.netflix.astyanax.util
Class ColumnarRecordWriter

java.lang.Object
  com.netflix.astyanax.util.ColumnarRecordWriter

All Implemented Interfaces:

RecordWriter

public class ColumnarRecordWriter
extends java.lang.Object
implements RecordWriter

Writer rows where the first pair is the key and subsequent pairs are columns.

Constructor Summary

ColumnarRecordWriter(Keyspace keyspace, java.lang.String cfName)

ColumnarRecordWriter(Keyspace keyspace, java.lang.String cfName, SerializerPackage serializers)

Method Summary

ColumnarRecordWriter	setBatchSize(int size)
void	shutdown()
void	start()
void	write(java.util.List<org.apache.cassandra.utils.Pair<java.lang.String,java.lang.String>> record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ColumnarRecordWriter

public ColumnarRecordWriter(Keyspace keyspace,
                            java.lang.String cfName)

ColumnarRecordWriter

public ColumnarRecordWriter(Keyspace keyspace,
                            java.lang.String cfName,
                            SerializerPackage serializers)

Method Detail

setBatchSize

public ColumnarRecordWriter setBatchSize(int size)

start

public void start()
           throws com.netflix.astyanax.connectionpool.exceptions.ConnectionException

Specified by:

start in interface RecordWriter

Throws:

com.netflix.astyanax.connectionpool.exceptions.ConnectionException

write

public void write(java.util.List<org.apache.cassandra.utils.Pair<java.lang.String,java.lang.String>> record)

Specified by:

write in interface RecordWriter

shutdown

public void shutdown()

Specified by:

shutdown in interface RecordWriter