Function main

c_glib/example/read-stream.c:86–142

}

int
main(int argc, char **argv)
{
  const char *input_path = "/tmp/stream.arrow";
  GArrowMemoryMappedInputStream *input;
  GError *error = NULL;

  if (argc > 1)
    input_path = argv[1];
  input = garrow_memory_mapped_input_stream_new(input_path, &error);
  if (!input) {
    g_print("failed to open file: %s\n", error->message);
    g_error_free(error);
    return EXIT_FAILURE;
  }

  {
    GArrowRecordBatchReader *reader;
    GArrowRecordBatchStreamReader *stream_reader;

    stream_reader =
      garrow_record_batch_stream_reader_new(GARROW_INPUT_STREAM(input), &error);
    if (!stream_reader) {
      g_print("failed to open stream reader: %s\n", error->message);
      g_error_free(error);
      g_object_unref(input);
      return EXIT_FAILURE;
    }

    reader = GARROW_RECORD_BATCH_READER(stream_reader);
    while (TRUE) {
      GArrowRecordBatch *record_batch;

      record_batch = garrow_record_batch_reader_read_next(reader, &error);
      if (error) {
        g_print("failed to read the next record batch: %s\n", error->message);
        g_error_free(error);
        g_object_unref(reader);
        g_object_unref(input);
        return EXIT_FAILURE;
      }

      if (!record_batch) {
        break;
      }

      print_record_batch(record_batch);
      g_object_unref(record_batch);
    }

    g_object_unref(reader);
  }

  g_object_unref(input);

  return EXIT_SUCCESS;
}