public class FVecParseWriter extends Iced implements StreamParseWriter
ParseWriter.ParseErr, ParseWriter.UnsupportedTypeOverride
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) |
FVecParseWriter(Vec.VectorGroup vg,
int cidx,
Categorical[] categoricals,
byte[] ctypes,
int chunkSize,
AppendableVec[] avs,
int[] parse_columns_indices,
Key<Job> jobKey) |
Modifier and Type | Method and Description |
---|---|
void |
addErr(ParseWriter.ParseErr err) |
void |
addError(ParseWriter.ParseErr err) |
void |
addInvalidCol(int colIdx) |
void |
addNAs(int colIdx,
int nrows) |
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) |
NewChunk[] |
getNvs() |
boolean |
hasErrors() |
void |
invalidLine(ParseWriter.ParseErr err) |
boolean |
isString(int colIdx) |
long |
lineNum() |
void |
newLine() |
FVecParseWriter |
nextChunk() |
FVecParseWriter |
reduce(StreamParseWriter sdout) |
ParseWriter.ParseErr[] |
removeErrors() |
void |
rollbackLine() |
void |
setColumnNames(java.lang.String[] names) |
void |
setIsAllASCII(int colIdx,
boolean b) |
asBytes, clone, copyOver, frozenType, read, readExternal, readJSON, reloadFromBytes, toJsonBytes, toJsonString, write, writeExternal, writeJSON
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
asBytes, clone, frozenType, read, readJSON, reloadFromBytes, write, 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(Vec.VectorGroup vg, int cidx, Categorical[] categoricals, byte[] ctypes, int chunkSize, AppendableVec[] avs, int[] parse_columns_indices, Key<Job> jobKey)
public FVecParseWriter reduce(StreamParseWriter sdout)
reduce
in interface StreamParseWriter
public FVecParseWriter close()
close
in interface StreamParseWriter
public FVecParseWriter close(Futures fs)
close
in interface StreamParseWriter
public FVecParseWriter nextChunk()
nextChunk
in interface StreamParseWriter
public void newLine()
newLine
in interface ParseWriter
public void addNumCol(int colIdx, long number, int exp)
addNumCol
in interface ParseWriter
public final void addInvalidCol(int colIdx)
addInvalidCol
in interface ParseWriter
public void addNAs(int colIdx, int nrows)
addNAs
in interface ParseWriter
public boolean isString(int colIdx)
isString
in interface ParseWriter
public void addStrCol(int colIdx, BufferedString str)
addStrCol
in interface ParseWriter
public void addNumCol(int colIdx, double value)
addNumCol
in interface ParseWriter
public void setColumnNames(java.lang.String[] names)
setColumnNames
in interface ParseWriter
public final void rollbackLine()
rollbackLine
in interface ParseWriter
public void invalidLine(ParseWriter.ParseErr err)
invalidLine
in interface ParseWriter
public void addError(ParseWriter.ParseErr err)
addError
in interface ParseWriter
public void setIsAllASCII(int colIdx, boolean b)
setIsAllASCII
in interface ParseWriter
public boolean hasErrors()
hasErrors
in interface ParseWriter
public ParseWriter.ParseErr[] removeErrors()
removeErrors
in interface ParseWriter
public long lineNum()
lineNum
in interface ParseWriter
public void addErr(ParseWriter.ParseErr err)
public NewChunk[] getNvs()