After many tries, in order to build a streaming query application on csv in
Eclipse I used:
As maven dependencies:
- commons-io 2.4 , commons-logging 1.1.3 , commons-lang3 3.2 , janino 2.7.6
, eigenbase-properties 1.1.5 , avatica 1.8.0, opencsv 2.3 , json-simple 1.1
and as external jars :
That still sounds like a version mismatch. Note that avatica releases are
separate from calcite these days. Therefore calcite-core-1.9.0-SNAPSHOT, for
instance, depends upon avatica-metrics-1.8.0.
I think you should use 1.9.0-SNAPSHOT versions of calcite- jars, and 1.8.0
versions of avatica-
I have imported as external jars calcite-example-csv, calcite-core, avatica
, linq4j, avatica-metrics, avatica-standalone with all their sources and
tests, and I get: Exception in thread "main" java.lang.AbstractMethodError:
You have mismatched versions. CANCEL_FLAG will be added to calcite-core only in
version 1.9. So, if you are using 1.9.0-SNAPSHOT version of example/csv you
should use a 1.9.0-SNAPSHOT version of other Calcite jars. (You can build and
install in your local repo using ‘mvn install’.)
1.9 should
It has to do with the dependencies. When I am running the sample code with
changes as Test in
../calcite-master/example/csv/src/test/java/org/apache/calcite/test/ I have
no errors. However, when I try to create my own project in Eclipse and
after I have imported everything with maven repositories
When I tried a query like SELECT STREAM ss.depts.deptno FROM ss.depts WHERE
ss.depts.deptno < 30; it gave me a correct answer on the SDEPTS.cvs in
sales folder with both my json and model-stream-table.json. I only had to
declare better where to find the tables and the columns, because with only
I am trying to create a simple streaming query ( like SELECT STREAM * FROM
ORDERS WHERE units > 10). I have created a stream using a socket that saves
the orders in an sOrders.csv file and I have changed the
model-stream-table.json like this:
{
version: '1.0',
defaultSchema: 'CUSTOM_TABLE',
