Sha256: 8b910548d6cbc16d4ef9d0a252c05a75239d74040342bc81b6233109e6d8234f
Contents?: true
Size: 777 Bytes
Versions: 52
Compression:
Stored size: 777 Bytes
Contents
module Polars
module IO
# Read into a DataFrame from Apache Avro format.
#
# @param source [Object]
# Path to a file or a file-like object.
# @param columns [Object]
# Columns to select. Accepts a list of column indices (starting at zero) or a list
# of column names.
# @param n_rows [Integer]
# Stop reading from Apache Avro file after reading ``n_rows``.
#
# @return [DataFrame]
def read_avro(source, columns: nil, n_rows: nil)
if Utils.pathlike?(source)
source = Utils.normalize_filepath(source)
end
projection, column_names = Utils.handle_projection_columns(columns)
rbdf = RbDataFrame.read_avro(source, column_names, projection, n_rows)
Utils.wrap_df(rbdf)
end
end
end
Version data entries
52 entries across 52 versions & 1 rubygems