Github user ravipesala closed the pull request at:
https://github.com/apache/incubator-carbondata/pull/318
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
GitHub user ravipesala opened a pull request:
https://github.com/apache/incubator-carbondata/pull/318
[WIP] Dictionary server implementation for single pass data load
It is work under progress, we can review the design of this PR
You can merge this pull request into a Git
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/262#discussion_r87713382
--- Diff:
integration/spark/src/main/scala/org/apache/spark/mapreduce/CarbonHadoopMapReduceUtil.scala
---
@@ -0,0 +1,25
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/262#discussion_r87713012
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/CarbonInputFormat.java ---
@@ -61,7 +61,6 @@
import
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/262#discussion_r87712886
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/CarbonInputFormat.java ---
@@ -224,42 +221,29 @@ private void addSegmentsIfEmpty
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/262#discussion_r87712823
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/CarbonInputFormat.java ---
@@ -224,42 +221,29 @@ private void addSegmentsIfEmpty
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/262#discussion_r87712366
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/CarbonInputFormat.java ---
@@ -130,41 +130,27 @@ public static CarbonTable
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/312#discussion_r87695038
--- Diff:
integration/spark/src/main/scala/org/apache/carbondata/spark/CarbonDataFrameWriter.scala
---
@@ -60,7 +61,12 @@ class
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/277#discussion_r87549081
--- Diff:
core/src/test/java/org/apache/carbondata/core/util/ValueCompressionUtilTest.java
---
@@ -0,0 +1,563 @@
+/*
+ * Licensed
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/313#discussion_r8753
--- Diff:
integration/spark/src/test/scala/org/apache/carbondata/spark/testsuite/dataframe/DataFrameTestCase.scala
---
@@ -0,0 +1,57
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/305#discussion_r87540775
--- Diff:
core/src/test/java/org/apache/carbondata/core/keygenerator/mdkey/NumberCompressorUnitTest.java
---
@@ -0,0 +1,132
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/312#discussion_r87540864
--- Diff:
integration/spark/src/main/scala/org/apache/carbondata/spark/CarbonDataFrameWriter.scala
---
@@ -60,7 +60,8 @@ class
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/305#discussion_r87540550
--- Diff:
core/src/test/java/org/apache/carbondata/core/keygenerator/mdkey/BitsUnitTest.java
---
@@ -0,0 +1,98 @@
+/*
+ * Licensed
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/305#discussion_r87540505
--- Diff:
core/src/test/java/org/apache/carbondata/core/keygenerator/mdkey/BitsUnitTest.java
---
@@ -0,0 +1,98 @@
+/*
+ * Licensed
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/305#discussion_r87540197
--- Diff:
core/src/test/java/org/apache/carbondata/core/keygenerator/columnar/impl/MultiDimKeyVarLengthVariableSplitGeneratorUnitTest.java
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/303#discussion_r87531522
--- Diff:
core/src/test/java/org/apache/carbondata/core/util/CarbonMetadataUtilTest.java
---
@@ -0,0 +1,60 @@
+/*
+ * Licensed to
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/295#discussion_r87529444
--- Diff:
core/src/test/java/org/apache/carbondata/scan/result/impl/NonFilterQueryScannedResultTest.java
---
@@ -0,0 +1,53
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/295#discussion_r87529121
--- Diff:
core/src/test/java/org/apache/carbondata/scan/filter/resolver/metadata/FilterResolverMetadataTest.java
---
@@ -0,0 +1,37
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/295#discussion_r87527367
--- Diff:
core/src/main/java/org/apache/carbondata/scan/complextypes/PrimitiveQueryType.java
---
@@ -166,6 +166,7 @@ public
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/277#discussion_r87527053
--- Diff:
core/src/test/java/org/apache/carbondata/core/util/ValueCompressionUtilTest.java
---
@@ -0,0 +1,546 @@
+/*
+ * Licensed
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/277#discussion_r87526104
--- Diff:
core/src/test/java/org/apache/carbondata/core/util/ValueCompressionUtilTest.java
---
@@ -0,0 +1,546 @@
+/*
+ * Licensed
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/270#discussion_r87453971
--- Diff:
core/src/test/java/org/apache/carbondata/core/util/CarbonUtilTest.java ---
@@ -18,18 +18,746 @@
*/
package
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/269#discussion_r87446559
--- Diff:
processing/src/test/java/org/apache/carbondata/lcm/locks/ZooKeeperLockingTest.java
---
@@ -41,103 +41,103 @@
*/
public
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/269#discussion_r87446084
--- Diff: pom.xml ---
@@ -6,9 +6,7 @@
The ASF licenses this file to You under the Apache License, Version 2.0
(the "Li
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/269#discussion_r87444981
--- Diff:
core/src/test/java/org/apache/carbondata/core/carbon/AbsoluteTableIdentifierTest.java
---
@@ -0,0 +1,106
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/269#discussion_r87444589
--- Diff:
core/src/test/java/org/apache/carbondata/core/cache/dictionary/DictionaryByteArrayWrapperTest.java
---
@@ -0,0 +1,58
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/267#discussion_r87442533
--- Diff:
core/src/main/java/org/apache/carbondata/core/load/LoadMetadataDetails.java ---
@@ -150,7 +150,7 @@ public String getLoadStartTime
GitHub user ravipesala opened a pull request:
https://github.com/apache/incubator-carbondata/pull/313
[CARBONDATA-405]Fixed Data load fail if dataframe is created with LONG
datatype column
If the dataframe schema has long datatype then carbon table creation is
failing because it
GitHub user ravipesala opened a pull request:
https://github.com/apache/incubator-carbondata/pull/312
[CARBONDATA-404] Fixing dataframe save when loading in cluster mode.
Currently dataframe save writes temp csv in local folder so it fails in
cluster mode. This PR changes the temp
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/308#discussion_r87191882
--- Diff:
integration/spark/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala
---
@@ -1284,14 +1284,18
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87172561
--- Diff:
integration/spark/src/main/java/org/apache/carbondata/spark/load/CarbonLoaderUtil.java
---
@@ -215,6 +227,105 @@ public static
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87171862
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/converter/impl/RowConverterImpl.java
---
@@ -43,35 +45,58
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87171880
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/sort/impl/ParallelReadMergeSorterImpl.java
---
@@ -102,21
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87171144
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/sortandgroupby/sortdata/IntermediateFileMerger.java
---
@@ -110,7
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87171167
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/steps/SortProcessorStepImpl.java
---
@@ -50,6 +50,7 @@ public
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87171187
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/steps/DataConverterProcessorStepImpl.java
---
@@ -47,20 +58,109
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87170923
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/sortandgroupby/sortdata/SortParameters.java
---
@@ -122,6 +116,11
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87170873
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/surrogatekeysgenerator/csvbased/BadRecordslogger.java
---
@@ -81,13
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87170942
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/sortandgroupby/sortdata/SortDataRows.java
---
@@ -264,6 +277,72
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87170892
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/sortandgroupby/sortdata/SortTempFileChunkHolder.java
---
@@ -136,6
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87170828
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/util/CarbonDataProcessorUtil.java
---
@@ -396,4 +407,223 @@ private
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87170805
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/util/CarbonDataProcessorUtil.java
---
@@ -396,4 +407,223 @@ private
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87170789
--- Diff:
integration/spark/src/main/java/org/apache/carbondata/spark/load/CarbonLoaderUtil.java
---
@@ -215,6 +227,105 @@ public static
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87170848
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/surrogatekeysgenerator/csvbased/CarbonCSVBasedSeqGenStep.java
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r87170688
--- Diff:
integration/spark/src/main/java/org/apache/carbondata/spark/load/CarbonLoaderUtil.java
---
@@ -215,6 +227,105 @@ public static
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r86929386
--- Diff:
integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonDataRDDFactory.scala
---
@@ -761,6 +761,11 @@ object
GitHub user ravipesala opened a pull request:
https://github.com/apache/incubator-carbondata/pull/300
[CARBONDATA-359]is null & not null functions are not working when data
fetching from sub query
https://issues.apache.org/jira/browse/CARBONDATA-359
You can merge this
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/284#discussion_r86706791
--- Diff:
core/src/main/java/org/apache/carbondata/core/util/CarbonUtil.java ---
@@ -117,18 +117,27 @@ public static void closeStreams
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r86684431
--- Diff:
integration/spark/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala
---
@@ -1198,10 +1172,16 @@ case
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r86684268
--- Diff:
integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/NewCarbonDataLoadRDD.scala
---
@@ -0,0 +1,281
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r86684118
--- Diff:
integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/NewCarbonDataLoadRDD.scala
---
@@ -0,0 +1,281
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r86683755
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/DataLoadProcessExecutor.java
---
@@ -0,0 +1,28 @@
+package
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r86683750
--- Diff:
integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/NewCarbonDataLoadRDD.scala
---
@@ -0,0 +1,281
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r86683747
--- Diff:
integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/NewCarbonDataLoadRDD.scala
---
@@ -0,0 +1,281
GitHub user ravipesala opened a pull request:
https://github.com/apache/incubator-carbondata/pull/297
[CARBONDATA-284]Fixed compilation and checkstyle issues of PR 208
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ravipesala
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/293#discussion_r86498453
--- Diff:
integration/spark/src/test/scala/org/apache/spark/sql/TestCreateTable.scala ---
@@ -0,0 +1,30 @@
+/*
--- End diff
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/262#discussion_r86214621
--- Diff:
integration/spark/src/main/java/org/apache/carbondata/spark/load/CarbonLoaderUtil.java
---
@@ -953,66 +959,6 @@ public static
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/262#discussion_r86211496
--- Diff:
core/src/main/java/org/apache/carbondata/scan/filter/FilterExpressionProcessor.java
---
@@ -352,4 +354,18 @@ private
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/263#discussion_r85923089
--- Diff:
integration/spark/src/main/java/org/apache/carbondata/spark/load/CarbonLoaderUtil.java
---
@@ -213,6 +224,64 @@ public static
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/208#discussion_r85470691
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonTableInputFormat.java
---
@@ -0,0 +1,169 @@
+/*
+ * Licensed
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/208#discussion_r85470293
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/internal/segment/impl/IndexedSegment.java
---
@@ -0,0 +1,73
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/208#discussion_r85346673
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/internal/segment/impl/IndexedSegment.java
---
@@ -0,0 +1,73
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/208#discussion_r85343636
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/internal/index/impl/InMemoryBTreeIndex.java
---
@@ -0,0 +1,215
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/208#discussion_r85340545
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/internal/index/impl/InMemoryBTreeIndex.java
---
@@ -0,0 +1,215
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/208#discussion_r85339106
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/internal/CarbonFormat.java ---
@@ -0,0 +1,24 @@
+/*
+ * Licensed to the
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/208#discussion_r85337928
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonTableInputFormat.java
---
@@ -0,0 +1,169 @@
+/*
+ * Licensed
GitHub user ravipesala opened a pull request:
https://github.com/apache/incubator-carbondata/pull/263
[CARBONDATA-2][WIP] Data load integration of all steps for removing kettle
This PR integrates all data load steps to the main flow.
Still DataWriterStep need to be
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/251#discussion_r85270264
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/steps/writer/DataWriterProcessorStepImpl.java
---
@@ -0,0
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/251#discussion_r85270229
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/util/CarbonDataProcessorUtil.java
---
@@ -304,4 +311,92 @@ public
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/251#discussion_r85267495
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/steps/writer/DataWriterProcessorStepImpl.java
---
@@ -0,0
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/251#discussion_r85267443
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/store/CarbonFactHandlerFactory.java
---
@@ -0,0 +1,48
Here age is int data type so it cannot insert special characters. Please try
with string type and verify.
--
View this message in context:
http://apache-carbondata-mailing-list-archive.1130556.n5.nabble.com/In-load-data-CSV-row-contains-special-char-at-start-and-end-of-value-but-insert-as-a-NUL
GitHub user ravipesala opened a pull request:
https://github.com/apache/incubator-carbondata/pull/256
[CARBONDATA-213] Remove thrift complier dependency from default build.
By default `mvn install` does not include carbon-format, it downloads
dependency from repository.
User
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/251#discussion_r84519762
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/steps/writer/DataWriterProcessorStepImpl.java
---
@@ -0,0
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/244#discussion_r84518688
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/converter/impl/FieldEncoderFactory.java
---
@@ -0,0 +1,69
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/244#discussion_r84518288
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/converter/impl/RowConverterImpl.java
---
@@ -0,0 +1,99
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/247#discussion_r84517789
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/util/RemoveDictionaryUtil.java
---
@@ -123,6 +123,60 @@ private static
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/247#discussion_r84510901
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/util/RemoveDictionaryUtil.java
---
@@ -123,6 +123,60 @@ private static
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/247#discussion_r84510667
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/sortandgroupby/sortdata/SortDataRows.java
---
@@ -334,24 +151,24
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/247#discussion_r84510612
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/sortandgroupby/sortdata/SortDataRows.java
---
@@ -334,24 +151,24
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/247#discussion_r84510589
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/steps/SortProcessorStepImpl.java
---
@@ -0,0 +1,79
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/247#discussion_r84510340
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/sort/impl/CarbonParallelReadMergeSorterImpl.java
---
@@ -0,0
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/247#discussion_r84510002
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/sort/CarbonSorter.java
---
@@ -0,0 +1,56
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/244#discussion_r84508061
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/converter/impl/RowConverterImpl.java
---
@@ -0,0 +1,99
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/244#discussion_r84508220
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/converter/impl/FieldEncoderFactory.java
---
@@ -0,0 +1,59
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/244#discussion_r84508170
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/converter/impl/FieldEncoderFactory.java
---
@@ -0,0 +1,59
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/244#discussion_r84504071
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/converter/impl/RowConverterImpl.java
---
@@ -0,0 +1,99
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/240#discussion_r84476461
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/steps/input/InputProcessorStepImpl.java
---
@@ -0,0 +1,171
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/240#discussion_r84476407
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/steps/input/InputProcessorStepImpl.java
---
@@ -0,0 +1,171
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/240#discussion_r84476341
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/steps/input/InputProcessorStepImpl.java
---
@@ -0,0 +1,171
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/240#discussion_r84476023
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/steps/input/InputProcessorStepImpl.java
---
@@ -0,0 +1,171
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/240#discussion_r84475851
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/constants/DataLoadProcessorConstants.java
---
@@ -33,4 +33,8
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/240#discussion_r84475781
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/complexobjects/StructObject.java
---
@@ -0,0 +1,19
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/240#discussion_r84475566
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/parser/GenericParser.java
---
@@ -0,0 +1,22 @@
+package
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/240#discussion_r84475433
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/parser/CarbonParserFactory.java
---
@@ -0,0 +1,40
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/240#discussion_r84475299
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/AbstractDataLoadProcessorStep.java
---
@@ -114,11 +114,15
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/244#discussion_r84474223
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/encoding/impl/RowConverterImpl.java
---
@@ -0,0 +1,94
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/244#discussion_r84474110
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/encoding/impl/RowConverterImpl.java
---
@@ -0,0 +1,94
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/244#discussion_r84473500
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/encoding/impl/RowEncoderImpl.java
---
@@ -0,0 +1,132
Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/incubator-carbondata/pull/244#discussion_r84472920
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/newflow/encoding/RowEncoder.java
---
@@ -0,0 +1,32
1 - 100 of 164 matches
Mail list logo