It might be case-sensitivity. Try double-quoting the column names in your query.
Julian > On Sep 4, 2016, at 09:43, Γιώργος Θεοδωράκης <[email protected]> wrote: > > I have correctly used sqlline to run queries on a streaming table, but now > I face problems trying to implement it programmatically with java. I have > made an attempt, but haven't got it running yet ( > http://stackoverflow.com/questions/39318653/create-a-streaming-example-with-calcite-using-csv > ). > Can somebody help me by giving a template or finding what's wrong with my > code? > > Thank you in advance, > George > > 2016-09-03 18:14 GMT+03:00 Γιώργος Θεοδωράκης <[email protected]>: > >> 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 the name it wouldn't run. I still haven't fixed my sOrders.csv yet, >> but I suppose it has to do with how I have created. >> >> 2016-09-03 15:39 GMT+03:00 Γιώργος Θεοδωράκης <[email protected]>: >> >>> 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', >>> schemas: [ >>> { >>> name: 'CUSTOM_TABLE', >>> tables: [ >>> { >>> name: 'ORDERS', >>> type: 'custom', >>> factory: 'org.apache.calcite.adapter.cs >>> v.CsvStreamTableFactory', >>> stream: { >>> stream: true >>> }, >>> operand: { >>> file: '/home/hduser/Desktop/sOrders.csv', >>> flavor: "scannable" >>> } >>> } >>> ] >>> } >>> >>> , because when I had defaultSchema: 'STREAM' it showed: Error while >>> executing SQL "SELECT STREAM * FROM orders": From line 1, column 22 to line >>> 1, column 27: Table 'ORDERS' not found (state=,code=0). >>> >>> Everything is good, until I try to project or filter a column when it >>> shows: Error while executing SQL "SELECT STREAM productId FROM orders": >>> From line 1, column 15 to line 1, column 23: Column 'PRODUCTID' not found >>> in any table (state=,code=0). When I type !columns I get: CUSTOM_TABLE | >>> ORDERS | productId | 4 | JavaType(class... >>> >>> To solve my problem, should I write from the >>> start CsvStreamFilterableTable.java etc. or are these operations already >>> implemented? >>> >>> Thank you in advance, >>> George >>
