ExArrow.Sink.DataFrame (ex_arrow v0.7.1)

Convert an Arrow stream or batch into an Explorer DataFrame.

Delegates to ExArrow.DataFrame.from_arrow/1, which accepts either an ExArrow.RecordBatch.t() or an ExArrow.Stream.t(). Requires the optional {:explorer, "~> 0.11"} dependency.

Example

{:ok, df} = ExArrow.Sink.DataFrame.write(stream)

Summary

Functions

write(source)

Convert source to an Explorer.DataFrame.

Functions

write(source)

@spec write(ExArrow.RecordBatch.t() | ExArrow.Stream.t()) ::
  {:ok, Explorer.DataFrame.t()} | {:error, String.t()}

Convert source to an Explorer.DataFrame.

Returns {:ok, dataframe} or {:error, message}.