Login  Register

[GitHub] [carbondata] ajantha-bhat commented on a change in pull request #4034: [CARBONDATA-4091] support prestosql 333 integartion with carbon

Posted by GitBox on Jan 13, 2021; 2:03am
URL: http://apache-carbondata-dev-mailing-list-archive.168.s1.nabble.com/GitHub-carbondata-ajantha-bhat-opened-a-new-pull-request-4034-WIP-support-prestosql-333-tp104025p105389.html


ajantha-bhat commented on a change in pull request #4034:
URL: https://github.com/apache/carbondata/pull/4034#discussion_r556215178



##########
File path: integration/presto/src/main/prestosql/org/apache/carbondata/presto/CarbonDataMetaData.java
##########
@@ -73,18 +74,27 @@
   private MapredCarbonOutputCommitter carbonOutputCommitter;
   private JobContextImpl jobContext;
 
-  public CarbonDataMetaData(SemiTransactionalHiveMetastore metastore,
-      HdfsEnvironment hdfsEnvironment, HivePartitionManager partitionManager, DateTimeZone timeZone,
-      boolean allowCorruptWritesForTesting, boolean writesToNonManagedTablesEnabled,
-      boolean createsOfNonManagedTablesEnabled, TypeManager typeManager,
+  public CarbonDataMetaData(
+      CatalogName catalogName,
+      SemiTransactionalHiveMetastore metastore,
+      HdfsEnvironment hdfsEnvironment,
+      HivePartitionManager partitionManager,
+      DateTimeZone timeZone,
+      boolean allowCorruptWritesForTesting,
+      boolean writesToNonManagedTablesEnabled,
+      boolean createsOfNonManagedTablesEnabled,
+      boolean translateHiveViews, TypeManager typeManager,
       LocationService locationService,
-      io.airlift.json.JsonCodec<PartitionUpdate> partitionUpdateCodec,
-      TypeTranslator typeTranslator, String prestoVersion,
-      HiveStatisticsProvider hiveStatisticsProvider, AccessControlMetadata accessControlMetadata) {
-    super(metastore, hdfsEnvironment, partitionManager, timeZone, allowCorruptWritesForTesting,
-        true, createsOfNonManagedTablesEnabled, typeManager,
-        locationService, partitionUpdateCodec, typeTranslator, prestoVersion,
-        hiveStatisticsProvider, accessControlMetadata);
+      JsonCodec<PartitionUpdate> partitionUpdateCodec,
+      TypeTranslator typeTranslator,
+      String prestoVersion,
+      HiveStatisticsProvider hiveStatisticsProvider,
+      AccessControlMetadata accessControlMetadata) {
+    super(catalogName, metastore, hdfsEnvironment, partitionManager, timeZone,
+        allowCorruptWritesForTesting, writesToNonManagedTablesEnabled,

Review comment:
       Insert has passed now.
   
   presto:aj333> select * from t1;
    name
   ------
    aj
    ab
   (2 rows)
   
   Query 20210113_015933_00005_6sfgc, FINISHED, 1 node
   Splits: 18 total, 18 done (100.00%)
   0:04 [2 rows, 22B] [0 rows/s, 5B/s]
   
   presto:aj333> insert into t1 values('junk');
   INSERT: 1 row
   
   Query 20210113_015940_00006_6sfgc, FINISHED, 1 node
   Splits: 35 total, 35 done (100.00%)
   0:04 [0 rows, 0B] [0 rows/s, 0B/s]
   
   presto:aj333> select * from t1;
    name
   ------
    junk
    aj
    ab
   (3 rows)
   
   Query 20210113_015951_00007_6sfgc, FINISHED, 1 node
   Splits: 19 total, 19 done (100.00%)
   0:00 [3 rows, 35B] [11 rows/s, 137B/s]
   




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]