It describes how to
- set up input and output queues, and how to connect them to the query
- feed individual XML documents/elements from a parser into the queues
- have different control flows of putting these elements into the queue
We are working on a more high-level API, but it might still some time to become stable enough for general usage.
Hope that helps.
Best Regards,
Peter Fischer
If you would like to refer to this comment somewhere else in this project, copy and paste the following link:
Is there any documentation for data stream processing via the Java API?
I need some Java examples that show the construction of an infinite XML stream, and continuous queries on it.
I also require the ability to place items on the stream at any time.
Anyone have ideas?
Hi williamdo,
MXQuery 0.6.0 does not have continuous query lifecycle API, so you have to build the XDM flow yourself.
In the download package and on the website there is one example file on how to exactly do this, see
http://mxquery.org/documentation/0.6.0/examples/StreamExample.java
It describes how to
- set up input and output queues, and how to connect them to the query
- feed individual XML documents/elements from a parser into the queues
- have different control flows of putting these elements into the queue
We are working on a more high-level API, but it might still some time to become stable enough for general usage.
Hope that helps.
Best Regards,
Peter Fischer