feat(clp-s): Add an initialization method in SchemaReader that passes…

… the column map to FilterClass. (#709)

components/core/src/clp_s/SchemaReader.cpp

@@ -259,6 +259,10 @@ void SchemaReader::initialize_filter(FilterClass* filter) {
     filter->init(this, m_schema_id, m_columns);
 }
 
+void SchemaReader::initialize_filter_with_column_map(FilterClass* filter) {
+    filter->init(this, m_schema_id, m_column_map);
+}
+
 void SchemaReader::generate_local_tree(int32_t global_id) {
     std::stack<int32_t> global_id_stack;
     global_id_stack.emplace(global_id);

components/core/src/clp_s/SchemaReader.hpp

@@ -32,6 +32,19 @@ class FilterClass {
             std::vector<BaseColumnReader*> const& column_readers
     ) = 0;
 
+    /**
+     * Initializes the filter with a column map.
+     * Note: the column map only contains the ordered columns in a schema.
+     * @param reader
+     * @param schema_id
+     * @param column_map
+     */
+    virtual void init(
+            SchemaReader* reader,
+            int32_t schema_id,
+            std::unordered_map<int32_t, BaseColumnReader*> const& column_map
+    ) {}
+
     /**
      * Filters the message
      * @param cur_message
@@ -180,6 +193,13 @@ class SchemaReader {
      */
     void initialize_filter(FilterClass* filter);
 
+    /**
+     * Initializes the filter with a column map.
+     * Note: the column map only contains the ordered columns in a schema.
+     * @param filter
+     */
+    void initialize_filter_with_column_map(FilterClass* filter);
+
     /**
      * Marks a column as timestamp
      * @param column_reader