Module org.yamcs.core
Package org.yamcs.http.api

Class TableApi

java.lang.Object
org.yamcs.protobuf.AbstractTableApi<Context>
org.yamcs.http.api.TableApi
All Implemented Interfaces:
org.yamcs.api.Api<Context>
public class TableApi extends org.yamcs.protobuf.AbstractTableApi<Context>

  • Constructor Summary

    Constructors
    Constructor
    Description
    TableApi()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    executeSql(Context ctx, org.yamcs.protobuf.Table.ExecuteSqlRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.ResultSet> observer)
     
    void
    executeStreamingSql(Context ctx, org.yamcs.protobuf.Table.ExecuteSqlRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.ResultSet> observer)
     
    void
    getStream(Context ctx, org.yamcs.protobuf.Table.GetStreamRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.StreamInfo> observer)
     
    void
    getTable(Context ctx, org.yamcs.protobuf.Table.GetTableRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.TableInfo> observer)
     
    void
    getTableData(Context ctx, org.yamcs.protobuf.Table.GetTableDataRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.TableData> observer)
     
    void
    listStreams(Context ctx, org.yamcs.protobuf.Table.ListStreamsRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.ListStreamsResponse> observer)
     
    void
    listTables(Context ctx, org.yamcs.protobuf.Table.ListTablesRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.ListTablesResponse> observer)
     
    void
    readRows(Context ctx, org.yamcs.protobuf.Table.ReadRowsRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.Row> observer)
     
    void
    rebuildHistogram(Context ctx, org.yamcs.protobuf.Table.RebuildHistogramRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.RebuildHistogramResponse> observer)
     
    void
    subscribeStream(Context ctx, org.yamcs.protobuf.Table.SubscribeStreamRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.StreamData> observer)
     
    void
    subscribeStreamStatistics(Context ctx, org.yamcs.protobuf.Table.SubscribeStreamStatisticsRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.StreamEvent> observer)
     
    static final List<org.yamcs.protobuf.Table.ColumnData>
    toColumnDataList(Tuple tuple)
     
    static Stream
    verifyStream(Context ctx, YarchDatabaseInstance ydb, String streamName)
     
    org.yamcs.api.Observer<org.yamcs.protobuf.Table.WriteRowsRequest>
    writeRows(Context ctx, org.yamcs.api.Observer<org.yamcs.protobuf.Table.WriteRowsResponse> observer)
     

    Methods inherited from class org.yamcs.protobuf.AbstractTableApi

    callMethod, callMethod, getDescriptorForType, getRequestPrototype, getResponsePrototype

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • TableApi

      public TableApi()

  • Method Details

    • listStreams

      public void listStreams(Context ctx, org.yamcs.protobuf.Table.ListStreamsRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.ListStreamsResponse> observer)
      Specified by:
      listStreams in class org.yamcs.protobuf.AbstractTableApi<Context>

    • subscribeStreamStatistics

      public void subscribeStreamStatistics(Context ctx, org.yamcs.protobuf.Table.SubscribeStreamStatisticsRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.StreamEvent> observer)
      Specified by:
      subscribeStreamStatistics in class org.yamcs.protobuf.AbstractTableApi<Context>

    • getStream

      public void getStream(Context ctx, org.yamcs.protobuf.Table.GetStreamRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.StreamInfo> observer)
      Specified by:
      getStream in class org.yamcs.protobuf.AbstractTableApi<Context>

    • subscribeStream

      public void subscribeStream(Context ctx, org.yamcs.protobuf.Table.SubscribeStreamRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.StreamData> observer)
      Specified by:
      subscribeStream in class org.yamcs.protobuf.AbstractTableApi<Context>

    • listTables

      public void listTables(Context ctx, org.yamcs.protobuf.Table.ListTablesRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.ListTablesResponse> observer)
      Specified by:
      listTables in class org.yamcs.protobuf.AbstractTableApi<Context>

    • getTable

      public void getTable(Context ctx, org.yamcs.protobuf.Table.GetTableRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.TableInfo> observer)
      Specified by:
      getTable in class org.yamcs.protobuf.AbstractTableApi<Context>

    • getTableData

      public void getTableData(Context ctx, org.yamcs.protobuf.Table.GetTableDataRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.TableData> observer)
      Specified by:
      getTableData in class org.yamcs.protobuf.AbstractTableApi<Context>

    • readRows

      public void readRows(Context ctx, org.yamcs.protobuf.Table.ReadRowsRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.Row> observer)
      Specified by:
      readRows in class org.yamcs.protobuf.AbstractTableApi<Context>

    • writeRows

      public org.yamcs.api.Observer<org.yamcs.protobuf.Table.WriteRowsRequest> writeRows(Context ctx, org.yamcs.api.Observer<org.yamcs.protobuf.Table.WriteRowsResponse> observer)
      Specified by:
      writeRows in class org.yamcs.protobuf.AbstractTableApi<Context>

    • executeSql

      public void executeSql(Context ctx, org.yamcs.protobuf.Table.ExecuteSqlRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.ResultSet> observer)
      Specified by:
      executeSql in class org.yamcs.protobuf.AbstractTableApi<Context>

    • executeStreamingSql

      public void executeStreamingSql(Context ctx, org.yamcs.protobuf.Table.ExecuteSqlRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.ResultSet> observer)
      Specified by:
      executeStreamingSql in class org.yamcs.protobuf.AbstractTableApi<Context>

    • verifyStream

      public static Stream verifyStream(Context ctx, YarchDatabaseInstance ydb, String streamName)

    • toColumnDataList

      public static final List<org.yamcs.protobuf.Table.ColumnData> toColumnDataList(Tuple tuple)

    • rebuildHistogram

      public void rebuildHistogram(Context ctx, org.yamcs.protobuf.Table.RebuildHistogramRequest request, org.yamcs.api.Observer<org.yamcs.protobuf.Table.RebuildHistogramResponse> observer)
      Specified by:
      rebuildHistogram in class org.yamcs.protobuf.AbstractTableApi<Context>