rjzamora

import argparse
import random
from functools import partial
from time import perf_counter as clock

import fsspec
import numpy as np
import pandas as pd

import dask

rjzamora

rjzamora

# # KvikIO S3 Env Variables
# os.environ["CUDF_NATIVE_S3_IO"] = "True"
# if os.environ.get("CUDF_NATIVE_S3_IO", "False") == "True":
#     os.environ["KVIKIO_NTHREADS"] = f"{os.cpu_count()}"

import os
import math
import argparse
import random
import time

rjzamora

rjzamora

rjzamora

rjzamora

rjzamora

rjzamora

rjzamora