public class FVecParseWriter extends Iced
Modifier and Type | Field and Description |
---|---|
protected Categorical[] |
_categoricals |
protected byte[] |
_ctypes |
protected NewChunk[] |
_nvs |
protected AppendableVec[] |
_vecs |
Constructor and Description |
---|
FVecParseWriter(Vec.VectorGroup vg,
int cidx,
Categorical[] categoricals,
byte[] ctypes,
int chunkSize,
AppendableVec[] avs) |
Modifier and Type | Method and Description |
---|---|
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) |
void |
invalidLine(java.lang.String err) |
boolean |
isString(int colIdx) |
void |
newLine() |
FVecParseWriter |
nextChunk() |
FVecParseWriter |
reduce(water.parser.StreamParseWriter sdout) |
void |
rollbackLine() |
void |
setColumnNames(java.lang.String[] names) |
void |
setIsAllASCII(int colIdx,
boolean b) |
clone, frozenType, read_impl, read, readExternal, readJSON_impl, readJSON, toJsonString, write_impl, write, writeExternal, writeJSON_impl, writeJSON
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clone, frozenType, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeJSON_impl, writeJSON
protected AppendableVec[] _vecs
protected transient NewChunk[] _nvs
protected final transient Categorical[] _categoricals
protected final transient byte[] _ctypes
public FVecParseWriter(Vec.VectorGroup vg, int cidx, Categorical[] categoricals, byte[] ctypes, int chunkSize, AppendableVec[] avs)
public FVecParseWriter reduce(water.parser.StreamParseWriter sdout)
public FVecParseWriter close()
public FVecParseWriter close(Futures fs)
public FVecParseWriter nextChunk()
public void newLine()
public void addNumCol(int colIdx, long number, int exp)
public final void addInvalidCol(int colIdx)
public boolean isString(int colIdx)
public void addStrCol(int colIdx, BufferedString str)
public void addNumCol(int colIdx, double value)
public void setColumnNames(java.lang.String[] names)
public final void rollbackLine()
public void invalidLine(java.lang.String err)
public void setIsAllASCII(int colIdx, boolean b)