com.alibaba.fastjson2.support.csv

Class CSVReaderUTF8<T>

java.lang.Object

com.alibaba.fastjson2.stream.StreamReader<T>

com.alibaba.fastjson2.support.csv.CSVReader<T>

com.alibaba.fastjson2.support.csv.CSVReaderUTF8<T>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

final class CSVReaderUTF8<T>
extends CSVReader<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	CSVReaderUTF8.ByteArrayConsumerImpl

Nested classes/interfaces inherited from class com.alibaba.fastjson2.stream.StreamReader

StreamReader.ColumnStat, StreamReader.Feature, StreamReader.StreamReaderSpliterator<T>

Field Summary

Fields

Modifier and Type	Field and Description
(package private) byte[]	buf
(package private) java.nio.charset.Charset	charset
(package private) static int	ESCAPE_INDEX_NOT_SET
(package private) java.io.InputStream	input
(package private) int	nextEscapeIndex
(package private) ByteArrayValueConsumer	valueConsumer
(package private) static java.util.Map<java.lang.Long,java.util.function.Function<java.util.function.Consumer,ByteArrayValueConsumer>>	valueConsumerCreators

Fields inherited from class com.alibaba.fastjson2.support.csv.CSVReader

objectClass, quote

Fields inherited from class com.alibaba.fastjson2.stream.StreamReader

columns, columnStats, columnStatsMap, end, errorCount, features, fieldReaders, inputEnd, lineEnd, lineNextStart, lineSize, lineStart, lineTerminated, mapping, objectCreator, off, rowCount, SIZE_512K, typeReaders, types

Constructor Summary

Constructors

Constructor and Description
CSVReaderUTF8(byte[] bytes, int off, int len, java.nio.charset.Charset charset, ByteArrayValueConsumer valueConsumer)
CSVReaderUTF8(byte[] bytes, int off, int len, java.nio.charset.Charset charset, java.lang.Class<T> objectClass)
CSVReaderUTF8(byte[] bytes, int off, int len, java.lang.Class<T> objectClass)
CSVReaderUTF8(byte[] bytes, int off, int len, java.lang.reflect.Type[] types)
CSVReaderUTF8(java.io.InputStream input, java.nio.charset.Charset charset, ByteArrayValueConsumer valueConsumer)
CSVReaderUTF8(java.io.InputStream input, java.nio.charset.Charset charset, java.lang.Class<T> objectClass)
CSVReaderUTF8(java.io.InputStream input, java.nio.charset.Charset charset, java.lang.reflect.Type[] types)
CSVReaderUTF8(StreamReader.Feature... features)

Method Summary

Modifier and Type	Method and Description
void	close()
(package private) static boolean	containsQuoteOrLineSeparator(long v)
private byte[]	getBuf()
private byte[]	initBuf()
boolean	isEnd()
void	readAll()
private void	readAll(ByteArrayValueConsumer consumer, int maxRows)
void	readAll(int maxRows)
private void	readLine(ByteArrayValueConsumer consumer)
private void	readLineEscaped(ByteArrayValueConsumer consumer)
void	readLineObjectAll(boolean readHeader, java.util.function.Consumer<T> consumer)
private java.lang.Object[]	readLineValue(boolean strings)
private java.lang.Object[]	readLineValueEscaped(boolean strings)
java.lang.Object[]	readLineValues(boolean strings)
private void	readValue(boolean strings, int columnIndex, int valueSize, byte[] buf, int valueStart, java.lang.Object[] values, java.util.List<java.lang.Object> valueList)
(package private) java.lang.Object	readValue(byte[] bytes, int off, int len, java.lang.reflect.Type type)
protected boolean	seekLine()
private boolean	seekLine0(byte[] buf, int off, int end)
void	statAll()
void	statAll(int maxRows)

Methods inherited from class com.alibaba.fastjson2.support.csv.CSVReader

config, config, error, errorCount, getColumn, getColumns, getColumnStat, getColumnStat, getColumnStats, getColumnType, isObjectSupport, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, readHeader, readLine, readLineAll, readLineObject, readLineObjectAll, readLineObjectAll, readLineValues, rowCount, rowCount, rowCount, rowCount, rowCount, rowCount, rowCount, rowCount, rowCount, skipLines

