| 50 | } |
| 51 | |
| 52 | void DataStream::fillFromProto(const Protos::DataStream & proto) |
| 53 | { |
| 54 | header = deserializeHeaderFromProto(proto.header()); |
| 55 | for (const auto & element : proto.distinct_columns()) |
| 56 | distinct_columns.emplace(element); |
| 57 | has_single_port = proto.has_single_port(); |
| 58 | for (const auto & proto_element : proto.sort_description()) |
| 59 | { |
| 60 | SortColumnDescription element; |
| 61 | element.fillFromProto(proto_element); |
| 62 | sort_description.emplace_back(std::move(element)); |
| 63 | } |
| 64 | sort_mode = DataStream::SortModeConverter::fromProto(proto.sort_mode()); |
| 65 | } |
| 66 | |
| 67 | void RuntimeAttributeDescription::fillFromProto(const Protos::RuntimeAttributeDescription & proto) |
| 68 | { |