| Modifier and Type | Method and Description |
|---|---|
void |
CcsdsTmIndex.onTuple(Stream stream,
Tuple tuple) |
void |
YarchReplay.onTuple(Stream s,
Tuple t) |
Object |
ParameterReplayHandler.transform(Tuple t) |
com.google.protobuf.MessageLite |
XtceTmReplayHandler.transform(Tuple tuple) |
com.google.protobuf.MessageLite |
EventReplayHandler.transform(Tuple t) |
Object |
ReplayHandler.transform(Tuple t) |
com.google.protobuf.MessageLite |
CommandHistoryReplayHandler.transform(Tuple t) |
static Commanding.CommandHistoryEntry |
GPBHelper.tupleToCommandHistoryEntry(Tuple tuple) |
static Yamcs.TmPacketData |
GPBHelper.tupleToTmPacketData(Tuple tuple) |
| Modifier and Type | Method and Description |
|---|---|
static Tuple |
Util.transform(Commanding.CommandHistoryEntry che)
Transforms protobuf messages of type CommandHistoryEntry to tuples.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StreamCommandHistoryProvider.onTuple(Stream s,
Tuple tuple) |
static Commanding.CommandHistoryEntry |
Util.transform(Tuple t)
Transforms a tuple as received on the command history stream to protobuf
|
| Modifier and Type | Method and Description |
|---|---|
Tuple |
PreparedCommand.toTuple() |
| Modifier and Type | Method and Description |
|---|---|
static PreparedCommand |
PreparedCommand.fromTuple(Tuple t) |
static Commanding.CommandId |
PreparedCommand.getCommandId(Tuple t) |
| Modifier and Type | Method and Description |
|---|---|
void |
BackFiller.onTuple(Stream stream,
Tuple tuple) |
| Modifier and Type | Method and Description |
|---|---|
void |
SystemParametersProvider.onTuple(Stream s,
Tuple tuple) |
| Modifier and Type | Method and Description |
|---|---|
void |
BackFiller.onTuple(Stream stream,
Tuple tuple) |
| Modifier and Type | Method and Description |
|---|---|
void |
StreamParameterProvider.onTuple(Stream s,
Tuple tuple)
Make sure all parameters are defined in the XtceDB, otherwise the PRM will choke
|
| Modifier and Type | Method and Description |
|---|---|
abstract T |
StreamToChunkedProtobufEncoder.mapTuple(Tuple tuple) |
void |
RestStreamSubscriber.onTuple(Stream stream,
Tuple tuple) |
void |
StreamToChunkedTransferEncoder.processTuple(Stream stream,
Tuple tuple) |
abstract void |
RestStreamSubscriber.processTuple(Stream stream,
Tuple tuple) |
abstract void |
StreamToChunkedTransferEncoder.processTuple(Tuple tuple,
io.netty.buffer.ByteBufOutputStream bufOut) |
void |
StreamToChunkedProtobufEncoder.processTuple(Tuple tuple,
io.netty.buffer.ByteBufOutputStream bufOut) |
void |
StreamToChunkedCSVEncoder.processTuple(Tuple tuple,
io.netty.buffer.ByteBufOutputStream bufOut) |
abstract void |
StreamToChunkedCSVEncoder.processTuple(Tuple tuple,
com.csvreader.CsvWriter csvWriter) |
| Modifier and Type | Method and Description |
|---|---|
void |
TableDumpEncoder.processTuple(Tuple tuple,
io.netty.buffer.ByteBufOutputStream bufOut) |
static Archive.StreamData |
ArchiveHelper.toStreamData(Stream stream,
Tuple tuple) |
| Modifier and Type | Method and Description |
|---|---|
protected Tuple |
AbstractTableReaderStream.dataToTuple(byte[] k,
byte[] v) |
Tuple |
TableDefinition.deserialize(byte[] k,
byte[] v) |
| Modifier and Type | Method and Description |
|---|---|
List<Tuple> |
WindowProcessor.newData(Tuple tuple)
When windows closes, returns a list with the tuples to be emitted, otherwise returns null
|
| Modifier and Type | Method and Description |
|---|---|
void |
Stream.emitTuple(Tuple t) |
void |
AbstractStream.emitTuple(Tuple tuple) |
Partition |
PartitionManager.getPartitionForTuple(Tuple t)
Gets partition where tuple has to be written.
|
Object |
CompiledExpression.getValue(Tuple tuple) |
Object |
ConstantValueCompiledExpression.getValue(Tuple tuple) |
Object |
FieldReturnCompiledExpression.getValue(Tuple tuple) |
void |
Stream.ExceptionHandler.handle(Tuple tuple,
StreamSubscriber s,
Throwable t) |
protected abstract boolean |
WindowProcessor.isOutsideWindow(Tuple tuple) |
void |
CompiledFirstVal.newData(Tuple tuple) |
void |
CompiledAggregateExpression.newData(Tuple tuple) |
List<Tuple> |
WindowProcessor.newData(Tuple tuple)
When windows closes, returns a list with the tuples to be emitted, otherwise returns null
|
void |
CompiledAggregateList.newData(Tuple tuple) |
void |
OutputStream.onTuple(Stream s,
Tuple t) |
void |
SelectStream.onTuple(Stream stream,
Tuple t) |
void |
MergeStream.onTuple(Stream s,
Tuple tuple) |
void |
SpeedLimitStream.onTuple(Stream s,
Tuple t) |
void |
StreamSubscriber.onTuple(Stream stream,
Tuple tuple) |
byte[] |
TableDefinition.serializeKey(Tuple t)
Transforms the key part of the tuple into a byte array to be written to
disk.
|
byte[] |
TableDefinition.serializeValue(Tuple t)
Transform the value part of the tuple into a byte array to be written on
disk.
|
protected abstract void |
WindowProcessor.setFirstTuple(Tuple tuple) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
AbstractTableWriter.addHistogram(YRDB db,
Tuple t) |
RdbPartition |
CfTableWriter.getDbPartition(Tuple t)
get the filename where the tuple would fit (can be a partition)
|
abstract RdbPartition |
AbstractTableWriter.getDbPartition(Tuple tuple) |
RdbPartition |
InKeyTableWriter.getDbPartition(Tuple t)
get the filename where the tuple would fit (can be a partition)
|
void |
CfTableWriter.onTuple(Stream stream,
Tuple t) |
void |
InKeyTableWriter.onTuple(Stream stream,
Tuple t) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
RdbTableWriter.addHistogram(YRDB db,
Tuple t) |
RdbPartition |
RdbTableWriter.getDbPartition(Tuple t)
get the filename where the tuple would fit (can be a partition)
|
void |
RdbTableWriter.onTuple(Stream stream,
Tuple t) |
Copyright © 2018 Space Applications Services. All rights reserved.