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

Method GetFamily

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

Source from the content-addressed store, hash-verified

611}
612
613inline Status HBaseTableScanner::GetFamily(JNIEnv* env, jobject cell,
614 void** data, int* length) {
615 int offset = env->CallIntMethod(cell, cell_get_family_offset_id_);
616 RETURN_ERROR_IF_EXC(env);
617 *length = env->CallShortMethod(cell, cell_get_family_length_id_);
618 RETURN_ERROR_IF_EXC(env);
619 jbyteArray jdata =
620 (jbyteArray) env->CallObjectMethod(cell, cell_get_family_array_);
621 RETURN_ERROR_IF_EXC(env);
622 *data = value_pool_->TryAllocate(*length);
623 if (UNLIKELY(*data == NULL)) {
624 string details = Substitute(HBASE_MEM_LIMIT_EXCEEDED, "GetFamily",
625 *length, "family array");
626 return value_pool_->mem_tracker()->MemLimitExceeded(state_, details, *length);
627 }
628 env->GetByteArrayRegion(jdata, offset, *length, reinterpret_cast<jbyte*>(*data));
629 RETURN_ERROR_IF_EXC(env);
630 COUNTER_ADD(scan_node_->bytes_read_counter(), *length);
631 return Status::OK();
632}
633
634inline Status HBaseTableScanner::GetQualifier(JNIEnv* env, jobject cell,
635 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