public class UploadFileVec extends FileVec
Modifier and Type | Class and Description |
---|---|
static class |
UploadFileVec.ReadPutStats |
Vec.ESPC, Vec.Holder, Vec.Reader, Vec.VectorGroup, Vec.Writer
_chunkSize, _nChunks, DFLT_CHUNK_SIZE, DFLT_LOG2_CHUNK_SIZE
_cids, _rowLayout, DO_HISTOGRAMS, KEY_PREFIX_LEN, PERCENTILES, T_BAD, T_CAT, T_NUM, T_STR, T_TIME, T_UUID, TYPE_STR
Modifier | Constructor and Description |
---|---|
protected |
UploadFileVec(Key key) |
Modifier and Type | Method and Description |
---|---|
void |
addAndCloseChunk(Chunk c,
Futures fs) |
Value |
chunkIdx(int cidx)
Get a Chunk's Value by index.
|
void |
close(water.fvec.C1NChunk c,
int cidx,
Futures fs) |
static Key |
readPut(Key k,
java.io.InputStream is,
UploadFileVec.ReadPutStats stats) |
static Key |
readPut(java.lang.String keyname,
java.io.InputStream is,
UploadFileVec.ReadPutStats stats) |
int |
setChunkSize(Frame fr,
int chunkSize) |
boolean |
writable()
Default read/write behavior for Vecs.
|
byteSize, calcOptimalChunkSize, chunkOffset, elem2ChunkIdx, getPathForKey, length, nChunks, nonEmptyChunks, setChunkSize, setNChunks
chunkForChunkIdx, getFirstBytes, getPreviewChunkBytes, isInt, naCnt, openStream
adaptTo, align, at, at16h, at16l, at8, atStr, base, bins, cardinality, checksum_impl, chunkForRow, chunkKey, chunkKey, chunkLen, copyMeta, doCopy, domain, equals, espc, factor, get_type_str, get_type, getVecKey, group, hashCode, isBad, isBinary, isCategorical, isCompatibleWith, isConst, isDomainTruncated, isHomedLocally, isNA, isNumeric, isString, isTime, isUUID, isVolatile, lazy_bins, makeCon, makeCon, makeCon, makeCon, makeCon, makeCon, makeCon, makeCon, makeCon, makeCon, makeCon, makeCon, makeCon, makeCon, makeConN, makeCons, makeCons, makeCopy, makeCopy, makeCopy, makeDoubles, makeRand, makeRepSeq, makeSeq, makeSeq, makeSeq, makeTimeVec, makeVec, makeVec, makeVec, makeVec, makeVec, makeVec, makeVolatileDoubles, makeVolatileInts, makeZero, makeZero, makeZero, makeZero, makeZero, makeZeros, makeZeros, max, maxs, mean, min, mins, mode, nChunksFor, newKey, ninfs, nzCnt, open, pctiles, pinfs, postWrite, preWriting, readAll_impl, remove_impl, rollupStatsKey, set, set, set, set, set, setBad, setChunkIdx, setDomain, setNA, sigma, sparseRatio, startRollupStats, startRollupStats, stride, stringAt, toCategoricalVec, toNumericVec, toString, toStringVec, toTwoDimTable, toTwoDimTable, writeAll_impl
checksum, makeSchema, readAll, remove, remove, remove, remove, writeAll
asBytes, clone, copyOver, frozenType, read, readExternal, readJSON, reloadFromBytes, toJsonString, write, writeExternal, writeJSON
protected UploadFileVec(Key key)
public boolean writable()
Vec
public void close(water.fvec.C1NChunk c, int cidx, Futures fs)
public Value chunkIdx(int cidx)
Vec
DKV.get()
. Warning: this pulls the data locally; using this call
on every Chunk index on the same node will probably trigger an OOM!public static Key readPut(java.lang.String keyname, java.io.InputStream is, UploadFileVec.ReadPutStats stats) throws java.io.IOException
java.io.IOException
public static Key readPut(Key k, java.io.InputStream is, UploadFileVec.ReadPutStats stats) throws java.io.IOException
java.io.IOException
public int setChunkSize(Frame fr, int chunkSize)
setChunkSize
in class FileVec