water.parser

Class FVecParseWriter

java.lang.Object

water.Iced

water.parser.FVecParseWriter

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, java.lang.Cloneable, Freezable

Direct Known Subclasses:

SVMLightFVecParseWriter

public class FVecParseWriter
extends Iced

Parsed data output specialized for fluid vecs.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface water.parser.ParseWriter

ParseWriter.ParseErr

Field Summary

Fields

Modifier and Type	Field and Description
protected Categorical[]	_categoricals
protected byte[]	_ctypes
protected NewChunk[]	_nvs
protected AppendableVec[]	_vecs

Constructor Summary

Constructors

Constructor and Description
FVecParseWriter(Vec.VectorGroup vg, int cidx, Categorical[] categoricals, byte[] ctypes, int chunkSize, AppendableVec[] avs)

Method Summary

Methods

Modifier and Type	Method and Description
void	addErr(ParseWriter.ParseErr err)
void	addError(ParseWriter.ParseErr err)
void	addInvalidCol(int colIdx)
void	addNumCol(int colIdx, double value) Adds double value to the column.
void	addNumCol(int colIdx, long number, int exp)
void	addStrCol(int colIdx, BufferedString str)
FVecParseWriter	close()
FVecParseWriter	close(Futures fs)
boolean	hasErrors()
void	invalidLine(ParseWriter.ParseErr err)
boolean	isString(int colIdx)
long	lineNum()
void	newLine()
FVecParseWriter	nextChunk()
FVecParseWriter	reduce(water.parser.StreamParseWriter sdout)
ParseWriter.ParseErr[]	removeErrors()
void	rollbackLine()
void	setColumnNames(java.lang.String[] names)
void	setIsAllASCII(int colIdx, boolean b)

Methods inherited from class water.Iced

asBytes, clone, copyOver, frozenType, read, readExternal, readJSON, reloadFromBytes, toJsonString, write, writeExternal, writeJSON

Methods inherited from class java.lang.Object

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

Methods inherited from interface water.Freezable

asBytes, clone, frozenType, read, readJSON, reloadFromBytes, write, writeJSON

Field Detail

_vecs

protected AppendableVec[] _vecs

_nvs

protected transient NewChunk[] _nvs

_categoricals

protected final transient Categorical[] _categoricals

_ctypes

protected final transient byte[] _ctypes

Constructor Detail

FVecParseWriter

public FVecParseWriter(Vec.VectorGroup vg,
               int cidx,
               Categorical[] categoricals,
               byte[] ctypes,
               int chunkSize,
               AppendableVec[] avs)

Method Detail

reduce

public FVecParseWriter reduce(water.parser.StreamParseWriter sdout)

close

public FVecParseWriter close()

close

public FVecParseWriter close(Futures fs)

nextChunk

public FVecParseWriter nextChunk()

newLine

public void newLine()

addNumCol

public void addNumCol(int colIdx,
             long number,
             int exp)

addInvalidCol

public final void addInvalidCol(int colIdx)

isString

public boolean isString(int colIdx)

addStrCol

public void addStrCol(int colIdx,
             BufferedString str)

addNumCol

public void addNumCol(int colIdx,
             double value)

Adds double value to the column.

setColumnNames

public void setColumnNames(java.lang.String[] names)

rollbackLine

public final void rollbackLine()

invalidLine

public void invalidLine(ParseWriter.ParseErr err)

addError

public void addError(ParseWriter.ParseErr err)

setIsAllASCII

public void setIsAllASCII(int colIdx,
                 boolean b)

hasErrors

public boolean hasErrors()

removeErrors

public ParseWriter.ParseErr[] removeErrors()

lineNum

public long lineNum()

addErr

public void addErr(ParseWriter.ParseErr err)