Package io.atlasmap.csv.core

Class CsvFieldReader

java.lang.Object

io.atlasmap.csv.core.CsvFieldReader

All Implemented Interfaces:

AtlasFieldReader

public class CsvFieldReader
extends Object
implements AtlasFieldReader

It accepts InputStream as a document in order to process big files efficiently. It uses the mark operation of the InputStream to reset the stream and read consecutive fields. If InputStream does not support the mark operation it is wrapped in BufferedInputStream.

Constructor Summary

Constructors

Constructor	Description
CsvFieldReader(CsvConfig csvConfig)

Method Summary

Modifier and Type	Method	Description
Field	read(AtlasInternalSession session)
Document	readSchema()	Reads only the first row of the document.
void	setDocument(InputStream inputStream)

Methods inherited from class java.lang.Object

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

Constructor Details

CsvFieldReader

public CsvFieldReader(CsvConfig csvConfig)

Method Details

setDocument

public void setDocument(InputStream inputStream)

read

public Field read(AtlasInternalSession session)
           throws AtlasException

Specified by:

read in interface AtlasFieldReader

Throws:

AtlasException

readSchema

public Document readSchema()
                    throws AtlasException

Reads only the first row of the document. If firstRecordAsHeader is set to true it uses column names for field names, otherwise it uses an index starting from 0.

Returns:

Document built from CSV

Throws:

AtlasException - if it fails