| Interface | Description |
|---|---|
| ColumnSerializer<T> |
Serializes column values to byte arrays (used as part of tables) and back
|
| CompiledAggregateExpression | |
| CompiledExpression | |
| DbReaderStream | |
| StorageEngine | |
| Stream | |
| StreamSubscriber |
| Class | Description |
|---|---|
| AbstractStream | |
| AbstractTableReaderStream |
Implements skeleton for table streamer that uses PartitionManager to handle partitioning.
|
| ByteArrayComparator | |
| ColumnDefinition | |
| ColumnSerializerFactory | |
| CompiledAggregateList | |
| CompiledFirstVal | |
| ConstantValueCompiledExpression |
this is no compiled expression at all, it just returns the same value
|
| DataType |
Types supported by yarch.
|
| FieldReturnCompiledExpression | |
| HistogramReaderStream |
Sends histogram data to a stream.
|
| HistogramRecord |
Stores a record in the histogram database.
|
| HistogramSegment | |
| IndexFilter | |
| InputStream | |
| InternalStream | |
| ListDataType | |
| MergeStream | |
| OutputStream | |
| ParameterValueColumnSerializer | |
| Partition |
stores information about Partition of a table
It is subclassed by storage engines to store additional information
|
| PartitioningSpec | |
| PartitionIterator | |
| PartitionManager |
Keeps track of partitions.
|
| PartitionManager.Interval |
Keeps a value -> partition map for a specific time interval
|
| ProtobufDataType | |
| RawTuple | |
| SelectStream | |
| SpeedLimitStream | |
| SpeedSpec | |
| TableDefinition |
A table definition consists of a (key,value) pair of tuple definitions.
|
| TableDefinitionConstructor |
Constructs
TableDefinition from .def yaml files. |
| TableDefinitionRepresenter |
Serializes TableDefinition to yaml format
|
| TableWriter | |
| TimePartitionSchema |
Implements different schemes for partitioning by time.
|
| TimePartitionSchema.PartitionInfo | |
| Tuple |
Contains the tuple value (as an array of Columns) together with a pointer to its definition
|
| TupleDataType | |
| TupleDefinition | |
| WindowProcessor | |
| YarchDatabase |
Synchronization policy: to avoid problems with stream disappearing when clients connect to them, all
the creation/closing/subscription to streams/tables shall be done while acquiring a lock on the YarchDatabase
object.
|
| Enum | Description |
|---|---|
| DataType._type | |
| PartitioningSpec._type | |
| SpeedSpec.Type | |
| TableDefinition.PartitionStorage | |
| TableWriter.InsertMode |
| Exception | Description |
|---|---|
| YarchException |
Copyright © 2017 Space Applications Services. All rights reserved.