Skip to content

Commit c4c02f8

Browse files
xiaoxmengtanjialiang
authored andcommitted
[native]Remove bucket property set in table write node
1 parent af88522 commit c4c02f8

File tree

2 files changed

+1
-9
lines changed

2 files changed

+1
-9
lines changed

presto-native-execution/presto_cpp/main/types/PrestoToVeloxQueryPlan.cpp

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
#include "presto_cpp/main/types/PrestoToVeloxConnector.h"
1717
#include "presto_cpp/main/types/PrestoToVeloxQueryPlan.h"
1818
#include <velox/type/Filter.h>
19-
#include "velox/connectors/hive/HiveDataSink.h"
2019
#include "velox/core/QueryCtx.h"
2120
#include "velox/exec/HashPartitionFunction.h"
2221
#include "velox/exec/RoundRobinPartitionFunction.h"
@@ -1317,12 +1316,6 @@ VeloxQueryPlanConverterBase::toVeloxQueryPlan(
13171316

13181317
auto insertTableHandle = std::make_shared<core::InsertTableHandle>(
13191318
connectorId, connectorInsertHandle);
1320-
bool hasBucketProperty{false};
1321-
if (auto* HiveInsertTableHandle =
1322-
dynamic_cast<velox::connector::hive::HiveInsertTableHandle*>(
1323-
connectorInsertHandle.get())) {
1324-
hasBucketProperty = HiveInsertTableHandle->bucketProperty() != nullptr;
1325-
}
13261319

13271320
const auto outputType = toRowType(
13281321
generateOutputVariables(
@@ -1348,7 +1341,6 @@ VeloxQueryPlanConverterBase::toVeloxQueryPlan(
13481341
std::move(aggregationNode),
13491342
std::move(insertTableHandle),
13501343
node->partitioningScheme != nullptr,
1351-
hasBucketProperty,
13521344
outputType,
13531345
getCommitStrategy(),
13541346
sourceVeloxPlan);

0 commit comments

Comments
 (0)