--- a/src/StreamletAttributeFinder.h Fri Jan 24 21:05:10 2020 +0100
+++ b/src/StreamletAttributeFinder.h Sat Jan 25 16:37:20 2020 +0100
@@ -95,7 +95,6 @@
}
virtual void writeFieldOfExistingFile(RelationalWriter* writer, const string_t& relationName, const RequestedField & field) override {
- // TODO: paralelize also over records → fork multiple processes and distribute records across them; then collect results (with a lock)
if (field.group == RequestedField::GROUP_STREAMLET) {
for (auto metadata : cachedMetadata[field.id]) {
SubProcess::Message m = subProcesses[field.id]->read();
@@ -105,7 +104,7 @@
SubProcess::Message m = subProcesses[field.id]->read();
if (m.code != StreamletMsg::WAITING_FOR_INPUT_ATTRIBUTES) throw RelpipeWriterException(L"Protocol violation from exec sub-process. Expected WAITING_FOR_INPUT_ATTRIBUTES but got: " + m.toString());
- // TODO: generic protocol violation error messages / method for checking responses
+ // FIXME: generic protocol violation error messages / method for checking responses
}
}