jdbc (DataFrameReader)

Konstruerar en DataFrame som representerar databastabellen som är tillgänglig via JDBC URL url. Partitioner i tabellen hämtas parallellt om antingen column eller predicates har angetts. Om både column och predicates anges column har företräde.

Syntax

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

Parameters

Parameter Type Beskrivning
url str JDBC-URL:en för formuläret jdbc:subprotocol:subname.
table str Namnet på tabellen i den externa databasen.
column str, valfritt Kolumnen som ska användas för partitionering (alias för alternativet partitionColumn ). Kräver lowerBound, upperBoundoch numPartitions.
lowerBound int eller str, valfritt Minimivärdet column för för partitionering. Krävs när column anges.
upperBound int eller str, valfritt Det maximala värdet column för för partitionering. Krävs när column anges.
numPartitions int, valfritt Antalet partitioner. Krävs när column anges.
predicates list, valfritt En lista över WHERE satsuttryck som var och en definierar en partition av DataFrame. Ignoreras om column har angetts.
properties diktering, valfritt JDBC-anslutningsargument, vanligtvis inklusive 'user' och 'password'. Till exempel {'user': 'SYSTEM', 'password': 'mypassword'}.

Retur

DataFrame

Notes

Undvik att skapa för många partitioner parallellt i ett stort kluster, eftersom detta kan krascha externa databassystem.

  • Last updated on