Skip to content

Commit

Permalink
code format
Browse files Browse the repository at this point in the history
  • Loading branch information
JkSelf committed Jan 12, 2024
1 parent 6e6e2c2 commit 32a54db
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 4 deletions.
3 changes: 2 additions & 1 deletion velox/connectors/hive/HiveDataSink.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -367,7 +367,8 @@ HiveDataSink::HiveDataSink(
hiveConfig_->isFileColumnNamesReadAsLowerCase(
connectorQueryCtx->sessionProperties()))
: nullptr),
dataChannels_(getNonPartitionChannels(partitionChannels_, inputType_->size())),
dataChannels_(
getNonPartitionChannels(partitionChannels_, inputType_->size())),
bucketCount_(
insertTableHandle_->bucketProperty() == nullptr
? 0
Expand Down
9 changes: 6 additions & 3 deletions velox/exec/tests/TableWriteTest.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1719,7 +1719,8 @@ TEST_P(AllTableWriterTest, commitStrategies) {
assertQuery(plan, "SELECT count(*) FROM tmp");

if (partitionedBy_.size() > 0) {
auto newOutputType = getNonPartitionsColumns(partitionedBy_, tableSchema_);
auto newOutputType =
getNonPartitionsColumns(partitionedBy_, tableSchema_);
assertQuery(
PlanBuilder().tableScan(newOutputType).planNode(),
makeHiveConnectorSplits(outputDirectory),
Expand Down Expand Up @@ -1755,7 +1756,8 @@ TEST_P(AllTableWriterTest, commitStrategies) {
assertQuery(plan, "SELECT count(*) FROM tmp");

if (partitionedBy_.size() > 0) {
auto newOutputType = getNonPartitionsColumns(partitionedBy_, tableSchema_);
auto newOutputType =
getNonPartitionsColumns(partitionedBy_, tableSchema_);
assertQuery(
PlanBuilder().tableScan(newOutputType).planNode(),
makeHiveConnectorSplits(outputDirectory),
Expand Down Expand Up @@ -2416,7 +2418,8 @@ TEST_P(BucketedTableOnlyWriteTest, bucketCountLimit) {
assertQueryWithWriterConfigs(plan, "SELECT count(*) FROM tmp");

if (partitionedBy_.size() > 0) {
auto newOutputType = getNonPartitionsColumns(partitionedBy_, tableSchema_);
auto newOutputType =
getNonPartitionsColumns(partitionedBy_, tableSchema_);
assertQuery(
PlanBuilder().tableScan(newOutputType).planNode(),
makeHiveConnectorSplits(outputDirectory),
Expand Down

0 comments on commit 32a54db

Please sign in to comment.