public class MemoryDataset extends Dataset
Dataset.ColumnsDataReader
internalId, internalName, log, TIMESTAMP_FORMAT
SERIALIZED_CLASS_NAME, TYPE
XML_SERIALIZED_CLASS_NAME
Constructor and Description |
---|
MemoryDataset(AbstractPipeline pipeline) |
Modifier and Type | Method and Description |
---|---|
protected void |
beforeLoad(Integer maxRecords) |
void |
close() |
protected DataWriter |
createDataWriter()
Writes records to this dataset's cache after clearing it.
|
Column |
getColumn(int index) |
Column |
getColumn(String name) |
long |
getColumnCount() |
List<String> |
getColumnNames() |
List<Column> |
getColumns() |
protected Column |
getOrCreateColumn(String name,
int index) |
Record |
getRecord(long index) |
long |
getRecordCount() |
addField, cancelLoad, createColumnsDataReader, createDataReader, createDataReader, finalize, fromRecord, getColumnStatsReaderThreads, getJob, getMaxColumnStatsRecords, getPipeline, getRecordList, isInferStringTypes, load, load, load, setColumnStatsReaderThreads, setInferStringTypes, setMaxColumnStatsRecords, toRecord, updateColumns, waitForColumnStatsToLoad, waitForColumnStatsToLoad, waitForRecordsToLoad, waitForRecordsToLoad
addExceptionProperties, assertValid, assertValid, clone, exception, exception, exception, getInternalId, getInternalName, resetInternalId
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
fromArrayValue, fromArrayValue, fromArrayValue, fromJson, fromJson, newInstanceFromRecord, newInstanceFromRecord, toArrayValue, toJson, toJson, toJson, toRecord
newInstanceFromJson
fromXml, fromXml, fromXmlElement, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getChildElement, getChildElements, newInstanceFromXml, newInstanceFromXml, setAttribute, toXml, toXml, toXml, toXml, toXml, toXmlElement, writeXml, writeXml
public MemoryDataset(AbstractPipeline pipeline)
public long getRecordCount()
getRecordCount
in class Dataset
public long getColumnCount()
getColumnCount
in class Dataset
public List<String> getColumnNames()
getColumnNames
in class Dataset
protected Column getOrCreateColumn(String name, int index)
getOrCreateColumn
in class Dataset
public List<Column> getColumns()
getColumns
in class Dataset
protected void beforeLoad(Integer maxRecords)
beforeLoad
in class Dataset
protected DataWriter createDataWriter()
Dataset
createDataWriter
in class Dataset