Skip to main content
Source

​
pub async fn get_records_by_series<R: RetrievedRecord>( &self, table_name: String, world_table_name: String, offset: i32, limit: i32, ) -> Result<GetRecordsBySeriesResponse<R>, KineticaError>

Retrieve the complete series/track records from partial track information

Retrieves the complete series/track records from the given world_table_name based on the partial track information contained in the table_name.

This operation supports paging through the data via the offset and limit parameters.

In contrast to /get/records this returns records grouped by series/track. So if offset is 0 and limit is 5 this operation would return the first 5 series/tracks in table_name. Each series/track will be returned sorted by their TIMESTAMP column.

The records are decoded by the types the server names, as known to this client or else read from the server.

  • table_name - Name of the table or view for which series/tracks will be fetched, in [schema_name.]table_name format, using standard name resolution rules.
  • world_table_name - Name of the table containing the complete series/track information to be returned for the tracks present in the table_name, in [schema_name.]table_name format, using standard name resolution rules. Typically this is used when retrieving series/tracks from a view (which contains partial series/tracks) but the user wants to retrieve the entire original series/tracks. Can be blank.
  • offset - A positive integer indicating the number of initial series/tracks to skip (useful for paging through the results).
  • limit - A positive integer indicating the maximum number of series/tracks to be returned. Or END_OF_SET (-9999) to indicate that the max number of results should be returned.
Source

​
pub async fn get_records_by_series_with_opts<R: RetrievedRecord>( &self, table_name: String, world_table_name: String, offset: i32, limit: i32, options: GetRecordsBySeriesRequestOptions, ) -> Result<GetRecordsBySeriesResponse<R>, KineticaError>

Retrieve the complete series/track records from partial track information

Retrieves the complete series/track records from the given world_table_name based on the partial track information contained in the table_name.

This operation supports paging through the data via the offset and limit parameters.

In contrast to /get/records this returns records grouped by series/track. So if offset is 0 and limit is 5 this operation would return the first 5 series/tracks in table_name. Each series/track will be returned sorted by their TIMESTAMP column.

The records are decoded by the types the server names, as known to this client or else read from the server.

  • table_name - Name of the table or view for which series/tracks will be fetched, in [schema_name.]table_name format, using standard name resolution rules.
  • world_table_name - Name of the table containing the complete series/track information to be returned for the tracks present in the table_name, in [schema_name.]table_name format, using standard name resolution rules. Typically this is used when retrieving series/tracks from a view (which contains partial series/tracks) but the user wants to retrieve the entire original series/tracks. Can be blank.
  • offset - A positive integer indicating the number of initial series/tracks to skip (useful for paging through the results).
  • limit - A positive integer indicating the maximum number of series/tracks to be returned. Or END_OF_SET (-9999) to indicate that the max number of results should be returned.
  • options - The optional parameters; any left unset take the server’s defaults.

Sends a pre-built GetRecordsBySeriesRequest to the /get/records/byseries endpoint and decodes the records it returns, by record_type if given, else by the types the server names. Only binary encoding is supported.

Sends a pre-built GetRecordsBySeriesRequest to the /get/records/byseries endpoint, returning the response as the server sends it.

Sends a pre-built GetRecordsBySeriesRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.