com.netflix.astyanax.util
Class ColumnarRecordWriter
java.lang.Object
com.netflix.astyanax.util.ColumnarRecordWriter
- All Implemented Interfaces:
- RecordWriter
public class ColumnarRecordWriter
- extends Object
- implements RecordWriter
Writer rows where the first pair is the key and subsequent pairs are columns.
- Author:
- elandau
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ColumnarRecordWriter
public ColumnarRecordWriter(Keyspace keyspace,
String cfName)
ColumnarRecordWriter
public ColumnarRecordWriter(Keyspace keyspace,
String cfName,
SerializerPackage serializers)
setBatchSize
public ColumnarRecordWriter setBatchSize(int size)
start
public void start()
throws ConnectionException
- Specified by:
start
in interface RecordWriter
- Throws:
ConnectionException
write
public void write(List<org.apache.cassandra.utils.Pair<String,String>> record)
- Specified by:
write
in interface RecordWriter
shutdown
public void shutdown()
- Specified by:
shutdown
in interface RecordWriter
Copyright © 2012. All Rights Reserved.