- class lance.LanceFragment(pyarrow._dataset.Fragment)
公共成员¶
- LanceFragment(dataset: LanceDataset, fragment_id: int | None, ...)
初始化自身。如需准确的签名信息,请参阅 help(type(self))。
- __repr__()
返回 repr(self)。
- __reduce__()
Fragment.__reduce_cython__(self)
- static create_from_file(文件名: str, ...) FragmentMetadata
从给定的数据文件URI创建片段。
- static create(dataset_uri: str | Path, ...) FragmentMetadata
从给定数据创建
FragmentMetadata。
- property fragment_id
- count_rows(表达式 filter=None, ...)
统计符合扫描器筛选条件的行数。
- property num_deletions : int
返回此片段中已删除的行数。
- property physical_rows : int
返回此片段中原始的行数。
- property physical_schema : 模式/架构
返回此片段的物理模式。该模式可能与数据集读取模式不同。
- property partition_expression : 模式/架构
一个表达式,对于该片段查看的所有数据评估为真。
- head(int num_rows, columns=None, 表达式 filter=None, ...)
加载片段的前N行。
- scanner(*, ...) LanceScanner
详情请参阅 Dataset::scanner
- 获取(索引, columns=None, 表达式 filter=None, ...)
按索引选择数据行。
- to_batches(Schema schema=None, columns=None, ...)
将片段读取为物化的记录批次。
- to_table(Schema schema=None, columns=None, ...)
将此片段转换为表格。
- merge(data_obj, ...) tuple[FragmentMetadata, LanceSchema]
将另一个数据集合并到此片段中。
- merge_columns(...) tuple[FragmentMetadata, LanceSchema]
向此片段添加列。
- delete(predicate: str) FragmentMetadata | None
从此片段中删除行。
- data_files()
返回此片段的数据文件。
- deletion_file()
返回删除文件(如果有的话)
- property metadata : FragmentMetadata
返回此片段的元数据。
- classmethod LanceFragment(*args, **kwargs)
创建并返回一个新对象。有关准确的签名,请参阅help(type)。