Vec.CollectDomain, Vec.VecIdenticalTask, Vec.VectorGroup, Vec.Writer_domain, _espc, _key, _time, KEY_PREFIX_LEN, LOG_CHK, MAX_ENUM_SIZE| 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(C1NChunk c,
int cidx,
Futures fs) |
static Key |
readPut(Key k,
java.io.InputStream is) |
static Key |
readPut(java.lang.String keyname,
java.io.InputStream is) |
boolean |
writable()
Default read/write behavior for Vecs.
|
byteSize, chunk2StartElem, chunkIdx, chunkOffset, isInt, length, max, mean, min, naCnt, nChunks, sigmachunkForChunkIdx, openStreamalign, at, at16h, at16l, at8, cardinality, changeDomain, checkMissing, checksum, chunkForRow, chunkKey, chunkKey, chunkLen, domain, domain, equals, getVecKey, group, groupKey, hashCode, isBad, isByteVec, isConst, isEnum, isFloat, isNA, isTime, isUUID, make1Elem, make1Elem, makeCon, makeCon, makeCon, makeCons, makeConSeq, makeNewCons, makeSeq, makeTransf, makeZero, makeZero, makeZeros, makeZeros, masterVec, newKey, open, postWrite, readable, remove, rollupStats, rollupStats, set, set, set, setNA, timeMode, timeParse, toEnum, toStringclone, frozenType, init, newInstance, read, toDocField, write, writeJSON, writeJSONFieldsprotected UploadFileVec(Key key)
public boolean writable()
Vecpublic Value chunkIdx(int cidx)
VecDKV.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) throws java.lang.Exception
java.lang.Exception