Parquex.Dataset.Writer (parquex v0.3.0)

A foreground, owner-bound writer for bounded time-partitioned Parquet parts.

Summary

t()

cancel(writer)

Returns a specification to start this module under a supervisor.

close(writer)

@opaque t()

@spec cancel(t()) :: :ok | {:error, Parquex.Error.t()}

Returns a specification to start this module under a supervisor.

@spec close(t()) ::
  {:ok, Parquex.Dataset.WriteReport.t()} | {:error, Parquex.Error.t()}

@spec open(
  Parquex.Dataset.t(),
  keyword()
) :: {:ok, t()} | {:error, Parquex.Error.t()}

@spec write(t(), Parquex.Batch.t() | map() | [map()]) ::
  :ok | {:error, Parquex.Error.t()}