Skip to content
This repository has been archived by the owner on Sep 18, 2023. It is now read-only.

[NSE-909] "INSERT OVERWRITE x SELECT /*+ REPARTITION(2) */ * FROM y L… #912

Merged
merged 1 commit into from
May 11, 2022

Conversation

zhztheplayer
Copy link
Collaborator

…IMIT 2" drains 4 rows into table x using Arrow write extension

…IMIT 2" drains 4 rows into table x using Arrow write extension
@github-actions
Copy link

#909

Comment on lines +84 to +95
def setNumRows(batch: ColumnarBatch, numRows: Int): Unit = {
batch.setNumRows(numRows)
for (i <- 0 until batch.numCols()) {
val vector = batch.column(i)
vector match {
case av: ArrowWritableColumnVector =>
av.setValueCount(numRows)
case _ =>
}
}
}

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We'd better have a customized ColumnarBatch impl to override ColumnarBatch#setNumRows however it's not allowed because of ColumnarBatch's final modifier.

@zhouyuan zhouyuan merged commit a154e27 into oap-project:main May 11, 2022
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants