com.alibaba.fastjson2.stream

Class StreamReader<T>

java.lang.Object

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

Direct Known Subclasses:

CSVReader, JSONStreamReader

public abstract class StreamReader<T>
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamReader.ColumnStat
static class	StreamReader.Feature
protected static class	StreamReader.StreamReaderSpliterator<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<java.lang.String>	columns
protected java.util.List<StreamReader.ColumnStat>	columnStats
protected java.util.Map<java.lang.String,StreamReader.ColumnStat>	columnStatsMap
protected int	end
protected int	errorCount
protected long	features
protected FieldReader[]	fieldReaders
protected boolean	inputEnd
protected int	lineEnd
protected int	lineNextStart
protected int	lineSize
protected int	lineStart
protected boolean	lineTerminated
protected int[]	mapping
protected java.util.function.Supplier	objectCreator
protected int	off
protected int	rowCount
protected static int	SIZE_512K
protected ObjectReader[]	typeReaders
protected java.lang.reflect.Type[]	types

Constructor Summary

Constructors

Constructor and Description
StreamReader()
StreamReader(java.lang.reflect.Type[] types)

Method Summary

Modifier and Type	Method and Description
abstract <T> T	readLineObject()
protected abstract boolean	seekLine()
<T> java.util.stream.Stream<T>	stream()
<T> java.util.stream.Stream<T>	stream(java.lang.Class<T> clazz)

Methods inherited from class java.lang.Object

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

Field Detail

SIZE_512K

protected static final int SIZE_512K

See Also:

Constant Field Values

features

protected long features

types

protected java.lang.reflect.Type[] types

typeReaders

protected ObjectReader[] typeReaders

objectCreator

protected java.util.function.Supplier objectCreator

fieldReaders

protected FieldReader[] fieldReaders

lineSize

protected int lineSize

rowCount

protected int rowCount

errorCount

protected int errorCount

lineStart

protected int lineStart

lineEnd

protected int lineEnd

lineNextStart

protected int lineNextStart

end

protected int end

off

protected int off

inputEnd

protected boolean inputEnd

lineTerminated

protected boolean lineTerminated

columnStatsMap

protected java.util.Map<java.lang.String,StreamReader.ColumnStat> columnStatsMap

columns

protected java.util.List<java.lang.String> columns

columnStats

protected java.util.List<StreamReader.ColumnStat> columnStats

mapping

protected int[] mapping

Constructor Detail

StreamReader

public StreamReader()

StreamReader

public StreamReader(java.lang.reflect.Type[] types)

Method Detail

seekLine

protected abstract boolean seekLine()
                             throws java.io.IOException

Throws:

java.io.IOException

readLineObject

public abstract <T> T readLineObject()

stream

public <T> java.util.stream.Stream<T> stream()

stream

public <T> java.util.stream.Stream<T> stream(java.lang.Class<T> clazz)