jdbc (DataFrameReader)

JDBC URL'si DataFramearacılığıyla erişilebilen veritabanı tablosunu temsil eden bir url oluşturur. Tablo bölümleri, veya column belirtilirse predicates paralel olarak alınır. Hem hem de columnpredicates belirtilirse öncelik column kazanır.

Sözdizimi

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

Parametreler

Parametre Türü Açıklama
url str formunun jdbc:subprotocol:subnameJDBC URL'si.
table str Dış veritabanındaki tablonun adı.
column str, isteğe bağlı Bölümleme için kullanılacak sütun (seçeneğin partitionColumn diğer adı). , lowerBoundve upperBoundgerektirirnumPartitions.
lowerBound int veya str, isteğe bağlı Bölümleme için en düşük değeri column . Belirtildiğinde column gereklidir.
upperBound int veya str, isteğe bağlı Bölümleme için en büyük değeri column . Belirtildiğinde column gereklidir.
numPartitions int, isteğe bağlı Bölüm sayısı. Belirtildiğinde column gereklidir.
predicates liste, isteğe bağlı Her biri öğesinin WHERE bir bölümünü tanımlayan yan tümce ifadelerinin DataFramelistesi. column belirtilmişse yoksayılır.
properties dict, isteğe bağlı Genellikle ve 'user'dahil olmak üzere 'password' JDBC bağlantı bağımsız değişkenleri. Örneğin, {'user': 'SYSTEM', 'password': 'mypassword'}.

İadeler

DataFrame

Notlar

Dış veritabanı sistemlerinin kilitlenmesine neden olabileceğinden, büyük bir kümede paralel olarak çok fazla bölüm oluşturmaktan kaçının.