How can I debug carbondata program on windows system

2019-03-20 Thread Jocean shi
Hi: Can't run program on windows system Best Jocean.shi

Re: 答复: spark streaming insert data error

2019-03-20 Thread David CaiQiang
There are all documents(include streaming table) under the following link. https://github.com/apache/carbondata/tree/master/docs You can find all examples in examples/spark2 module: example 1 (support Update/Delete) https://github.com/apache/carbondata/blob/master/examples/spark2/src/main/scala/or

Re: spark streaming insert data error

2019-03-20 Thread Jocean shi
HI yanggs: The example is SparkStreamingExample in source code. Streaming table don't support update/delete Best Jocean.shi Jocean shi 于2019年3月20日周三 下午4:09写道: > HI: > > I dont't use CarbonTable.getCreateOrderColumn method. > All the method controller is Carbondata. > If my DataFrame schema ord

Re: spark streaming insert data error

2019-03-20 Thread Jocean shi
HI: I dont't use CarbonTable.getCreateOrderColumn method. All the method controller is Carbondata. If my DataFrame schema order don't match table schema order then error Best Jocean.shi David CaiQiang 于2019年3月20日周三 下午3:48写道: > You can get table schema by CarbonTable.getCreateOrderColumn metho

答复: spark streaming insert data error

2019-03-20 Thread yanggs
I want to using spark streaming insert data into carbondata. But I cann’t find any example for it.can you help for it. Another question is that Spark streaming is support update/delete carbondata table?

Re: spark streaming insert data error

2019-03-20 Thread David CaiQiang
You can get table schema by CarbonTable.getCreateOrderColumn method. It will return the correct table schema. "name,city,id,salary" is the order of column storage, it is not the table schema. - Best Regards David Cai -- Sent from: http://apache-carbondata-dev-mailing-list-archive.1130556.n

spark streaming insert data error

2019-03-20 Thread Jocean shi
Hi: I use spark streaming insert data into carbondata. I find that the schema of my data don't match the schema of table. after the method of class RowParserImpl: @Override public Object[] parseRow(Object[] row) { if (row == null) { return new String[numberOfColumns]; } // If number of