Function main

example/encode_simple.cc:46–80

}

int main(int argc, char** argv) {
  plato::stop_watch_t watch;
  auto& cluster_info = plato::cluster_info_t::get_instance();
  init(argc, argv);
  cluster_info.initialize(&argc, &argv);

  plato::graph_info_t graph_info(FLAGS_is_directed);
  plato::vid_encoder_opts_t opts;
  opts.src_need_encode_ = FLAGS_src_need_encode;
  opts.dst_need_encode_ = FLAGS_dst_need_encode;
  using EDATA = plato::empty_t;
  using VID_T = uint64_t;

  auto decoder = plato::dummy_decoder<plato::empty_t>;
  //auto decoder = plato::uint8_t_decoder;
  plato::vid_encoder_t<EDATA, VID_T, plato::edge_cache_t> data_encoder(opts);
  //auto graph = plato::create_bcsr_seqs_from_path<EDATA, VID_T>(&graph_info, 
  //  FLAGS_input, plato::edge_format_t::CSV, decoder,
  //  FLAGS_alpha, FLAGS_part_by_in, &data_encoder);

  auto tcsr = plato::create_tcsr_hashs_from_path<EDATA, plato::vid_t, std::hash<plato::vid_t>,
       VID_T, plato::edge_cache_t>(&graph_info, FLAGS_input, plato::edge_format_t::CSV,
       decoder, &data_encoder);

  auto data = data_encoder.data();

  LOG(INFO) << "data size: " << data.size();

  size_t stride = data.size() / 100;
  if (stride == 0) stride = 1;
  for (size_t i = 0; i < data.size(); i += stride) {
    LOG(INFO) << "pid: " << cluster_info.partition_id_ << " i: " << i << " val: " << data[i];
  }
  return 0;
}