MCPcopy Create free account
hub / github.com/apache/impala / GetQualifier

Method GetQualifier

be/src/exec/hbase/hbase-table-scanner.cc:634–653  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

632}
633
634inline Status HBaseTableScanner::GetQualifier(JNIEnv* env, jobject cell,
635 void** data, int* length) {
636 int offset = env->CallIntMethod(cell, cell_get_qualifier_offset_id_);
637 RETURN_ERROR_IF_EXC(env);
638 *length = env->CallIntMethod(cell, cell_get_qualifier_length_id_);
639 RETURN_ERROR_IF_EXC(env);
640 jbyteArray jdata =
641 (jbyteArray) env->CallObjectMethod(cell, cell_get_qualifier_array_);
642 RETURN_ERROR_IF_EXC(env);
643 *data = value_pool_->TryAllocate(*length);
644 if (UNLIKELY(*data == NULL)) {
645 string details = Substitute(HBASE_MEM_LIMIT_EXCEEDED, "GetQualifier",
646 *length, "qualifier array");
647 return value_pool_->mem_tracker()->MemLimitExceeded(state_, details, *length);
648 }
649 env->GetByteArrayRegion(jdata, offset, *length, reinterpret_cast<jbyte*>(*data));
650 RETURN_ERROR_IF_EXC(env);
651 COUNTER_ADD(scan_node_->bytes_read_counter(), *length);
652 return Status::OK();
653}
654
655inline Status HBaseTableScanner::GetValue(JNIEnv* env, jobject cell,
656 void** data, int* length) {

Callers

nothing calls this directly

Calls 6

SubstituteFunction · 0.85
OKFunction · 0.85
bytes_read_counterMethod · 0.80
TryAllocateMethod · 0.45
MemLimitExceededMethod · 0.45
mem_trackerMethod · 0.45

Tested by

no test coverage detected