com.netflix.astyanax.util
Class CsvColumnReader

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

All Implemented Interfaces:

RecordReader

public class CsvColumnReader
extends java.lang.Object
implements RecordReader

Read a CSV where each row represents a single column rowkey, columname, columnvalue

Constructor Summary

CsvColumnReader(java.io.Reader reader)

Method Summary

java.util.List<org.apache.cassandra.utils.Pair<java.lang.String,java.lang.String>>	next()
CsvColumnReader	setHasHeaderLine(boolean flag)
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

CsvColumnReader

public CsvColumnReader(java.io.Reader reader)

Method Detail

setHasHeaderLine

public CsvColumnReader setHasHeaderLine(boolean flag)

start

public void start()
           throws java.io.IOException

Specified by:

start in interface RecordReader

Throws:

java.io.IOException

shutdown

public void shutdown()

Specified by:

shutdown in interface RecordReader

next

public java.util.List<org.apache.cassandra.utils.Pair<java.lang.String,java.lang.String>> next()
                                                                                        throws java.io.IOException

Specified by:

next in interface RecordReader

Throws:

java.io.IOException