Methods inherited from class com.alibaba.fastjson2.stream.StreamReader

stream, stream

Methods inherited from class java.lang.Object

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

Field Detail

ESCAPE_INDEX_NOT_SET

static final int ESCAPE_INDEX_NOT_SET

See Also:

Constant Field Values

nextEscapeIndex

int nextEscapeIndex

valueConsumerCreators

static final java.util.Map<java.lang.Long,java.util.function.Function<java.util.function.Consumer,ByteArrayValueConsumer>> valueConsumerCreators

buf

byte[] buf

input

java.io.InputStream input

charset

java.nio.charset.Charset charset

valueConsumer

ByteArrayValueConsumer valueConsumer

Constructor Detail

CSVReaderUTF8

CSVReaderUTF8(StreamReader.Feature... features)

CSVReaderUTF8

CSVReaderUTF8(byte[] bytes,
              int off,
              int len,
              java.nio.charset.Charset charset,
              java.lang.Class<T> objectClass)

CSVReaderUTF8

CSVReaderUTF8(byte[] bytes,
              int off,
              int len,
              java.nio.charset.Charset charset,
              ByteArrayValueConsumer valueConsumer)

CSVReaderUTF8

CSVReaderUTF8(byte[] bytes,
              int off,
              int len,
              java.lang.reflect.Type[] types)

CSVReaderUTF8

CSVReaderUTF8(byte[] bytes,
              int off,
              int len,
              java.lang.Class<T> objectClass)

CSVReaderUTF8

CSVReaderUTF8(java.io.InputStream input,
              java.nio.charset.Charset charset,
              java.lang.reflect.Type[] types)

CSVReaderUTF8

CSVReaderUTF8(java.io.InputStream input,
              java.nio.charset.Charset charset,
              java.lang.Class<T> objectClass)

CSVReaderUTF8

CSVReaderUTF8(java.io.InputStream input,
              java.nio.charset.Charset charset,
              ByteArrayValueConsumer valueConsumer)

Method Detail

containsQuoteOrLineSeparator

static boolean containsQuoteOrLineSeparator(long v)

getBuf

private byte[] getBuf()
               throws java.io.IOException

Throws:

java.io.IOException

initBuf

private byte[] initBuf()
                throws java.io.IOException

Throws:

java.io.IOException

seekLine

protected boolean seekLine()
                    throws java.io.IOException

Specified by:

seekLine in class StreamReader<T>

Throws:

java.io.IOException

seekLine0

private boolean seekLine0(byte[] buf,
                          int off,
                          int end)
                   throws java.io.IOException

Throws:

java.io.IOException

readValue

java.lang.Object readValue(byte[] bytes,
                           int off,
                           int len,
                           java.lang.reflect.Type type)

isEnd

public boolean isEnd()

Specified by:

isEnd in class CSVReader<T>

readLineValues

public java.lang.Object[] readLineValues(boolean strings)

Specified by:

readLineValues in class CSVReader<T>

readLineValue

private java.lang.Object[] readLineValue(boolean strings)

readValue

private void readValue(boolean strings,
                       int columnIndex,
                       int valueSize,
                       byte[] buf,
                       int valueStart,
                       java.lang.Object[] values,
                       java.util.List<java.lang.Object> valueList)

readLineValueEscaped

private java.lang.Object[] readLineValueEscaped(boolean strings)

close

public void close()

statAll

public void statAll()

Specified by:

statAll in class CSVReader<T>

statAll

public void statAll(int maxRows)

Specified by:

statAll in class CSVReader<T>

readAll

public void readAll()

Specified by:

readAll in class CSVReader<T>

readAll

public void readAll(int maxRows)

Specified by:

readAll in class CSVReader<T>

readLineObjectAll

public void readLineObjectAll(boolean readHeader,
                              java.util.function.Consumer<T> consumer)

Specified by:

readLineObjectAll in class CSVReader<T>

readAll

private void readAll(ByteArrayValueConsumer consumer,
                     int maxRows)

readLine

private void readLine(ByteArrayValueConsumer consumer)

readLineEscaped

private void readLineEscaped(ByteArrayValueConsumer consumer)