recipe

func ExecuteSpark ¶ added in v0.4.0

func ExecuteSpark(t *testing.T, scriptPath string, args ...string) (string, error)

func SparkMajorVersion ¶ added in v0.7.0

func SparkMajorVersion() (int, error)

SparkMajorVersion returns the major pyspark version (3 or 4) of the spark-iceberg container. Extraction runs once per process on success; failures are not cached so transient docker-exec errors do not poison the result for the rest of the run.

func Start ¶

func Start(t *testing.T) (*compose.DockerCompose, error)