Skip to content

Commit

Permalink
[Coral-Trino] Use CoralSqlDialect during CoralRelNode to CoralSqlNode…
Browse files Browse the repository at this point in the history
… conversion (#521)

* temp

* temp

* use coralsqldialect in trino reltosql

* Import class not member
  • Loading branch information
KevinGe00 authored Jul 31, 2024
1 parent 74c2ca8 commit 8e03f4c
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,7 @@
import com.linkedin.coral.common.HiveMetastoreClient;
import com.linkedin.coral.common.functions.CoralSqlUnnestOperator;
import com.linkedin.coral.common.functions.FunctionFieldReferenceOperator;
import com.linkedin.coral.transformers.CoralRelToSqlNodeConverter;

import static com.google.common.base.Preconditions.*;
import static com.linkedin.coral.trino.rel2trino.CoralTrinoConfigKeys.*;
Expand Down Expand Up @@ -60,7 +61,7 @@ public class RelToTrinoConverter extends RelToSqlConverter {
* @param mscClient client interface used to interact with the Hive Metastore service.
*/
public RelToTrinoConverter(HiveMetastoreClient mscClient) {
super(TrinoSqlDialect.INSTANCE);
super(CoralRelToSqlNodeConverter.INSTANCE);
_hiveMetastoreClient = mscClient;
}

Expand All @@ -70,7 +71,7 @@ public RelToTrinoConverter(HiveMetastoreClient mscClient) {
* @param configs configs
*/
public RelToTrinoConverter(HiveMetastoreClient mscClient, Map<String, Boolean> configs) {
super(TrinoSqlDialect.INSTANCE);
super(CoralRelToSqlNodeConverter.INSTANCE);
checkNotNull(configs);
this.configs = configs;
_hiveMetastoreClient = mscClient;
Expand Down

0 comments on commit 8e03f4c

Please sign in to comment.