Package org.apache.druid.data.input

Class TextReader.Bytes

java.lang.Object

org.apache.druid.data.input.IntermediateRowParsingReader<byte[]>

org.apache.druid.data.input.TextReader<byte[]>

org.apache.druid.data.input.TextReader.Bytes

All Implemented Interfaces:

InputEntityReader

Direct Known Subclasses:

DelimitedValueReader, JsonLineReader

Enclosing class:

TextReader<T>

public abstract static class TextReader.Bytes
extends TextReader<byte[]>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.druid.data.input.TextReader

TextReader.Bytes, TextReader.Strings

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Bytes(InputRowSchema inputRowSchema, InputEntity source)

Method Summary

Modifier and Type	Method	Description
protected String	intermediateRowAsString(byte[] row)	String representation of an intermediate row.
protected CloseableIterator<byte[]>	makeSourceIterator(InputStream in)

Methods inherited from class org.apache.druid.data.input.TextReader

findOrCreateInputRowSignature, getInputRowSchema, getNumHeaderLinesToSkip, intermediateRowIteratorWithMetadata, needsToProcessHeaderLine, parseInputRows, processHeaderLine, source

Methods inherited from class org.apache.druid.data.input.IntermediateRowParsingReader

intermediateRowIterator, read, sample, toMap

Methods inherited from class java.lang.Object

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

Constructor Details

Bytes

protected Bytes(InputRowSchema inputRowSchema,
 InputEntity source)

Method Details

makeSourceIterator

protected CloseableIterator<byte[]> makeSourceIterator(InputStream in)

Specified by:

makeSourceIterator in class TextReader<byte[]>

intermediateRowAsString

protected String intermediateRowAsString(@Nullable
 byte[] row)

Description copied from class: IntermediateRowParsingReader

String representation of an intermediate row. Used for error messages.

Overrides:

intermediateRowAsString in class IntermediateRowParsingReader<byte[]>