jdbc (DataFrameReader)

Membuat tabel database yang DataFrame mewakili yang dapat diakses melalui URL urlJDBC . Partisi tabel diambil secara paralel jika salah satu column atau predicates ditentukan. Jika keduanya column dan predicates ditentukan, column diutamakan.

Sintaksis

jdbc(url, table, column=None, lowerBound=None, upperBound=None,
     numPartitions=None, predicates=None, properties=None)

Parameter-parameternya

Parameter	Tipe	Deskripsi
url	str	URL JDBC formulir jdbc:subprotocol:subname.
table	str	Nama tabel dalam database eksternal.
column	str, opsional	Kolom yang digunakan untuk pemartisian (alias untuk partitionColumn opsi ). lowerBoundMembutuhkan , upperBound, dan numPartitions.
lowerBound	int atau str, opsional	Nilai minimum untuk pemartisian column . Diperlukan ketika column ditentukan.
upperBound	int atau str, opsional	Nilai column maksimum untuk partisi. Diperlukan ketika column ditentukan.
numPartitions	int, opsional	Jumlah partisi. Diperlukan ketika column ditentukan.
predicates	daftar, opsional	Daftar WHERE ekspresi klausul, masing-masing menentukan satu partisi .DataFrame Diabaikan jika column ditentukan.
properties	dict, opsional	Argumen koneksi JDBC, biasanya termasuk 'user' dan 'password'. Contohnya, {'user': 'SYSTEM', 'password': 'mypassword'}.

Pengembalian Barang

DataFrame

Catatan

Hindari membuat terlalu banyak partisi secara paralel pada kluster besar, karena ini dapat merusak sistem database eksternal.