public class PreviewParseWriter extends Iced implements StreamParseWriter
ParseWriter.ParseErr, ParseWriter.UnsupportedTypeOverride
Modifier and Type | Field and Description |
---|---|
protected java.lang.String[][] |
_data |
protected ParseWriter.ParseErr[] |
_errs |
protected int |
_invalidLines |
protected int |
_ncols |
protected int |
_nlines |
protected static int |
MAX_PREVIEW_COLS |
protected static int |
MAX_PREVIEW_LINES |
Modifier | Constructor and Description |
---|---|
protected |
PreviewParseWriter() |
protected |
PreviewParseWriter(int ncols) |
Modifier and Type | Method and Description |
---|---|
void |
addError(ParseWriter.ParseErr err) |
void |
addInvalidCol(int colIdx) |
void |
addNAs(int colIdx,
int nrow) |
void |
addNumCol(int colIdx,
double d) |
void |
addNumCol(int colIdx,
long number,
int exp) |
void |
addStrCol(int colIdx,
BufferedString str) |
StreamParseWriter |
close() |
StreamParseWriter |
close(Futures fs) |
java.lang.String[][] |
guessNAStrings(byte[] types) |
byte[] |
guessTypes() |
boolean |
hasErrors() |
void |
invalidLine(ParseWriter.ParseErr err) |
boolean |
isString(int colIdx) |
long |
lineNum() |
void |
newLine() |
StreamParseWriter |
nextChunk() |
StreamParseWriter |
reduce(StreamParseWriter dout) |
ParseWriter.ParseErr[] |
removeErrors() |
void |
rollbackLine() |
void |
setColumnNames(java.lang.String[] names) |
void |
setIsAllASCII(int colIdx,
boolean b) |
static PreviewParseWriter |
unifyColumnPreviews(PreviewParseWriter prevA,
PreviewParseWriter prevB) |
asBytes, clone, copyOver, frozenType, read, readExternal, readJSON, reloadFromBytes, toJsonString, write, writeExternal, writeJSON
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
asBytes, clone, frozenType, read, readJSON, reloadFromBytes, write, writeJSON
protected static final int MAX_PREVIEW_COLS
protected static final int MAX_PREVIEW_LINES
protected int _nlines
protected int _ncols
protected int _invalidLines
protected java.lang.String[][] _data
protected ParseWriter.ParseErr[] _errs
protected PreviewParseWriter()
protected PreviewParseWriter(int ncols)
public void setColumnNames(java.lang.String[] names)
setColumnNames
in interface ParseWriter
public void newLine()
newLine
in interface ParseWriter
public boolean isString(int colIdx)
isString
in interface ParseWriter
public void addNumCol(int colIdx, long number, int exp)
addNumCol
in interface ParseWriter
public void addNumCol(int colIdx, double d)
addNumCol
in interface ParseWriter
public void addInvalidCol(int colIdx)
addInvalidCol
in interface ParseWriter
public void addNAs(int colIdx, int nrow)
addNAs
in interface ParseWriter
public void addStrCol(int colIdx, BufferedString str)
addStrCol
in interface ParseWriter
public void rollbackLine()
rollbackLine
in interface ParseWriter
public void setIsAllASCII(int colIdx, boolean b)
setIsAllASCII
in interface ParseWriter
public byte[] guessTypes()
public java.lang.String[][] guessNAStrings(byte[] types)
public static PreviewParseWriter unifyColumnPreviews(PreviewParseWriter prevA, PreviewParseWriter prevB)
public void invalidLine(ParseWriter.ParseErr err)
invalidLine
in interface ParseWriter
public void addError(ParseWriter.ParseErr err)
addError
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 StreamParseWriter nextChunk()
nextChunk
in interface StreamParseWriter
public StreamParseWriter reduce(StreamParseWriter dout)
reduce
in interface StreamParseWriter
public StreamParseWriter close()
close
in interface StreamParseWriter
public StreamParseWriter close(Futures fs)
close
in interface StreamParseWriter