public class AppendableVec extends Vec
Vec.CollectDomain, Vec.VecIdenticalTask, Vec.VectorGroup, Vec.Writer| Modifier and Type | Field and Description |
|---|---|
static byte |
ENUM |
static byte |
NA |
static byte |
NUMBER |
static byte |
TIME |
static byte |
UUID |
_domain, _key, _time, CHUNK_SZ, KEY_PREFIX_LEN, LOG_CHK, MAX_ENUM_SIZE| Constructor and Description |
|---|
AppendableVec(Key key) |
AppendableVec(Key key,
long[] espc,
int chunkOff) |
| Modifier and Type | Method and Description |
|---|---|
long |
byteSize()
Size of compressed vector data.
|
long |
chunk2StartElem(int cidx)
Convert a chunk-index into a starting row #.
|
Chunk |
chunkForChunkIdx(int cidx)
The Chunk for a chunk#.
|
Value |
chunkIdx(int cidx)
Get a Chunk's Value by index.
|
Vec |
close(Futures fs) |
static Vec[] |
closeAll(AppendableVec[] avs) |
static Vec[] |
closeAll(AppendableVec[] avs,
Futures fs) |
int |
elem2ChunkIdx(long i)
Convert a row# to a chunk#.
|
long |
length()
Number of elements in the vector.
|
int |
nChunks()
Number of chunks.
|
boolean |
readable()
Default read/write behavior for Vecs.
|
void |
reduce(AppendableVec nv) |
void |
setSubRange(AppendableVec av)
Add AV build over sub-range of this vec (used e.g.
|
java.lang.String |
toString()
Pretty print the Vec: [#elems, min/mean/max]{chunks,...}
|
boolean |
writable()
Default read/write behavior for Vecs.
|
align, at, at16h, at16l, at8, cardinality, changeDomain, checkMissing, checksum, chunkForRow, chunkKey, chunkKey, chunkLen, domain, domain, equals, getVecKey, group, groupKey, hashCode, isBad, isByteVec, isConst, isEnum, isFloat, isInt, isNA, isTime, isUUID, make1Elem, make1Elem, makeCon, makeCon, makeCon, makeCons, makeConSeq, makeNewCons, makeSeq, makeTransf, makeTransf, makeZero, makeZero, makeZeros, makeZeros, masterVec, max, mean, min, naCnt, newKey, open, postWrite, preWriting, remove, rollupStats, rollupStats, set, set, set, setNA, sigma, timeMode, timeParse, toEnumclone, frozenType, init, newInstance, read, toDocField, write, writeJSON, writeJSONFieldspublic static final byte NA
public static final byte ENUM
public static final byte NUMBER
public static final byte TIME
public static final byte UUID
public AppendableVec(Key key)
public AppendableVec(Key key, long[] espc, int chunkOff)
public void setSubRange(AppendableVec av)
av - public static Vec[] closeAll(AppendableVec[] avs)
public static Vec[] closeAll(AppendableVec[] avs, Futures fs)
public void reduce(AppendableVec nv)
public boolean readable()
Vecpublic boolean writable()
Vecpublic Chunk chunkForChunkIdx(int cidx)
VecchunkForChunkIdx in class 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 long length()
Vecpublic int nChunks()
Vecpublic int elem2ChunkIdx(long i)
Vecelem2ChunkIdx in class Vecpublic long chunk2StartElem(int cidx)
Vecchunk2StartElem in class Vecpublic long byteSize()
Vec