Function TEST_F

src/codec/codec_bench_test.cc:62–105

}

TEST_F(CodecBenchmarkTest, ProjectTest) {
    Schema schema;
    for (uint32_t i = 0; i < 100; i++) {
        common::ColumnDesc* col = schema.Add();
        col->set_name("col" + std::to_string(i));
        col->set_data_type(type::kBigInt);
    }
    common::ColumnDesc* col_last = schema.Add();
    col_last->set_name("col_last");
    col_last->set_data_type(type::kVarchar);
    std::string hello = "hello";
    RowBuilder rb(schema);
    uint32_t total_size = rb.CalTotalLength(hello.size());
    void* ptr = ::malloc(total_size);
    rb.SetBuffer(reinterpret_cast<int8_t*>(ptr), total_size);
    for (uint32_t i = 0; i < 100; i++) {
        int64_t val = 100;
        rb.AppendInt64(val);
    }
    rb.AppendString(hello.c_str(), hello.size());
    ProjectList plist;
    uint32_t* idx = plist.Add();
    *idx = 100;
    uint32_t* idx2 = plist.Add();
    *idx2 = 99;

    uint64_t consumed = ::baidu::common::timer::get_micros();
    std::map<int32_t, std::shared_ptr<Schema>> vers_schema;
    vers_schema.insert(std::make_pair(1, std::make_shared<Schema>(schema)));
    for (int64_t i = 1; i < 100; i++) {
        RowProject rp(vers_schema, plist);
        rp.Init();
        for (int32_t j = 0; j < 1000; j++) {
            int8_t* data = NULL;
            uint32_t size = 0;
            rp.Project(reinterpret_cast<int8_t*>(ptr), total_size, &data,
                       &size);
            free(reinterpret_cast<void*>(data));
        }
    }
    consumed = ::baidu::common::timer::get_micros() - consumed;
    std::cout << "project 1000 records avg consumed:" << consumed / 100 << "μs"
              << std::endl;
}

TEST_F(CodecBenchmarkTest, Encode_ts_vs_none_ts) {
    char* bd = new char[128];