Filter Use Cases

Working with data filters. More...

Working with data filters.

Introduction

RTI Connext supports filtering data either during the exchange from dds::pub::DataWriter to dds::sub::DataReader, or after the data has been stored at the dds::sub::DataReader.

Filtering during the exchange process is performed by a dds::topic::ContentFilteredTopic, which is created by the dds::sub::DataReader as a way of specifying a subset of the data samples that it wishes to receive.

Filtering samples that have already been received by the dds::sub::DataReader is performed by creating a dds::sub::cond::QueryCondition, which can then used to check for matching samples, be alerted when matching samples arrive, or retrieve matching samples.

Filtering may be performed on any topic, either keyed or un-keyed, except the built-in topics. Filtering may be performed on any field, subset of fields, or combination of fields, subject only to the limitations of the filter syntax.

Code Examples

The following #includes are needed for the examples on this page

#include <iostream>
#include <dds/topic/ddstopic.hpp>
#include <dds/sub/ddssub.hpp>
#include "Foo.hpp"

Filtering with ContentFilteredTopic

• Set up a Subscriber

• Set up a Topic

• Create a ContentFilteredTopic, of user data type Foo:

      // Create the DomainParticipant
      dds::domain::DomainParticipant participant(0);
  
      // Create a Topic
      dds::topic::Topic<Foo> topic(participant, "MyTopicName");
  
      // Create the parameter list
      std::vector<std::string> cft_parameters(2);
      cft_parameters[0] = "1";
      cft_parameters[1] = "100";
  
      // Create the ContentFilteredTopic
      dds::topic::ContentFilteredTopic<Foo> cft(
          topic, // related topic
          "ContentFilteredTopic", // local name for the CFT
          dds::topic::Filter( // filter (constructed in-line in this example)
              "x > %0 AND x < %1", // expression
              cft_parameters)); // parameter vector
  
      // Parameters are optional
      dds::topic::ContentFilteredTopic<Foo> cft2(
          topic,
          "ContentFilteredTopic2",
          dds::topic::Filter("x = 100 AND y < 20"));

  
  
• Create a DataReader using the ContentFilteredTopic:

      dds::sub::DataReader<Foo> reader(subscriber, cft);

  Once setup, reading samples with a dds::topic::ContentFilteredTopic is exactly the same as normal reads or takes, as described in DataReader Use Cases.
  
  
• Changing filter criteria:

      std::vector<std::string> new_cft_parameters(2);
      new_cft_parameters[0] = "5";
      new_cft_parameters[1] = "9";
  
      cft.filter_parameters(new_cft_parameters.begin(), new_cft_parameters.end());

Filtering with Query Conditions

• Creating a QueryCondition

      // Create parameter list
      std::vector<std::string> query_parameters(2);
      query_parameters[0] = "1";
      query_parameters[1] = "100";
  
      // Create query condition
      dds::sub::cond::QueryCondition query_condition(
          dds::sub::Query(reader, "x > %0 AND x < %1", query_parameters),
          dds::sub::status::DataState::any_data());

  
  
• You can use a QueryCondition in a WaitSet: see Waiting for Condition(s) to trigger

• And to query for data in a DataReader: see Selecting what samples to read

• To modify the filter criteria you can use dds::sub::cond::QueryCondition::parameters (similar to dds::topic::ContentFilteredTopic::filter_parameters)