| Package | Description |
|---|---|
| org.yamcs | |
| org.yamcs.archive | |
| org.yamcs.cmdhistory | |
| org.yamcs.tctm | |
| org.yamcs.yarch | |
| org.yamcs.yarch.streamsql |
| Modifier and Type | Method and Description |
|---|---|
void |
StreamInitializer.createStreams() |
| Constructor and Description |
|---|
ProcessorCreatorService(String yamcsInstance,
Map<String,String> config) |
YProcessorCreatorService(String yamcsInstance,
Map<String,String> config)
Deprecated.
|
| Constructor and Description |
|---|
AlarmRecorder(String yamcsInstance) |
EventRecorder(String instance) |
XtceTmRecorder(String yamcsInstance) |
XtceTmRecorder(String yamcsInstance,
Map<String,Object> config)
old constructor for compatibility with older configuration files
|
| Constructor and Description |
|---|
YarchCommandHistoryAdapter(String archiveInstance) |
| Constructor and Description |
|---|
DataLinkInitialiser(String yamcsInstance) |
TcUplinkerAdapter(String yamcsInstance) |
TmProviderAdapter(String yamcsInstance)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
AbstractTableReaderStream.addInFilter(ColumnExpression cexpr,
Set<Object> values)
currently adds only filters on value based partitions
|
boolean |
DbReaderStream.addInFilter(ColumnExpression cexpr,
Set<Object> values) |
boolean |
HistogramReaderStream.addRelOpFilter(ColumnExpression cexpr,
RelOp relOp,
Object value) |
boolean |
AbstractTableReaderStream.addRelOpFilter(ColumnExpression cexpr,
RelOp relOp,
Object value) |
boolean |
DbReaderStream.addRelOpFilter(ColumnExpression cexpr,
RelOp relOp,
Object value) |
StreamSqlResult |
YarchDatabase.execute(String query) |
void |
TableDefinition.setHistogramColumns(List<String> histoColumns) |
void |
TableDefinition.setPartitioningSpec(PartitioningSpec pspec)
time based partitions can be on the first column of the key (which has to be of type timestamp)
value based partitions can be on any other mandatory column
|
void |
TableDefinition.validate()
Checks that the table definition is valid:
- primary key not string, except for the last in the list (otherwise the binary sorting does not work properly)
|
| Constructor and Description |
|---|
MergeStream(YarchDatabase ydb,
AbstractStream[] streams,
String mergeColumn,
boolean ascending) |
TableDefinition(String name,
TupleDefinition tdef,
List<String> primaryKey)
Used when creating an "empty"(i.e.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ColumnNotFoundException |
class |
GenericStreamSqlException |
class |
NotSupportedException |
class |
ResourceNotFoundException |
| Modifier and Type | Method and Description |
|---|---|
Expression |
InExpression.addFilter(DbReaderStream tableStream) |
Expression |
AndExpression.addFilter(DbReaderStream tableStream) |
Expression |
RelationalExpression.addFilter(DbReaderStream tableStream) |
Expression |
Expression.addFilter(DbReaderStream tableStream)
add a filter to the table if applicable and returns an expression where the condition is removed.
|
Expression |
OrExpression.addFilter(DbReaderStream tableStream) |
protected void |
SumExpression.aggregateFillCode_newData(StringBuilder code) |
protected abstract void |
CompilableAggregateExpression.aggregateFillCode_newData(StringBuilder code) |
void |
SpeedLimitStreamExpression.bind(ExecutionContext c) |
void |
SelectExpression.bind(ExecutionContext c) |
void |
Expression.bind(TupleDefinition inputDef2) |
void |
WindowSpecification.bind(TupleDefinition inputDef) |
void |
AggregateExpression.bind(TupleDefinition def) |
void |
AggregateExpression.bindAggregate(TupleDefinition def)
When this is called, all the children are already bound.
|
CompiledExpression |
Expression.compile() |
CompiledExpression |
ColumnExpression.compile() |
CompiledExpression |
AggregateExpression.compile() |
CreateTableStatement |
StreamSqlParser.CreateTableStatement() |
protected void |
InExpression.doBind() |
void |
AndExpression.doBind() |
void |
NotExpression.doBind() |
void |
RelationalExpression.doBind() |
void |
ExponentExpression.doBind() |
protected abstract void |
Expression.doBind() |
void |
ValueExpression.doBind() |
void |
AdditiveExpression.doBind() |
void |
ColumnExpression.doBind() |
void |
MultiplicativeExpression.doBind() |
protected void |
SumExpression.doBind() |
void |
OrExpression.doBind() |
protected void |
FirstValExpression.doBind() |
void |
NegativeExpression.doBind() |
protected void |
LikeExpression.doBind() |
protected void |
AggregateListExpression.doBind() |
StreamSqlResult |
CreateOutputStreamStatement.execute(ExecutionContext c) |
StreamSqlResult |
ShowStreamsStatement.execute(ExecutionContext c) |
StreamSqlResult |
ShowTablesStatement.execute(ExecutionContext c) |
StreamSqlResult |
CloseStreamStatement.execute(ExecutionContext c) |
StreamSqlResult |
CreateStreamStatement.execute(ExecutionContext c) |
abstract StreamSqlResult |
StreamSqlStatement.execute(ExecutionContext c) |
StreamSqlResult |
ShowStreamStatement.execute(ExecutionContext c) |
AbstractStream |
SpeedLimitStreamExpression.execute(ExecutionContext c) |
AbstractStream |
SelectExpression.execute(ExecutionContext c) |
StreamSqlResult |
DeleteStatement.execute(ExecutionContext c) |
StreamSqlResult |
InsertStatement.execute(ExecutionContext c) |
StreamSqlResult |
CreateInputStreamStatement.execute(ExecutionContext c) |
StreamSqlResult |
DropTableStatement.execute(ExecutionContext c) |
StreamSqlResult |
CreateTableStatement.execute(ExecutionContext c) |
StreamSqlResult |
MergeStatement.execute(ExecutionContext c) |
protected void |
InExpression.fillCode_Constructor(StringBuilder code) |
protected void |
Expression.fillCode_Constructor(StringBuilder code) |
protected void |
InExpression.fillCode_getValueBody(StringBuilder code) |
protected void |
Expression.fillCode_getValueBody(StringBuilder code) |
void |
InExpression.fillCode_getValueReturn(StringBuilder code) |
void |
AndExpression.fillCode_getValueReturn(StringBuilder code) |
void |
NotExpression.fillCode_getValueReturn(StringBuilder code) |
void |
RelationalExpression.fillCode_getValueReturn(StringBuilder code) |
void |
ExponentExpression.fillCode_getValueReturn(StringBuilder code) |
protected abstract void |
Expression.fillCode_getValueReturn(StringBuilder code) |
void |
ValueExpression.fillCode_getValueReturn(StringBuilder code) |
void |
AdditiveExpression.fillCode_getValueReturn(StringBuilder code) |
void |
ColumnExpression.fillCode_getValueReturn(StringBuilder code) |
void |
MultiplicativeExpression.fillCode_getValueReturn(StringBuilder code) |
void |
OrExpression.fillCode_getValueReturn(StringBuilder code) |
void |
NegativeExpression.fillCode_getValueReturn(StringBuilder code) |
protected void |
LikeExpression.fillCode_getValueReturn(StringBuilder code) |
void |
AggregateExpression.fillCode_getValueReturn(StringBuilder code) |
CompiledAggregateExpression |
FirstValExpression.getCompiledAggregate() |
abstract CompiledAggregateExpression |
AggregateExpression.getCompiledAggregate() |
CompiledAggregateExpression |
CompilableAggregateExpression.getCompiledAggregate() |
CompiledAggregateExpression |
AggregateListExpression.getCompiledAggregate() |
StreamSqlStatement |
StreamSqlParser.OneStatement() |
StreamSqlStatement |
StreamSqlParser.StreamSqlStatement() |
Copyright © 2017 Space Applications Services. All rights reserved.