Skip to main content
Source

​
pub async fn filter( &self, table_name: String, view_name: String, expression: String, ) -> Result<FilterResponse, KineticaError>

Filter a dataset for records matching an expression

Filters data based on the specified expression. The results are stored in a result set with the given view_name.

For details see Expressions.

The response message contains the number of points for which the expression evaluated to be true, which is equivalent to the size of the result view.

  • table_name - Name of the table to filter, in [schema_name.]table_name format, using standard name resolution rules. This may be the name of a table or a view (when chaining queries).
  • view_name - If provided, then this will be the name of the view containing the results, in [schema_name.]view_name format, using standard name resolution rules and meeting table naming criteria. Must not be an already existing table or view.
  • expression - The select expression to filter the specified table. For details see Expressions.
Source

​
pub async fn filter_with_opts( &self, table_name: String, view_name: String, expression: String, options: FilterRequestOptions, ) -> Result<FilterResponse, KineticaError>

Filter a dataset for records matching an expression

Filters data based on the specified expression. The results are stored in a result set with the given view_name.

For details see Expressions.

The response message contains the number of points for which the expression evaluated to be true, which is equivalent to the size of the result view.

  • table_name - Name of the table to filter, in [schema_name.]table_name format, using standard name resolution rules. This may be the name of a table or a view (when chaining queries).
  • view_name - If provided, then this will be the name of the view containing the results, in [schema_name.]view_name format, using standard name resolution rules and meeting table naming criteria. Must not be an already existing table or view.
  • expression - The select expression to filter the specified table. For details see Expressions.
  • options - The optional parameters; any left unset take the server’s defaults.

Sends a pre-built FilterRequest to the /filter endpoint.

Source

​
pub async fn filter_from_url( &self, url: &str, request: &FilterRequest, ) -> Result<FilterResponse, KineticaError>

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