com.netflix.astyanax.util
Class CsvColumnReader

java.lang.Object
  extended by com.netflix.astyanax.util.CsvColumnReader
All Implemented Interfaces:
RecordReader

public class CsvColumnReader
extends Object
implements RecordReader

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

Author:
elandau

Constructor Summary
CsvColumnReader(Reader reader)
           
 
Method Summary
 List<org.apache.cassandra.utils.Pair<String,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(Reader reader)
Method Detail

setHasHeaderLine

public CsvColumnReader setHasHeaderLine(boolean flag)

start

public void start()
           throws IOException
Specified by:
start in interface RecordReader
Throws:
IOException

shutdown

public void shutdown()
Specified by:
shutdown in interface RecordReader

next

public List<org.apache.cassandra.utils.Pair<String,String>> next()
                                                          throws IOException
Specified by:
next in interface RecordReader
Throws:
IOException


Copyright © 2012. All Rights Reserved.