jdbc (DataFrameReader)

DataFrame Vytvoří reprezentaci databázové tabulky přístupné prostřednictvím adresy URL urlJDBC . Oddíly tabulky se načítají paralelně, pokud column je zadána nebo predicates je zadána. Pokud jsou zadány obě column a predicates jsou zadány, column má přednost.

Syntaxe

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

Parametry

Parameter Typ Description
url str Adresa URL JDBC formuláře jdbc:subprotocol:subname.
table str Název tabulky v externí databázi.
column str, volitelné Sloupec, který se má použít pro dělení (alias pro partitionColumn tuto možnost). Vyžaduje lowerBound, upperBounda numPartitions.
lowerBound int nebo str, volitelné Minimální hodnota column dělení. Je vyžadováno, když je column zadáno.
upperBound int nebo str, volitelné Maximální hodnota column dělení. Je vyžadováno, když je column zadáno.
numPartitions int, volitelné Počet oddílů. Je vyžadováno, když je column zadáno.
predicates list, volitelné Seznam WHERE výrazů klauzule, každý definující jeden oddíl DataFrame. Ignorováno, pokud column je zadáno.
properties diktování, volitelné Argumenty připojení JDBC, obvykle včetně 'user' a 'password'. Například: {'user': 'SYSTEM', 'password': 'mypassword'}.

Návraty

DataFrame

Poznámky

Vyhněte se paralelnímu vytváření příliš mnoha oddílů ve velkém clusteru, protože může dojít k chybovému ukončení externích databázových systémů.