database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](jni) fix jni_reader function name get_nex_block to get_next_block (#29943)

Browse Source
This commit is contained in:
nanfeng
2024-01-15 11:38:08 +08:00
committed by yiguolei
parent f6dc6ea13b
commit be893d792c
7 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/vec/exec/format/avro/avro_jni_reader.cpp
View File

@ -43,7 +43,7 @@ AvroJNIReader::AvroJNIReader(RuntimeProfile* profile, const TFileScanRangeParams
AvroJNIReader::~AvroJNIReader() = default;
Status AvroJNIReader::get_next_block(Block* block, size_t* read_rows, bool* eof) {
RETURN_IF_ERROR(_jni_connector->get_nex_block(block, read_rows, eof));
RETURN_IF_ERROR(_jni_connector->get_next_block(block, read_rows, eof));
if (*eof) {
RETURN_IF_ERROR(_jni_connector->close());
}

2
be/src/vec/exec/format/jni_reader.cpp
View File

@ -63,7 +63,7 @@ MockJniReader::MockJniReader(const std::vector<SlotDescriptor*>& file_slot_descs
}
Status MockJniReader::get_next_block(Block* block, size_t* read_rows, bool* eof) {
RETURN_IF_ERROR(_jni_connector->get_nex_block(block, read_rows, eof));
RETURN_IF_ERROR(_jni_connector->get_next_block(block, read_rows, eof));
if (*eof) {
RETURN_IF_ERROR(_jni_connector->close());
}

2
be/src/vec/exec/format/table/hudi_jni_reader.cpp
View File

@ -80,7 +80,7 @@ HudiJniReader::HudiJniReader(const TFileScanRangeParams& scan_params,
}
Status HudiJniReader::get_next_block(Block* block, size_t* read_rows, bool* eof) {
RETURN_IF_ERROR(_jni_connector->get_nex_block(block, read_rows, eof));
RETURN_IF_ERROR(_jni_connector->get_next_block(block, read_rows, eof));
if (*eof) {
RETURN_IF_ERROR(_jni_connector->close());
}

2
be/src/vec/exec/format/table/max_compute_jni_reader.cpp
View File

@ -81,7 +81,7 @@ MaxComputeJniReader::MaxComputeJniReader(const MaxComputeTableDescriptor* mc_des
}
Status MaxComputeJniReader::get_next_block(Block* block, size_t* read_rows, bool* eof) {
RETURN_IF_ERROR(_jni_connector->get_nex_block(block, read_rows, eof));
RETURN_IF_ERROR(_jni_connector->get_next_block(block, read_rows, eof));
if (*eof) {
RETURN_IF_ERROR(_jni_connector->close());
}

2
be/src/vec/exec/format/table/paimon_reader.cpp
View File

@ -70,7 +70,7 @@ PaimonJniReader::PaimonJniReader(const std::vector<SlotDescriptor*>& file_slot_d
}
Status PaimonJniReader::get_next_block(Block* block, size_t* read_rows, bool* eof) {
RETURN_IF_ERROR(_jni_connector->get_nex_block(block, read_rows, eof));
RETURN_IF_ERROR(_jni_connector->get_next_block(block, read_rows, eof));
if (*eof) {
RETURN_IF_ERROR(_jni_connector->close());
}

2
be/src/vec/exec/jni_connector.cpp
View File

@ -112,7 +112,7 @@ Status JniConnector::init(
return Status::OK();
}
Status JniConnector::get_nex_block(Block* block, size_t* read_rows, bool* eof) {
Status JniConnector::get_next_block(Block* block, size_t* read_rows, bool* eof) {
// Call org.apache.doris.common.jni.JniScanner#getNextBatchMeta
// return the address of meta information
JNIEnv* env = nullptr;

2
be/src/vec/exec/jni_connector.h
View File

@ -234,7 +234,7 @@ public:
* | data column start address of the variable length column-B |
* | ... |
*/
Status get_nex_block(Block* block, size_t* read_rows, bool* eof);
Status get_next_block(Block* block, size_t* read_rows, bool* eof);
/**
* Get performance metrics from java scanner