amkcpu opened a new pull request #22: URL: https://github.com/apache/incubator-streampipes/pull/22
### Purpose Currently, there is only one list of event keys (attributes), which gets expanded with the keys from all streams: `sortedEventKeys`. When connecting multiple streams to a Siddhi processing element, this leads to `NullPointerException`s and duplicate keys in the stream definition clause. This PR adds a HashMap containing a separate list of event keys for each stream. ### Approach 1. Adds the `listOfEventKeys` HashMap. Keys are the stream names, values are the lists containing the respective event key. This is somewhat similar to the already existing `siddhiInputHandlers` Map, just with a different purpose. 2. Changes registerEventTypeIfNotExists() to put new event keys there when invocating the processing element. 3. Changes onEvent() and toObjArr() to use the HashMap when receiving new events. ### Remarks Jira issue: None ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
