org.apache.drill.exec.store.easy.text.reader

Class CompliantTextBatchReader

java.lang.Object

org.apache.drill.exec.store.easy.text.reader.CompliantTextBatchReader

All Implemented Interfaces:

ManagedReader<ColumnsSchemaNegotiator>

public class CompliantTextBatchReader
extends Object
implements ManagedReader<ColumnsSchemaNegotiator>

Text reader, Complies with the RFC 4180 standard for text/csv files.

Constructor Summary

Constructors

Constructor and Description
CompliantTextBatchReader(TextParsingSettings settings, int maxRecords)

Method Summary

Modifier and Type	Method and Description
void	close() Cleanup state once we are finished processing all the records.
boolean	next() Generates the next record batch
boolean	open(ColumnsSchemaNegotiator schemaNegotiator) Performs the initial setup required for the record reader.

Methods inherited from class java.lang.Object

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

Constructor Detail

CompliantTextBatchReader

public CompliantTextBatchReader(TextParsingSettings settings,
                                int maxRecords)

Method Detail

open

public boolean open(ColumnsSchemaNegotiator schemaNegotiator)

Performs the initial setup required for the record reader. Initializes the input stream, handling of the output record batch and the actual reader to be used.

Specified by:

open in interface ManagedReader<ColumnsSchemaNegotiator>

Parameters:

schemaNegotiator - Used to create the schema in the output record batch

Returns:

true if opens successfully, false if output is null

next

public boolean next()

Generates the next record batch

Specified by:

next in interface ManagedReader<ColumnsSchemaNegotiator>

Returns:

number of records in the batch

close

public void close()

Cleanup state once we are finished processing all the records. This would internally close the input stream we are reading from.

Specified by:

close in interface ManagedReader<ColumnsSchemaNegotiator>