[ES|QL] Query executor implementation

[mashhurs]

Query executor implementation

• query execution
• Parse and map response data
• Decorate and push to output queue
• Error handling
• If any additional message ES sends (if limit isn’t set, do we get a message for the default limit?), notify