Package org.yamcs.http.api

Class 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

      All Methods Static Methods Instance Methods Concrete Methods 
      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 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

    • Constructor Detail

      • TableApi

        public TableApi()

    • Method Detail

      • 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>

      • 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>