http://git-wip-us.apache.org/repos/asf/carbondata/blob/2ea3b2dc/store/sdk/src/main/java/org/apache/carbondata/store/LocalCarbonStore.java ---------------------------------------------------------------------- diff --git a/store/sdk/src/main/java/org/apache/carbondata/store/LocalCarbonStore.java b/store/sdk/src/main/java/org/apache/carbondata/store/LocalCarbonStore.java index 9e338e7..daa1447 100644 --- a/store/sdk/src/main/java/org/apache/carbondata/store/LocalCarbonStore.java +++ b/store/sdk/src/main/java/org/apache/carbondata/store/LocalCarbonStore.java @@ -65,7 +65,7 @@ class LocalCarbonStore extends MetaCachedCarbonStore { Objects.requireNonNull(projectColumns); CarbonTable table = getTable(path); - if (table.isStreamingTable() || table.isHivePartitionTable()) { + if (table.isStreamingSink() || table.isHivePartitionTable()) { throw new UnsupportedOperationException("streaming and partition table is not supported"); } // TODO: use InputFormat to prune data and read data
http://git-wip-us.apache.org/repos/asf/carbondata/blob/2ea3b2dc/streaming/src/main/scala/org/apache/carbondata/streaming/parser/RowStreamParserImp.scala ---------------------------------------------------------------------- diff --git a/streaming/src/main/scala/org/apache/carbondata/streaming/parser/RowStreamParserImp.scala b/streaming/src/main/scala/org/apache/carbondata/streaming/parser/RowStreamParserImp.scala index 1696fdc..5a888ef 100644 --- a/streaming/src/main/scala/org/apache/carbondata/streaming/parser/RowStreamParserImp.scala +++ b/streaming/src/main/scala/org/apache/carbondata/streaming/parser/RowStreamParserImp.scala @@ -17,7 +17,6 @@ package org.apache.carbondata.streaming.parser -import java.nio.charset.Charset import java.text.SimpleDateFormat import org.apache.hadoop.conf.Configuration
