code: def test_read_parquet_arrow_nativefile(s3_base, s3so, pdf, columns):
      # Write to buffer
      fname = "test_parquet_reader_arrow_nativefile.parquet"
      bucket = "parquet"
      buffer = BytesIO()
      pdf.to_parquet(path=buffer)
      buffer.seek(0)
      with s3_context(
          s3_base=s3_base, bucket=bucket, files={fname: buffer}
      ):
          fs = pa_fs.S3FileSystem(
              endpoint_override=s3so["client_kwargs"]["endpoint_url"],
          )
          with fs.open_input_file(f"{bucket}/{fname}") as fil:
              got = cudf.read_parquet(fil, columns=columns)
  
      expect = pdf[columns] if columns else pdf
      assert_eq(expect, got)
  
imports: import os
  import socket
  from contextlib import contextmanager
  from io import BytesIO
  import numpy
  import pandas
  import pyarrow.fs
  import pytest
  from fsspec.core import get_fs_token_paths
  import cudf
  from cudf.testing._utils import assert_eq
label_desc: Use image node_id 16 for calling a global function with example usage: test_read_parquet_arrow_nativefile(s3_base, s3so, pdf, columns) without return types