water.fvec
Class ParseDataset2.FVecDataOut

java.lang.Object
  water.Iced
      water.fvec.ParseDataset2.FVecDataOut

All Implemented Interfaces:

java.lang.Cloneable, Freezable, CustomParser.DataOut, CustomParser.StreamDataOut

Direct Known Subclasses:

SVMLightFVecDataOut

Enclosing class:

ParseDataset2

public static class ParseDataset2.FVecDataOut
extends Iced
implements CustomParser.StreamDataOut

Parsed data output specialized for fluid vecs.

Field Summary

protected byte[]	_ctypes
protected Enum[]	_enums
protected NewChunk[]	_nvs
protected AppendableVec[]	_vecs

Constructor Summary

ParseDataset2.FVecDataOut(Vec.VectorGroup vg, int cidx, int ncols, int vecIdStart, Enum[] enums)

Method Summary

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, ValueString str)
ParseDataset2.FVecDataOut	close()
ParseDataset2.FVecDataOut	close(Futures fs)
Vec[]	closeVecs()
Vec[]	closeVecs(Futures fs)
void	invalidLine(java.lang.String err)
void	invalidValue(int line, int col)
boolean	isString(int colIdx)
protected long	linenum()
void	newLine()
ParseDataset2.FVecDataOut	nextChunk()
ParseDataset2.FVecDataOut	reduce(CustomParser.StreamDataOut sdout)
void	rollbackLine()
void	setColumnNames(java.lang.String[] names)

Methods inherited from class water.Iced

clone, frozenType, init, newInstance, read, toDocField, write, writeJSON, writeJSONFields

Methods inherited from class java.lang.Object

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

Methods inherited from interface water.Freezable

frozenType, newInstance, read, toDocField, write, writeJSONFields

Field Detail

_nvs

protected transient NewChunk[] _nvs

_vecs

protected AppendableVec[] _vecs

_enums

protected final Enum[] _enums

_ctypes

protected final byte[] _ctypes

Constructor Detail

ParseDataset2.FVecDataOut

public ParseDataset2.FVecDataOut(Vec.VectorGroup vg,
                                 int cidx,
                                 int ncols,
                                 int vecIdStart,
                                 Enum[] enums)

Method Detail

reduce

public ParseDataset2.FVecDataOut reduce(CustomParser.StreamDataOut sdout)

Specified by:

reduce in interface CustomParser.StreamDataOut

close

public ParseDataset2.FVecDataOut close()

Specified by:

close in interface CustomParser.StreamDataOut

close

public ParseDataset2.FVecDataOut close(Futures fs)

Specified by:

close in interface CustomParser.StreamDataOut

nextChunk

public ParseDataset2.FVecDataOut nextChunk()

Specified by:

nextChunk in interface CustomParser.StreamDataOut

closeVecs

public Vec[] closeVecs()

closeVecs

public Vec[] closeVecs(Futures fs)

newLine

public void newLine()

Specified by:

newLine in interface CustomParser.DataOut

linenum

protected long linenum()

addNumCol

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

Specified by:

addNumCol in interface CustomParser.DataOut

addInvalidCol

public final void addInvalidCol(int colIdx)

Specified by:

addInvalidCol in interface CustomParser.DataOut

isString

public final boolean isString(int colIdx)

Specified by:

isString in interface CustomParser.DataOut

addStrCol

public final void addStrCol(int colIdx,
                            ValueString str)

Specified by:

addStrCol in interface CustomParser.DataOut

addNumCol

public void addNumCol(int colIdx,
                      double value)

Adds double value to the column.

Specified by:

addNumCol in interface CustomParser.DataOut

Parameters:

colIdx -

value -

setColumnNames

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

Specified by:

setColumnNames in interface CustomParser.DataOut

rollbackLine

public final void rollbackLine()

Specified by:

rollbackLine in interface CustomParser.DataOut

invalidLine

public void invalidLine(java.lang.String err)

Specified by:

invalidLine in interface CustomParser.DataOut

invalidValue

public void invalidValue(int line,
                         int col)

Specified by:

invalidValue in interface CustomParser.DataOut