Index

_

__call__() (parquetranger.HashPartitioner method)

A

add_to_batch() (parquetranger.RecordWriter method)

B

batch_extend() (parquetranger.TableRepo method)

C

close() (parquetranger.RecordWriter method)

col (parquetranger.HashPartitioner attribute)

D

DfBatchWriter (class in parquetranger) dfs (parquetranger.TableRepo attribute)

dump_all() (parquetranger.ObjIngestor method) dump_largest() (parquetranger.ObjIngestor method)

E

env_ctx() (parquetranger.TableRepo method)

extend() (parquetranger.TableRepo method)

F

force_key (parquetranger.ObjIngestor attribute)

forward_uuids (parquetranger.ObjIngestor attribute) full_metadata (parquetranger.TableRepo attribute)

G

get_extending_df_batch_writer() (parquetranger.TableRepo method) get_extending_dict_batch_writer() (parquetranger.TableRepo method) get_extending_fixed_dict_batch_writer() (parquetranger.TableRepo method) get_full_df() (parquetranger.TableRepo method) get_full_table() (parquetranger.TableRepo method)

get_partition_df() (parquetranger.TableRepo method) get_partition_paths() (parquetranger.TableRepo method) get_partition_table() (parquetranger.TableRepo method) get_replacing_df_batch_writer() (parquetranger.TableRepo method) get_replacing_dict_batch_writer() (parquetranger.TableRepo method) group_cols (parquetranger.TableRepo attribute)

H

h() (parquetranger.HashPartitioner method)

HashPartitioner (class in parquetranger)

I

ingest() (parquetranger.ObjIngestor method)

K

key (parquetranger.HashPartitioner attribute)

L

largest_size (parquetranger.ObjIngestor attribute)

M

main_path (parquetranger.TableRepo attribute) map_partitions() (parquetranger.TableRepo method)

mkdirs() (parquetranger.TableRepo method) module parquetranger

N

n_files (parquetranger.TableRepo attribute)

num_groups (parquetranger.HashPartitioner attribute)

O

ObjIngestor (class in parquetranger)

P

parquetranger module

paths (parquetranger.TableRepo attribute) purge() (parquetranger.TableRepo method)

R

read_df_from_path() (parquetranger.TableRepo method) read_table_from_path() (parquetranger.TableRepo method) record_count (parquetranger.RecordWriter attribute) record_limit (parquetranger.RecordWriter attribute)

RecordWriter (class in parquetranger) replace_all() (parquetranger.TableRepo method) replace_groups() (parquetranger.TableRepo method) replace_records() (parquetranger.TableRepo method) root_id_key (parquetranger.ObjIngestor attribute)

S

set_env() (parquetranger.TableRepo method)

set_env_to_default() (parquetranger.TableRepo method) size_limit (parquetranger.ObjIngestor attribute)

T

TableRepo (class in parquetranger)

tables (parquetranger.TableRepo attribute) total_atoms (parquetranger.ObjIngestor attribute)

V

vc_path (parquetranger.TableRepo attribute)

W

writer_function() (parquetranger.RecordWriter method)

written_count (parquetranger.RecordWriter attribute)