Datasets documentation
Kelas Tabel
Kelas Tabel
Setiap objek Dataset didukung oleh PyArrow Table.
Sebuah Table dapat dimuat dari disk (memory mapped) atau di memori.
Beberapa tipe Table tersedia, dan semuanya mewarisi dari table.Table.
Tabel
Membungkus tabel pyarrow dengan menggunakan komposisi.
Ini adalah kelas dasar untuk InMemoryTable, MemoryMappedTable dan ConcatenationTable.
Itu mengimplementasikan semua atribut/metode dasar dari kelas Table pyarrow kecuali transformasi Table: slice, filter, flatten, combine_chunks, cast, add_column, append_column, remove_column, set_column, rename_columns dan drop.
Implementasi dari metode-metode ini berbeda untuk setiap subkelas.
validate
< source >( *args**kwargs )
Lakukan pemeriksaan validasi. Pengecualian akan dilemparkan jika validasi gagal.
Secara default, hanya pemeriksaan validasi yang murah yang dijalankan. Luluskan full=True untuk pemeriksaan validasi yang menyeluruh (potensi O(n)).
sama dengan
< source >( *args**kwargs ) β bool
Parameter
- other (Tabel) β Tabel untuk dibandingkan.
- check_metadata
bool, defaultnyaFalse) β Apakah kesetaraan metadata skema juga harus diperiksa.
Mengembalikan
bool
Periksa apakah isi dua tabel sama.
to_batches
< source >( *args**kwargs )
Konversi Tabel menjadi daftar objek RecordBatch (kontigu).
Konversi Table menjadi dict atau OrderedDict.
to_pandas
< source >( *args**kwargs ) β pandas.Series or pandas.DataFrame
Parameter
- memory_pool (
MemoryPool, defaultnyaNone) β Arrow MemoryPool yang digunakan untuk alokasi. Menggunakan memory pool default jika tidak ada yang diteruskan. - strings_to_categorical (
bool, defaultFalse) β Enkode tipe string (UTF8) dan biner menjadipandas.Categorical. - categories (
list, defaultnyaempty) β Daftar field yang harus dikembalikan sebagaipandas.Categorical. Hanya berlaku untuk struktur data berbentuk tabel. - zero_copy_only (
bool, defaultnyaFalse) β MembuangArrowExceptionjika pemanggilan fungsi ini akan memerlukan penyalinan data yang mendasarinya. - integer_object_nulls (
bool, defaultnyaFalse) β Cast integer dengan null menjadi objek. - date_as_object (
bool, defaultnyaTrue) β Mengubah tanggal menjadi objek. JikaFalse, konversi ke dtypedatetime64[ns]. - timestamp_as_object (
bool, defaultnyaFalse) β Mengubah timestamp non-nanosecond (np.datetime64) menjadi objek. Hal ini berguna jika Anda memiliki timestamp yang tidak muat dalam rentang tanggal normal untuk timestamp nanosecond (1678 M-2262 M). JikaFalse, semua timestamp dikonversi ke dtypedatetime64[ns]. - use_threads (
bool, defaultnyaTrue) β Apakah akan memparalelkan konversi menggunakan beberapa thread. - deduplicate_objects (
bool, defaultnyaFalse) β Jangan buat beberapa salinan objek Python saat dibuat, untuk menghemat penggunaan memori. Konversi akan lebih lambat. - ignore_metadata (
bool, defaultnyaFalse) β JikaTrue, jangan gunakan metadata βpandasβ untuk merekonstruksi indeks DataFrame, jika ada. - safe (
bool, defaultnyaTrue) β Untuk beberapa tipe data, cast diperlukan agar data dapat disimpan dalam pandas DataFrame atau Series (misalnya, timestamp selalu disimpan sebagai nanosekon di pandas). Opsi ini mengontrol apakah cast tersebut aman atau tidak. - split_blocks (
bool, defaultnyaFalse) β JikaTrue, buat satu βblockβ internal untuk setiap kolom saat membuat pandas.DataFrame dariRecordBatchatauTable. Meskipun ini dapat mengurangi memori secara sementara, perhatikan bahwa berbagai operasi pandas dapat memicu βkonsolidasiβ yang dapat membengkakkan penggunaan memori. - self_destruct (
bool, defaultnyaFalse) β EKSPERIMEN: JikaTrue, coba lepaskan memori Arrow asal saat mengonversi objek Arrow ke pandas. Jika Anda menggunakan objek tersebut setelah memanggilto_pandasdengan opsi ini, program Anda akan crash. - types_mapper (
function, defaultnyaNone) β Fungsi yang memetakan pyarrow DataType keExtensionDtypepandas. Ini dapat digunakan untuk menimpa tipe pandas default untuk konversi tipe bawaan pyarrow atau jika tidak adapandas_metadatadalam skema Table. Fungsi ini menerima pyarrow DataType dan diharapkan mengembalikanExtensionDtypepandas atauNonejika konversi default harus digunakan untuk tipe tersebut. Jika Anda memiliki pemetaan kamus, Anda dapat meneruskandict.getsebagai fungsi.
Mengembalikan
pandas.Series atau pandas.DataFrame
pandas.Series atau pandas.DataFrame tergantung pada tipe objek
Konversi menjadi array NumPy atau DataFrame yang kompatibel dengan pandas, sesuai kebutuhan.
field
< source >( *args**kwargs )
Pilih bidang skema berdasarkan nama kolom atau indeks numeriknya.
kolom
< source >( *args**kwargs )
Pilih kolom berdasarkan nama kolom atau indeks numeriknya.
Iterator untuk semua kolom dalam urutan numerik.
Skema tabel dan kolom-kolomnya.
Daftar semua kolom dalam urutan numerik.
Jumlah kolom dalam tabel ini.
Jumlah baris dalam tabel ini.
Karena definisi tabel, semua kolom memiliki jumlah baris yang sama.
Dimensi tabel: (#baris, #kolom).
Total jumlah byte yang dikonsumsi oleh elemen-elemen tabel.
InMemoryTable
Tabel dikatakan in-memory ketika dimuat ke RAM pengguna.
Pickling memang menyalin semua data menggunakan memori. Implementasinya sederhana dan menggunakan metode Table pyarrow yang mendasarinya secara langsung.
Ini berbeda dari tabel MemoryMapped, di mana pickling tidak menyalin semua data di memori. Untuk MemoryMapped, unpickling justru memuat ulang tabel dari disk.
InMemoryTable harus digunakan ketika data muat di memori, sedangkan MemoryMapped dikhususkan untuk data yang lebih besar dari memori atau ketika Anda ingin jejak memori aplikasi Anda tetap rendah.
validate
< source >( *args**kwargs )
Lakukan pemeriksaan validasi. Pengecualian akan dilemparkan jika validasi gagal.
Secara default, hanya pemeriksaan validasi yang murah yang dijalankan. Luluskan full=True untuk pemeriksaan validasi yang menyeluruh (potensi O(n)).
sama dengan
< source >( *args**kwargs ) β bool
Parameter
- other (Tabel) β Tabel untuk dibandingkan.
- check_metadata
bool, defaultnyaFalse) β Apakah kesetaraan metadata skema juga harus diperiksa.
Mengembalikan
bool
Periksa apakah isi dua tabel sama.
to_batches
< source >( *args**kwargs )
Konversi Tabel menjadi daftar objek RecordBatch (kontigu).
Konversi Table menjadi dict atau OrderedDict.
to_pandas
< source >( *args**kwargs ) β pandas.Series or pandas.DataFrame
Parameter
- memory_pool (
MemoryPool, defaultnyaNone) β Arrow MemoryPool yang digunakan untuk alokasi. Menggunakan memory pool default jika tidak ada yang diteruskan. - strings_to_categorical (
bool, defaultFalse) β Enkode tipe string (UTF8) dan biner menjadipandas.Categorical. - categories (
list, defaultnyaempty) β Daftar field yang harus dikembalikan sebagaipandas.Categorical. Hanya berlaku untuk struktur data berbentuk tabel. - zero_copy_only (
bool, defaultnyaFalse) β MembuangArrowExceptionjika pemanggilan fungsi ini akan memerlukan penyalinan data yang mendasarinya. - integer_object_nulls (
bool, defaultnyaFalse) β Cast integer dengan null menjadi objek. - date_as_object (
bool, defaultnyaTrue) β Mengubah tanggal menjadi objek. JikaFalse, konversi ke dtypedatetime64[ns]. - timestamp_as_object (
bool, defaultnyaFalse) β Mengubah timestamp non-nanosecond (np.datetime64) menjadi objek. Hal ini berguna jika Anda memiliki timestamp yang tidak muat dalam rentang tanggal normal untuk timestamp nanosecond (1678 M-2262 M). JikaFalse, semua timestamp dikonversi ke dtypedatetime64[ns]. - use_threads (
bool, defaultnyaTrue) β Apakah akan memparalelkan konversi menggunakan beberapa thread. - deduplicate_objects (
bool, defaultnyaFalse) β Jangan buat beberapa salinan objek Python saat dibuat, untuk menghemat penggunaan memori. Konversi akan lebih lambat. - ignore_metadata (
bool, defaultnyaFalse) β JikaTrue, jangan gunakan metadata βpandasβ untuk merekonstruksi indeks DataFrame, jika ada. - safe (
bool, defaultnyaTrue) β Untuk beberapa tipe data, cast diperlukan agar data dapat disimpan dalam pandas DataFrame atau Series (misalnya, timestamp selalu disimpan sebagai nanosekon di pandas). Opsi ini mengontrol apakah cast tersebut aman atau tidak. - split_blocks (
bool, defaultnyaFalse) β JikaTrue, buat satu βblockβ internal untuk setiap kolom saat membuat pandas.DataFrame dariRecordBatchatauTable. Meskipun ini dapat mengurangi memori secara sementara, perhatikan bahwa berbagai operasi pandas dapat memicu βkonsolidasiβ yang dapat membengkakkan penggunaan memori. - self_destruct (
bool, defaultnyaFalse) β EKSPERIMEN: JikaTrue, coba lepaskan memori Arrow asal saat mengonversi objek Arrow ke pandas. Jika Anda menggunakan objek tersebut setelah memanggilto_pandasdengan opsi ini, program Anda akan crash. - types_mapper (
function, defaultnyaNone) β Fungsi yang memetakan pyarrow DataType keExtensionDtypepandas. Ini dapat digunakan untuk menimpa tipe pandas default untuk konversi tipe bawaan pyarrow atau jika tidak adapandas_metadatadalam skema Table. Fungsi ini menerima pyarrow DataType dan diharapkan mengembalikanExtensionDtypepandas atauNonejika konversi default harus digunakan untuk tipe tersebut. Jika Anda memiliki pemetaan kamus, Anda dapat meneruskandict.getsebagai fungsi.
Mengembalikan
pandas.Series atau pandas.DataFrame
pandas.Series atau pandas.DataFrame tergantung pada tipe objek
Konversi menjadi array NumPy atau DataFrame yang kompatibel dengan pandas, sesuai kebutuhan.
field
< source >( *args**kwargs )
Pilih bidang skema berdasarkan nama kolom atau indeks numeriknya.
kolom
< source >( *args**kwargs )
Pilih kolom berdasarkan nama kolom atau indeks numeriknya.
Iterator untuk semua kolom dalam urutan numerik.
Skema tabel dan kolom-kolomnya.
Daftar semua kolom dalam urutan numerik.
Jumlah kolom dalam tabel ini.
Jumlah baris dalam tabel ini.
Karena definisi tabel, semua kolom memiliki jumlah baris yang sama.
Dimensi tabel: (#baris, #kolom).
Total jumlah byte yang dikonsumsi oleh elemen-elemen tabel.
Nama kolom tabel.
slice
< source >( offset = 0length = None )
Hitung irisan zero-copy dari Table ini.
Pilih rekaman dari sebuah Table. Lihat pyarrow.compute.filter untuk penggunaan lengkap.
flatten
< source >( *args**kwargs )
Ratakan tabel ini. Setiap kolom dengan tipe struct diratakan menjadi satu kolom per field struct. Kolom lainnya tidak diubah.
combine_chunks
< source >( *args**kwargs )
Buat tabel baru dengan menggabungkan chunk yang dimiliki tabel ini.
Semua chunk yang mendasari dalam ChunkedArray dari setiap kolom digabungkan menjadi nol atau satu chunk.
cast
< source >( *args**kwargs )
Cast nilai tabel ke skema lain.
replace_schema_metadata
< source >( *args**kwargs ) β datasets.table.Table
EKSPERIMEN: Buat salinan dangkal tabel dengan mengganti metadata skema key-value dengan metadata baru yang ditunjukkan (yang dapat berupa None, yang menghapus metadata yang ada).
add_column
< source >( *args**kwargs ) β datasets.table.Table
Parameter
- i (
int) β Indeks untuk menempatkan kolom. - field_ (
Union[str, pyarrow.Field]) β Jika string yang diberikan, tipe akan disimpulkan dari data kolom. - column (
Union[pyarrow.Array, List[pyarrow.Array]]) β Data kolom.
Mengembalikan
datasets.table.Table
Tabel baru dengan kolom yang ditambahkan.
Tambahkan kolom ke Tabel pada posisi.
Tabel baru dikembalikan dengan kolom yang ditambahkan, objek tabel asli tetap tidak berubah.
append_column
< source >( *args**kwargs ) β datasets.table.Table
Tambahkan kolom di akhir daftar kolom.
remove_column
< source >( *args**kwargs ) β datasets.table.Table
Buat tabel baru dengan kolom yang ditunjukkan dihapus.
set_column
< source >( *args**kwargs ) β datasets.table.Table
Parameter
- i (
int) β Indeks untuk menempatkan kolom. - field_ (
Union[str, pyarrow.Field]) β Jika string yang diberikan, tipe akan disimpulkan dari data kolom. - column (
Union[pyarrow.Array, List[pyarrow.Array]]) β Data kolom.
Mengembalikan
datasets.table.Table
Tabel baru dengan set kolom yang diteruskan.
Ganti kolom di Tabel pada posisi.
Buat tabel baru dengan kolom yang namanya diganti menjadi nama yang diberikan.
pilih
< source >( *args**kwargs ) β datasets.table.Table
Parameter
Mengembalikan
Tabel baru dengan kolom yang ditentukan, dan metadata dipertahankan.
Pilih kolom dari tabel.
Mengembalikan tabel baru dengan kolom yang ditentukan, dan metadata dipertahankan.
drop
< source >( *args**kwargs ) β datasets.table.Table
Hapus satu atau beberapa kolom dan kembalikan tabel baru.
from_pandas
< source >( *args**kwargs ) β datasets.table.Table
Parameter
- df (
pandas.DataFrame) — - schema (
pyarrow.Schema, opsional) β Skema yang diharapkan dari Tabel Arrow. Hal ini dapat digunakan untuk menunjukkan tipe kolom jika tidak dapat disimpulkan secara otomatis. Jika diberikan, output akan memiliki skema ini secara persis. Kolom yang ditentukan dalam skema tetapi tidak ditemukan dalam kolom DataFrame atau indeksnya akan memicu error. Kolom tambahan atau level indeks dalam DataFrame yang tidak ditentukan dalam skema akan diabaikan. - preserve_index (
bool, opsional) β Apakah indeks akan disimpan sebagai kolom tambahan padaTableyang dihasilkan. Nilai default None akan menyimpan indeks sebagai kolom, kecuali untuk RangeIndex yang hanya disimpan sebagai metadata. Gunakanpreserve_index=Trueuntuk memaksa indeks disimpan sebagai kolom. - nthreads (
int, defaultnyaNone(dapat menggunakan hingga jumlah CPU sistem)) β Jika lebih dari 1, konversi kolom ke Arrow secara paralel menggunakan jumlah thread yang ditunjukkan. - columns (
List[str], opsional) β Daftar kolom yang akan dikonversi. JikaNone, gunakan semua kolom. - safe (
bool, defaultnyaTrue) β Periksa apakah ada overflow atau konversi tidak aman lainnya,
Mengembalikan
datasets.table.Table
Mengonversi pandas.DataFrame menjadi Tabel Arrow.
Tipe kolom dalam Tabel Arrow yang dihasilkan disimpulkan dari dtype dari pandas.Series dalam DataFrame. Untuk Series non-object, dtype NumPy diterjemahkan ke padanan Arrow-nya. Untuk object, kita perlu menebak tipe data dengan melihat objek Python dalam Series ini.
Perhatikan bahwa Series dengan dtype object tidak membawa informasi yang cukup untuk selalu menghasilkan tipe Arrow yang bermakna. Dalam kasus di mana kita tidak dapat menyimpulkan tipe, misalnya karena DataFrame memiliki panjang 0 atau Series hanya berisi objek None/nan, tipe akan diatur ke null. Perilaku ini dapat dihindari dengan membuat skema eksplisit dan meneruskannya ke fungsi ini.
from_arrays
< source >( *args**kwargs )
Parameter
- arrays (
List[Union[pyarrow.Array, pyarrow.ChunkedArray]]) β Array dengan panjang yang sama yang harus membentuk tabel. - names (
List[str], opsional) β Nama untuk kolom tabel. Jika tidak diberikan, skema harus diberikan. - schema (
Schema, defaultnyaNone) β Skema untuk tabel yang dibuat. Jika tidak diberikan, nama harus diberikan. - metadata (
Union[dict, Mapping], defaultnyaNone) β Metadata opsional untuk skema (jika disimpulkan).
Konstruksi sebuah Table dari array Arrow.
from_pydict
< source >( *args**kwargs )
Konstruksi sebuah Table dari array atau kolom Arrow.
from_batches
< source >( *args**kwargs ) β datasets.table.Table
Konstruksi sebuah Table dari urutan atau iterator dari RecordBatches Arrow.
MemoryMappedTable
kelas datasets.table.MemoryMappedTable
< source >( table: Tablepath: strreplays: typing.Optional[list[tuple[str, tuple, dict]]] = None )
Tabel dikatakan memory mapped ketika tidak menggunakan RAM pengguna, melainkan memuat data dari disk.
Pickling tidak menyalin data ke dalam memori. Sebagai gantinya, hanya path ke file arrow yang di-memory map yang di-pickle, beserta daftar transformasi untuk βdiputar ulangβ saat memuat ulang tabel dari disk.
Implementasinya memerlukan penyimpanan riwayat semua transformasi yang diterapkan pada tabel pyarrow yang mendasarinya, sehingga transformasi tersebut dapat βdiputar ulangβ saat memuat ulang tabel dari disk.
Ini berbeda dari tabel InMemoryTable, di mana pickling memang menyalin semua data di memori.
InMemoryTable harus digunakan ketika data muat di memori, sedangkan MemoryMapped dikhususkan untuk data yang lebih besar dari memori atau ketika Anda ingin jejak memori aplikasi Anda tetap rendah.
validate
< source >( *args**kwargs )
Lakukan pemeriksaan validasi. Pengecualian akan dilemparkan jika validasi gagal.
Secara default, hanya pemeriksaan validasi yang murah yang dijalankan. Luluskan full=True untuk pemeriksaan validasi yang menyeluruh (potensi O(n)).
sama dengan
< source >( *args**kwargs ) β bool
Parameter
- other (Tabel) β Tabel untuk dibandingkan.
- check_metadata
bool, defaultnyaFalse) β Apakah kesetaraan metadata skema juga harus diperiksa.
Mengembalikan
bool
Periksa apakah isi dua tabel sama.
to_batches
< source >( *args**kwargs )
Konversi Tabel menjadi daftar objek RecordBatch (kontigu).
Konversi Table menjadi dict atau OrderedDict.
to_pandas
< source >( *args**kwargs ) β pandas.Series or pandas.DataFrame
Parameter
- memory_pool (
MemoryPool, defaultnyaNone) β Arrow MemoryPool yang digunakan untuk alokasi. Menggunakan memory pool default jika tidak ada yang diteruskan. - strings_to_categorical (
bool, defaultFalse) β Enkode tipe string (UTF8) dan biner menjadipandas.Categorical. - categories (
list, defaultnyaempty) β Daftar field yang harus dikembalikan sebagaipandas.Categorical. Hanya berlaku untuk struktur data berbentuk tabel. - zero_copy_only (
bool, defaultnyaFalse) β MembuangArrowExceptionjika pemanggilan fungsi ini akan memerlukan penyalinan data yang mendasarinya. - integer_object_nulls (
bool, defaultnyaFalse) β Cast integer dengan null menjadi objek. - date_as_object (
bool, defaultnyaTrue) β Mengubah tanggal menjadi objek. JikaFalse, konversi ke dtypedatetime64[ns]. - timestamp_as_object (
bool, defaultnyaFalse) β Mengubah timestamp non-nanosecond (np.datetime64) menjadi objek. Hal ini berguna jika Anda memiliki timestamp yang tidak muat dalam rentang tanggal normal untuk timestamp nanosecond (1678 M-2262 M). JikaFalse, semua timestamp dikonversi ke dtypedatetime64[ns]. - use_threads (
bool, defaultnyaTrue) β Apakah akan memparalelkan konversi menggunakan beberapa thread. - deduplicate_objects (
bool, defaultnyaFalse) β Jangan buat beberapa salinan objek Python saat dibuat, untuk menghemat penggunaan memori. Konversi akan lebih lambat. - ignore_metadata (
bool, defaultnyaFalse) β JikaTrue, jangan gunakan metadata βpandasβ untuk merekonstruksi indeks DataFrame, jika ada. - safe (
bool, defaultnyaTrue) β Untuk beberapa tipe data, cast diperlukan agar data dapat disimpan dalam pandas DataFrame atau Series (misalnya, timestamp selalu disimpan sebagai nanosekon di pandas). Opsi ini mengontrol apakah cast tersebut aman atau tidak. - split_blocks (
bool, defaultnyaFalse) β JikaTrue, buat satu βblockβ internal untuk setiap kolom saat membuat pandas.DataFrame dariRecordBatchatauTable. Meskipun ini dapat mengurangi memori secara sementara, perhatikan bahwa berbagai operasi pandas dapat memicu βkonsolidasiβ yang dapat membengkakkan penggunaan memori. - self_destruct (
bool, defaultnyaFalse) β EKSPERIMEN: JikaTrue, coba lepaskan memori Arrow asal saat mengonversi objek Arrow ke pandas. Jika Anda menggunakan objek tersebut setelah memanggilto_pandasdengan opsi ini, program Anda akan crash. - types_mapper (
function, defaultnyaNone) β Fungsi yang memetakan pyarrow DataType keExtensionDtypepandas. Ini dapat digunakan untuk menimpa tipe pandas default untuk konversi tipe bawaan pyarrow atau jika tidak adapandas_metadatadalam skema Table. Fungsi ini menerima pyarrow DataType dan diharapkan mengembalikanExtensionDtypepandas atauNonejika konversi default harus digunakan untuk tipe tersebut. Jika Anda memiliki pemetaan kamus, Anda dapat meneruskandict.getsebagai fungsi.
Mengembalikan
pandas.Series atau pandas.DataFrame
pandas.Series atau pandas.DataFrame tergantung pada tipe objek
Konversi menjadi array NumPy atau DataFrame yang kompatibel dengan pandas, sesuai kebutuhan.
field
< source >( *args**kwargs )
Pilih bidang skema berdasarkan nama kolom atau indeks numeriknya.
kolom
< source >( *args**kwargs )
Pilih kolom berdasarkan nama kolom atau indeks numeriknya.
Iterator untuk semua kolom dalam urutan numerik.
Skema tabel dan kolom-kolomnya.
Daftar semua kolom dalam urutan numerik.
Jumlah kolom dalam tabel ini.
Jumlah baris dalam tabel ini.
Karena definisi tabel, semua kolom memiliki jumlah baris yang sama.
Dimensi tabel: (#baris, #kolom).
Total jumlah byte yang dikonsumsi oleh elemen-elemen tabel.
Nama kolom tabel.
slice
< source >( offset = 0length = None )
Hitung irisan zero-copy dari Table ini.
Pilih rekaman dari sebuah Table. Lihat pyarrow.compute.filter untuk penggunaan lengkap.
flatten
< source >( *args**kwargs )
Ratakan tabel ini. Setiap kolom dengan tipe struct diratakan menjadi satu kolom per field struct. Kolom lainnya tidak diubah.
combine_chunks
< source >( *args**kwargs )
Buat tabel baru dengan menggabungkan chunk yang dimiliki tabel ini.
Semua chunk yang mendasari dalam ChunkedArray dari setiap kolom digabungkan menjadi nol atau satu chunk.
cast
< source >( *args**kwargs )
Cast nilai tabel ke skema lain
replace_schema_metadata
< source >( *args**kwargs ) β datasets.table.Table
EKSPERIMEN: Buat salinan dangkal tabel dengan mengganti metadata skema key-value dengan metadata baru yang ditunjukkan (yang dapat berupa None, yang menghapus metadata yang ada).
add_column
< source >( *args**kwargs ) β datasets.table.Table
Parameter
- i (
int) β Indeks untuk menempatkan kolom. - field_ (
Union[str, pyarrow.Field]) β Jika string yang diberikan, tipe akan disimpulkan dari data kolom. - column (
Union[pyarrow.Array, List[pyarrow.Array]]) β Data kolom.
Mengembalikan
datasets.table.Table
Tabel baru dengan kolom yang ditambahkan.
Tambahkan kolom ke Tabel pada posisi.
Tabel baru dikembalikan dengan kolom yang ditambahkan, objek tabel asli tetap tidak berubah.
append_column
< source >( *args**kwargs ) β datasets.table.Table
Tambahkan kolom di akhir daftar kolom.
remove_column
< source >( *args**kwargs ) β datasets.table.Table
Buat tabel baru dengan kolom yang ditunjukkan dihapus.
set_column
< source >( *args**kwargs ) β datasets.table.Table
Parameter
- i (
int) β Indeks untuk menempatkan kolom. - field_ (
Union[str, pyarrow.Field]) β Jika string yang diberikan, tipe akan disimpulkan dari data kolom. - column (
Union[pyarrow.Array, List[pyarrow.Array]]) β Data kolom.
Mengembalikan
datasets.table.Table
Tabel baru dengan set kolom yang diteruskan.
Ganti kolom di Tabel pada posisi.
Buat tabel baru dengan kolom yang namanya diganti menjadi nama yang diberikan.
pilih
< source >( *args**kwargs ) β datasets.table.Table
Parameter
Mengembalikan
Tabel baru dengan kolom yang ditentukan, dan metadata dipertahankan.
Pilih kolom dari tabel.
Mengembalikan tabel baru dengan kolom yang ditentukan, dan metadata dipertahankan.
drop
< source >( *args**kwargs ) β datasets.table.Table
Hapus satu atau beberapa kolom dan kembalikan tabel baru.
ConcatenationTable
Tabel berasal dari penggabungan beberapa tabel yang disebut blok. Hal ini memungkinkan penggabungan pada sumbu 0 (menambahkan baris) dan sumbu 1 (menambahkan kolom).
Tabel yang mendasarinya disebut βblocksβ dan dapat berupa objek InMemoryTable atau MemoryMappedTable.
Hal ini memungkinkan penggabungan tabel yang berasal dari memori atau yang dipetakan ke memori.
Ketika ConcatenationTable di-pickle, maka setiap block di-pickle:
- objek
InMemoryTabledi-pickle dengan menyalin semua data di memori. - objek MemoryMappedTable di-pickle tanpa menyalin data ke memori. Sebagai gantinya, hanya path ke file arrow yang di-memory map yang di-pickle, beserta daftar transformasi untuk βreplayβ saat memuat ulang tabel dari disk.
Implementasinya memerlukan penyimpanan setiap blok secara terpisah.
Atribut blocks menyimpan daftar dari daftar blok.
Sumbu pertama menggabungkan tabel sepanjang sumbu 0 (menambahkan baris),
sedangkan sumbu kedua menggabungkan tabel sepanjang sumbu 1 (menambahkan kolom).
Jika beberapa kolom hilang saat penggabungan pada sumbu 0, kolom tersebut diisi dengan nilai null.
Hal ini dilakukan menggunakan pyarrow.concat_tables(tables, promote=True).
Anda dapat mengakses tabel gabungan penuh dengan mengakses atribut ConcatenationTable.table,
dan blok-bloknya dengan mengakses atribut ConcatenationTable.blocks.
validate
< source >( *args**kwargs )
Lakukan pemeriksaan validasi. Pengecualian akan dilemparkan jika validasi gagal.
Secara default, hanya pemeriksaan validasi yang murah yang dijalankan. Luluskan full=True untuk pemeriksaan validasi yang menyeluruh (potensi O(n)).
sama dengan
< source >( *args**kwargs ) β bool
Parameter
- other (Tabel) β Tabel untuk dibandingkan.
- check_metadata
bool, defaultnyaFalse) β Apakah kesetaraan metadata skema juga harus diperiksa.
Mengembalikan
bool
Periksa apakah isi dua tabel sama.
to_batches
< source >( *args**kwargs )
Konversi Tabel menjadi daftar objek RecordBatch (kontigu).
Konversi Table menjadi dict atau OrderedDict.
to_pandas
< source >( *args**kwargs ) β pandas.Series or pandas.DataFrame
Parameter
- memory_pool (
MemoryPool, defaultnyaNone) β Arrow MemoryPool yang digunakan untuk alokasi. Menggunakan memory pool default jika tidak ada yang diteruskan. - strings_to_categorical (
bool, defaultFalse) β Enkode tipe string (UTF8) dan biner menjadipandas.Categorical. - categories (
list, defaultnyaempty) β Daftar field yang harus dikembalikan sebagaipandas.Categorical. Hanya berlaku untuk struktur data berbentuk tabel. - zero_copy_only (
bool, defaultnyaFalse) β MembuangArrowExceptionjika pemanggilan fungsi ini akan memerlukan penyalinan data yang mendasarinya. - integer_object_nulls (
bool, defaultnyaFalse) β Cast integer dengan null menjadi objek. - date_as_object (
bool, defaultnyaTrue) β Mengubah tanggal menjadi objek. JikaFalse, konversi ke dtypedatetime64[ns]. - timestamp_as_object (
bool, defaultnyaFalse) β Mengubah timestamp non-nanosecond (np.datetime64) menjadi objek. Hal ini berguna jika Anda memiliki timestamp yang tidak muat dalam rentang tanggal normal untuk timestamp nanosecond (1678 M-2262 M). JikaFalse, semua timestamp dikonversi ke dtypedatetime64[ns]. - use_threads (
bool, defaultnyaTrue) β Apakah akan memparalelkan konversi menggunakan beberapa thread. - deduplicate_objects (
bool, defaultnyaFalse) β Jangan buat beberapa salinan objek Python saat dibuat, untuk menghemat penggunaan memori. Konversi akan lebih lambat. - ignore_metadata (
bool, defaultnyaFalse) β JikaTrue, jangan gunakan metadata βpandasβ untuk merekonstruksi indeks DataFrame, jika ada. - safe (
bool, defaultnyaTrue) β Untuk beberapa tipe data, cast diperlukan agar data dapat disimpan dalam pandas DataFrame atau Series (misalnya, timestamp selalu disimpan sebagai nanosekon di pandas). Opsi ini mengontrol apakah cast tersebut aman atau tidak. - split_blocks (
bool, defaultnyaFalse) β JikaTrue, buat satu βblockβ internal untuk setiap kolom saat membuat pandas.DataFrame dariRecordBatchatauTable. Meskipun ini dapat mengurangi memori secara sementara, perhatikan bahwa berbagai operasi pandas dapat memicu βkonsolidasiβ yang dapat membengkakkan penggunaan memori. - self_destruct (
bool, defaultnyaFalse) β EKSPERIMEN: JikaTrue, coba lepaskan memori Arrow asal saat mengonversi objek Arrow ke pandas. Jika Anda menggunakan objek tersebut setelah memanggilto_pandasdengan opsi ini, program Anda akan crash. - types_mapper (
function, defaultnyaNone) β Fungsi yang memetakan pyarrow DataType keExtensionDtypepandas. Ini dapat digunakan untuk menimpa tipe pandas default untuk konversi tipe bawaan pyarrow atau jika tidak adapandas_metadatadalam skema Table. Fungsi ini menerima pyarrow DataType dan diharapkan mengembalikanExtensionDtypepandas atauNonejika konversi default harus digunakan untuk tipe tersebut. Jika Anda memiliki pemetaan kamus, Anda dapat meneruskandict.getsebagai fungsi.
Mengembalikan
pandas.Series atau pandas.DataFrame
pandas.Series atau pandas.DataFrame tergantung pada tipe objek
Konversi menjadi array NumPy atau DataFrame yang kompatibel dengan pandas, sesuai kebutuhan.
field
< source >( *args**kwargs )
Pilih bidang skema berdasarkan nama kolom atau indeks numeriknya.
kolom
< source >( *args**kwargs )
Pilih kolom berdasarkan nama kolom atau indeks numeriknya.
Iterator untuk semua kolom dalam urutan numerik.
Skema tabel dan kolom-kolomnya.
Daftar semua kolom dalam urutan numerik.
Jumlah kolom dalam tabel ini.
Jumlah baris dalam tabel ini.
Karena definisi tabel, semua kolom memiliki jumlah baris yang sama.
Dimensi tabel: (#baris, #kolom).
Total jumlah byte yang dikonsumsi oleh elemen-elemen tabel.
Nama kolom tabel.
slice
< source >( offset = 0length = None )
Hitung irisan zero-copy dari Table ini.
Pilih rekaman dari sebuah Table. Lihat pyarrow.compute.filter untuk penggunaan lengkap.
flatten
< source >( *args**kwargs )
Ratakan tabel ini. Setiap kolom dengan tipe struct diratakan menjadi satu kolom per field struct. Kolom lainnya tidak diubah.
combine_chunks
< source >( *args**kwargs )
Buat tabel baru dengan menggabungkan chunk yang dimiliki tabel ini.
Semua chunk yang mendasari dalam ChunkedArray dari setiap kolom digabungkan menjadi nol atau satu chunk.
cast
< source >( target_schema*args**kwargs )
Cast nilai tabel ke skema lain.
replace_schema_metadata
< source >( *args**kwargs ) β datasets.table.Table
EKSPERIMEN: Buat salinan dangkal tabel dengan mengganti metadata skema key-value dengan metadata baru yang ditunjukkan (yang dapat berupa None, yang menghapus metadata yang ada).
add_column
< source >( *args**kwargs ) β datasets.table.Table
Parameter
- i (
int) β Indeks untuk menempatkan kolom. - field_ (
Union[str, pyarrow.Field]) β Jika string yang diberikan, tipe akan disimpulkan dari data kolom. - column (
Union[pyarrow.Array, List[pyarrow.Array]]) β Data kolom.
Mengembalikan
datasets.table.Table
Tabel baru dengan kolom yang ditambahkan.
Tambahkan kolom ke Tabel pada posisi.
Tabel baru dikembalikan dengan kolom yang ditambahkan, objek tabel asli tetap tidak berubah.
append_column
< source >( *args**kwargs ) β datasets.table.Table
Tambahkan kolom di akhir daftar kolom.
remove_column
< source >( i*args**kwargs ) β datasets.table.Table
Buat tabel baru dengan kolom yang ditunjukkan dihapus.
set_column
< source >( *args**kwargs ) β datasets.table.Table
Parameter
- i (
int) β Indeks untuk menempatkan kolom. - field_ (
Union[str, pyarrow.Field]) β Jika string yang diberikan, tipe akan disimpulkan dari data kolom. - column (
Union[pyarrow.Array, List[pyarrow.Array]]) β Data kolom.
Mengembalikan
datasets.table.Table
Tabel baru dengan set kolom yang diteruskan.
Ganti kolom di Tabel pada posisi.
Buat tabel baru dengan kolom yang namanya diganti menjadi nama yang diberikan.
pilih
< source >( columns*args**kwargs ) β datasets.table.Table
Parameter
Mengembalikan
Tabel baru dengan kolom yang ditentukan, dan metadata dipertahankan.
Pilih kolom dari tabel.
Mengembalikan tabel baru dengan kolom yang ditentukan, dan metadata dipertahankan.
drop
< source >( columns*args**kwargs ) β datasets.table.Table
Hapus satu atau beberapa kolom dan kembalikan tabel baru.
from_tables
< source >( tables: listaxis: int = 0 )
Buat ConcatenationTable dari daftar tabel.
Utilitas
datasets.table.concat_tables
< source >( tables: listaxis: int = 0 ) β datasets.table.Table
Parameter
- tables (list of
Table) β Daftar tabel yang akan digabungkan. - axis (
{0, 1}, default ke0, yang berarti pada baris) β Axis untuk penggabungan, di mana0berarti pada baris (vertikal) dan1berarti pada kolom (horizontal).Ditambahkan di 1.6.0
Mengembalikan
datasets.table.Table
Jika jumlah tabel input > 1, maka tabel yang dikembalikan adalah datasets.table.ConcatenationTable.
Jika tidak, jika hanya ada satu tabel, tabel tersebut dikembalikan apa adanya.
Gabungkan tabel.
datasets.table.list_table_cache_files
< source >( table: Table ) β List[str]
Mengembalikan
List[str]
Daftar jalur ke file cache yang dimuat oleh tabel.
Dapatkan file cache yang dimuat oleh tabel. File cache digunakan ketika bagian dari tabel berasal dari disk melalui pemetaan memori.