org.easybatch.extensions.yaml

Class YamlRecordReader

java.lang.Object

org.easybatch.extensions.yaml.YamlRecordReader

All Implemented Interfaces:

RecordReader

public class YamlRecordReader
extends java.lang.Object
implements RecordReader

Reader for Yaml records delimited by "---".

Author:

Mahmoud Ben Hassine (mahmoud.benhassine@icloud.com)

Constructor Summary

Constructors

Constructor and Description
YamlRecordReader(java.io.InputStream inputStream) Create a new YamlRecordReader.
YamlRecordReader(java.io.InputStream inputStream, java.lang.String charset) Create a new YamlRecordReader.

Method Summary

Modifier and Type	Method and Description
void	close()
protected java.lang.String	getDataSourceName()
void	open()
YamlRecord	readRecord()

Methods inherited from class java.lang.Object

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

Constructor Detail

YamlRecordReader

public YamlRecordReader(java.io.InputStream inputStream)

Create a new YamlRecordReader.

Parameters:

inputStream - to read records from

YamlRecordReader

public YamlRecordReader(java.io.InputStream inputStream,
                        java.lang.String charset)

Create a new YamlRecordReader.

Parameters:

inputStream - to read records from

charset - of the input stream

Method Detail

open

public void open()
          throws java.lang.Exception

Specified by:

open in interface RecordReader

Throws:

java.lang.Exception

readRecord

public YamlRecord readRecord()
                      throws java.lang.Exception

Specified by:

readRecord in interface RecordReader

Throws:

java.lang.Exception

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface RecordReader

Throws:

java.lang.Exception

getDataSourceName

protected java.lang.String getDataSourceName()