Function NativeScan

src/sdk/java/native-src/jni_tera_table.cc:176–193

}

JNIEXPORT jlong NativeScan(JNIEnv* env, jobject jobj, jlong jtable, jlong jdesc) {
  tera::Table* table = reinterpret_cast<tera::Table*>(jtable);
  tera::ScanDescriptor* desc = reinterpret_cast<tera::ScanDescriptor*>(jdesc);
  tera::ErrorCode error_code;

  if (table == NULL || desc == NULL) {
    SendErrorJ(env, jobj, "table or scan descriptor not initialized.");
    return 0;
  }

  tera::ResultStream* result_stream;
  if ((result_stream = table->Scan(*desc, &error_code)) == NULL) {
    LOG(ERROR) << "fail to scan records from table: " << table->GetName();
    return 0;
  }

  return reinterpret_cast<jlong>(result_stream);
}