File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -23,10 +23,10 @@ namespace facebook::velox::parquet {
2323
2424void registerParquetReaderFactory (ParquetReaderType parquetReaderType) {
2525 switch (parquetReaderType) {
26- case ParquetReaderType::DUCKDB:
26+ /* case ParquetReaderType::DUCKDB:
2727 dwio::common::registerReaderFactory(
2828 std::make_shared<duckdb_reader::ParquetReaderFactory>());
29- break ;
29+ break;*/
3030 case ParquetReaderType::NATIVE:
3131 dwio::common::registerReaderFactory (
3232 std::make_shared<ParquetReaderFactory>());
Original file line number Diff line number Diff line change @@ -222,7 +222,7 @@ core::PlanNodePtr SubstraitVeloxPlanConverter::toVeloxPlan(
222222 sJoin .advanced_extension (), " isExistenceJoin=" )) {
223223 joinType = core::JoinType::kLeftSemiProject ;
224224 } else {
225- joinType = core::JoinType::kLeftSemi ;
225+ joinType = core::JoinType::kLeftSemiFilter ;
226226 }
227227 break ;
228228 case ::substrait::JoinRel_JoinType::JoinRel_JoinType_JOIN_TYPE_RIGHT_SEMI:
@@ -232,7 +232,7 @@ core::PlanNodePtr SubstraitVeloxPlanConverter::toVeloxPlan(
232232 sJoin .advanced_extension (), " isExistenceJoin=" )) {
233233 joinType = core::JoinType::kRightSemiProject ;
234234 } else {
235- joinType = core::JoinType::kRightSemi ;
235+ joinType = core::JoinType::kRightSemiFilter ;
236236 }
237237 break ;
238238 case ::substrait::JoinRel_JoinType::JoinRel_JoinType_JOIN_TYPE_ANTI: {
You can’t perform that action at this time.
0 commit comments