jdbc (DataFrameReader)

DataFrame Создает таблицу базы данных, доступную по URL-адресу urlJDBC. Секции таблицы извлекаются параллельно, если column задано или predicates указано. Если оба column и predicates задано, column имеет приоритет.

Синтаксис

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

Параметры

Параметр	Тип	Описание
url	str	URL-адрес JDBC формы jdbc:subprotocol:subname.
table	str	Имя таблицы во внешней базе данных.
column	str, необязательный	Столбец, используемый для секционирования (псевдоним для partitionColumn параметра). Требуется lowerBound, upperBoundи numPartitions.
lowerBound	int или str, необязательный	Минимальное значение column секционирования. Обязательно, когда указано column.
upperBound	int или str, необязательный	Максимальное значение column секционирования. Обязательно, когда указано column.
numPartitions	int, необязательный	Количество секций. Обязательно, когда указано column.
predicates	list, необязательный	Список выражений WHERE предложения, каждый из которых определяет одну секцию DataFrame. Игнорируется, если указан column.
properties	дикт, необязательный	Аргументы подключения JDBC, как правило, включая 'user' и 'password'. Например: {'user': 'SYSTEM', 'password': 'mypassword'}.

Возвраты

DataFrame

Примечания

Избегайте параллельного создания слишком большого количества секций в большом кластере, так как это может завершить работу внешних систем баз данных.