| Package | Description |
|---|---|
| org.yamcs.alarms | |
| org.yamcs.archive | |
| org.yamcs.artemis | |
| org.yamcs.tctm | |
| org.yamcs.yarch | |
| org.yamcs.yarch.streamsql |
| Modifier and Type | Field and Description |
|---|---|
static TupleDefinition |
AlarmServer.ALARM_TUPLE_DEFINITION |
| Modifier and Type | Field and Description |
|---|---|
static TupleDefinition |
XtceTmRecorder.RECORDED_TM_TUPLE_DEFINITION |
| Modifier and Type | Method and Description |
|---|---|
Tuple |
TupleTranslator.buildTuple(TupleDefinition tdef,
org.apache.activemq.artemis.api.core.client.ClientMessage message) |
Tuple |
TmTupleTranslator.buildTuple(TupleDefinition tdef,
org.apache.activemq.artemis.api.core.client.ClientMessage msg) |
Tuple |
EventTupleTranslator.buildTuple(TupleDefinition tdef,
org.apache.activemq.artemis.api.core.client.ClientMessage msg) |
Tuple |
PpTupleTranslator.buildTuple(TupleDefinition tdef,
org.apache.activemq.artemis.api.core.client.ClientMessage message) |
| Modifier and Type | Field and Description |
|---|---|
static TupleDefinition |
ParameterDataLinkInitialiser.PARAMETER_TUPLE_DEFINITION |
static TupleDefinition |
TcUplinkerAdapter.TC_TUPLE_DEFINITION |
static TupleDefinition |
TmDataLinkInitialiser.TM_TUPLE_DEFINITION |
| Modifier and Type | Field and Description |
|---|---|
TupleDefinition |
WindowProcessor.aggInputDef |
protected TupleDefinition |
AbstractStream.outputDefinition |
| Modifier and Type | Method and Description |
|---|---|
TupleDefinition |
TupleDefinition.copy() |
TupleDefinition |
Stream.getDefinition() |
TupleDefinition |
AbstractStream.getDefinition() |
TupleDefinition |
Tuple.getDefinition() |
TupleDefinition |
TableDefinition.getKeyDefinition() |
TupleDefinition |
TableDefinition.getTupleDefinition() |
TupleDefinition |
TableDefinition.getValueDefinition() |
| Modifier and Type | Method and Description |
|---|---|
static WindowProcessor |
WindowProcessor.getInstance(WindowSpecification spec,
TupleDefinition aggInputDef,
List<CompiledAggregateExpression> aggList,
TupleDefinition aggregateOutputDef) |
static DataType |
DataType.list(TupleDefinition td) |
void |
Tuple.setDefinition(TupleDefinition definition) |
static DataType |
DataType.tuple(TupleDefinition td) |
| Modifier and Type | Field and Description |
|---|---|
protected TupleDefinition |
Expression.inputDef |
| Modifier and Type | Method and Description |
|---|---|
TupleDefinition |
SpeedLimitStreamExpression.getOutputDefinition() |
TupleDefinition |
SelectExpression.getOutputDefinition() |
TupleDefinition |
StreamSqlParser.TupleDefinition() |
| Modifier and Type | Method and Description |
|---|---|
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.
|
| Constructor and Description |
|---|
CreateInputStreamStatement(String name,
TupleDefinition definition) |
CreateStreamStatement(String name,
TupleDefinition tupleDefinition) |
CreateTableStatement(boolean ifNotExists,
String tableName,
TupleDefinition tupleDefinition,
ArrayList<String> primaryKey) |
Copyright © 2017 Space Applications Services. All rights reserved.