@@ -30,7 +30,7 @@ class Join : public Operator {
3030 throw std::runtime_error (" Unknown port type: " + type);
3131 }
3232
33- PortType::add_port (*this , type, true , false ); // input only
33+ PortType::add_port (*this , type, true , false , false ); // input only
3434 data_time_tracker_[num_data_ports () - 1 ] = std::set<timestamp_t >();
3535 port_type_names_.push_back (type);
3636 }
@@ -40,7 +40,7 @@ class Join : public Operator {
4040 if (!PortType::is_valid_port_type (type)) {
4141 throw std::runtime_error (" Unknown port type: " + type);
4242 }
43- PortType::add_port (*this , type, false , true ); // output only
43+ PortType::add_port (*this , type, false , false , true ); // output only
4444 }
4545 }
4646
@@ -55,7 +55,7 @@ class Join : public Operator {
5555 throw std::runtime_error (" Unknown port type: " + type);
5656 }
5757
58- PortType::add_port (*this , type, true , true );
58+ PortType::add_port (*this , type, true , false , true );
5959 data_time_tracker_[num_data_ports () - 1 ] = std::set<timestamp_t >();
6060 port_type_names_.push_back (type);
6161 }
@@ -70,7 +70,7 @@ class Join : public Operator {
7070
7171 std::string port_type = PortType::get_port_type<T>();
7272 for (size_t i = 0 ; i < num_ports; ++i) {
73- PortType::add_port (*this , port_type, true , true );
73+ PortType::add_port (*this , port_type, true , false , true );
7474 data_time_tracker_[i] = std::set<timestamp_t >();
7575 port_type_names_.push_back (port_type);
7676 }
0 commit comments