AbstractStream(YarchDatabaseInstance ydb,
String name,
TupleDefinition definition) |
AbstractTableReaderStream(YarchDatabaseInstance ydb,
TableDefinition tblDef,
PartitionManager partitionManager,
boolean ascending,
boolean follow) |
HistogramReaderStream(YarchDatabaseInstance ydb,
TableDefinition tblDef,
String histoColumnName,
TupleDefinition tupleDef) |
InputStream(YarchDatabaseInstance dict,
String name,
TupleDefinition def) |
InternalStream(YarchDatabaseInstance dict,
String name,
TupleDefinition definition) |
MergeStream(YarchDatabaseInstance ydb,
AbstractStream[] streams,
String mergeColumn,
boolean ascending) |
OutputStream(YarchDatabaseInstance dict,
String name,
TupleDefinition def) |
SelectStream(YarchDatabaseInstance ydb,
AbstractStream input,
CompiledExpression cWhereClause,
List<CompiledExpression> caggInputList,
WindowProcessor wp,
List<CompiledExpression> cselectList,
TupleDefinition outputDef,
TupleDefinition minOutputDef) |
SpeedLimitStream(YarchDatabaseInstance dict,
String name,
TupleDefinition definition,
SpeedSpec speedSpec) |
TableWriter(YarchDatabaseInstance ydb,
TableDefinition tableDefinition,
TableWriter.InsertMode mode) |