Package 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

public class CompliantTextBatchReader
extends Object
implements ManagedReader

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

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.physical.impl.scan.v3.ManagedReader

ManagedReader.EarlyEofException

Field Summary

Fields

Modifier and Type	Field	Description
static final String	COLUMNS_COL

Constructor Summary

Constructors

Constructor	Description
CompliantTextBatchReader(FileSchemaNegotiator schemaNegotiator, TextParsingSettings settings)	Create and open the text reader.

Method Summary

Modifier and Type	Method	Description
void	close()	Cleanup state once we are finished processing all the records.
static TupleMetadata	columnsSchema()
boolean	next()	Generates the next record batch

Methods inherited from class java.lang.Object

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

Field Details

COLUMNS_COL

public static final String COLUMNS_COL

See Also:

• Constant Field Values

Constructor Details

CompliantTextBatchReader

public CompliantTextBatchReader(FileSchemaNegotiator schemaNegotiator,
 TextParsingSettings settings)
                         throws ManagedReader.EarlyEofException

Create and open the text reader.

Throws:

ManagedReader.EarlyEofException

Method Details

columnsSchema

public static TupleMetadata columnsSchema()

next

public boolean next()

Generates the next record batch

Specified by:

next in interface ManagedReader

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