partitionRead

Импортируйте данные от разделов Apache таблица базы данных Кассандры

Описание

пример

results = partitionRead(conn,keyspace,tablename) возвращает импортированные данные путем чтения всех столбцов базы данных Cassandra® из всех разделов таблицы базы данных Кассандры. partitionRead функция импортирует данные от базы данных Кассандры в MATLAB®, не используя запрос Языка запросов Кассандры (CQL).

пример

results = partitionRead(conn,keyspace,tablename,keyValue1...keyValueN) возвращает импортированные данные путем чтения всех столбцов Кассандры из одного или нескольких разделов, заданных значениями ключа раздела.

пример

results = partitionRead(___,Name,Value) задает опции с помощью одного или нескольких аргументов значения имени с помощью любой из предыдущих комбинаций входных аргументов. Например, 'ConsistencyLevel',"TWO" устанавливает уровень непротиворечивости указывать, что два узла должны ответить для запроса CQL, чтобы выполниться.

Примеры

свернуть все

Используя базу данных Apache Cassandra® интерфейс C++, создайте соединение с базой данных Кассандры и импортируйте данные от таблицы базы данных Кассандры в MATLAB®. База данных Кассандры содержит таблицу базы данных с данными сотрудника.

Создайте соединение с базой данных Кассандры с помощью сконфигурированного источника данных CassandraDataSource и пустое имя пользователя и пароль. apacheCassandra функция возвращает conn как connection объект.

datasource = "CassandraDataSource";
username = "";
password = "";
conn = apacheCassandra(datasource,username,password);

Импортируйте данные сотрудника в MATLAB от employeedata ключевого пространства и employees_by_job таблица базы данных при помощи соединения с базой данных Кассандры.

keyspace = "employeedata";
tablename = "employees_by_job";
results = partitionRead(conn,keyspace,tablename);

Отобразите первые несколько строк возвращенных данных сотрудника.

head(results)
ans=8×13 table
      job_id       hire_date     employee_id    commission_pct    department_id      email       first_name      last_name      manager_id         office         performance_ratings     phone_number     salary
                                                                                                                                              building    room                                                   
    __________    ___________    ___________    ______________    _____________    __________    __________    _____________    __________    ________________    ___________________    ______________    ______

    "ST_CLERK"    08-Mar-2008        128             NaN               50          "SMARKLE"     "Steven"      "Markle"            120        "North"     171         {3×1 int32}        "650.124.1434"     2200 
    "ST_CLERK"    06-Feb-2008        136             NaN               50          "HPHILTAN"    "Hazel"       "Philtanker"        122        "North"     303         {[      2]}        "650.127.1634"     2200 
    "ST_CLERK"    12-Dec-2007        135             NaN               50          "KGEE"        "Ki"          "Gee"               122        "West"      287         {2×1 int32}        "650.127.1734"     2400 
    "ST_CLERK"    10-Apr-2007        132             NaN               50          "TJOLSON"     "TJ"          "Olson"             121        "North"     256         {[      7]}        "650.124.8234"     2100 
    "ST_CLERK"    14-Jan-2007        127             NaN               50          "JLANDRY"     "James"       "Landry"            120        "West"      273         {2×1 int32}        "650.124.1334"     2400 
    "ST_CLERK"    28-Sep-2006        126             NaN               50          "IMIKKILI"    "Irene"       "Mikkilineni"       120        "East"      246         {4×1 int32}        "650.124.1224"     2700 
    "ST_CLERK"    26-Aug-2006        134             NaN               50          "MROGERS"     "Michael"     "Rogers"            122        "East"      246         {3×1 int32}        "650.127.1834"     2900 
    "ST_CLERK"    09-Jul-2006        144             NaN               50          "PVARGAS"     "Peter"       "Vargas"            124        "North"     129         {3×1 int32}        "650.121.2004"     2500 

results таблица, которая содержит эти переменные:

  • job_id — Идентификатор задания

  • hire_date — Наймите дату

  • employee_id — Идентификатор сотрудника

  • commission_pct — Уполномочьте процент

  • department_id — Идентификатор отдела

  • email — Адрес электронной почты

  • first_name — Имя

  • last_name — Фамилия

  • manager_id — Идентификатор менеджера

  • office — Местоположение Office (таблица, которая содержит две переменные для создания и комнаты),

  • performance_ratings — Оценки эффективности

  • phone_number — Номер телефона

  • salary — Зарплата

Закройте соединение с базой данных Кассандры.

close(conn)

Используя базу данных Apache Cassandra® интерфейс C++, создайте соединение с базой данных Cassandra® и импортируйте данные от таблицы базы данных Кассандры в MATLAB®. Используйте значения двух ключей раздела в таблице базы данных, чтобы импортировать данные. База данных Кассандры содержит таблицу базы данных с данными сотрудника.

Создайте соединение с базой данных Кассандры с помощью сконфигурированного источника данных CassandraDataSource и пустое имя пользователя и пароль. apacheCassandra функция возвращает conn как connection объект.

datasource = "CassandraDataSource";
username = "";
password = "";
conn = apacheCassandra(datasource,username,password);

Импортируйте данные сотрудника в MATLAB от employeedata ключевое пространство и employees_by_name таблица базы данных при помощи соединения с базой данных Кассандры. Эта таблица базы данных имеет first_name и last_name ключи раздела. Задайте имя и фамилию двух сотрудников как значения ключей раздела, чтобы импортировать данные для тех двух сотрудников.

keyspace = "employeedata";
tablename = "employees_by_name";
keyValue1 = ["Christopher","Alexander"];
keyValue2 = ["Olsen","Hunold"];
results = partitionRead(conn,keyspace,tablename,keyValue1,keyValue2);

Отобразите возвращенные данные сотрудника для этих двух сотрудников.

results
results=2×13 table
     first_name      last_name     hire_date     employee_id    commission_pct    department_id      email       job_id      manager_id         office         performance_ratings        phone_number        salary
                                                                                                                                           building    room                                                         
    _____________    _________    ___________    ___________    ______________    _____________    _________    _________    __________    ________________    ___________________    ____________________    ______

    "Alexander"      "Hunold"     03-Jan-2006        103             NaN               60          "AHUNOLD"    "IT_PROG"       102        "West"      155         {2×1 int32}        "590.423.4567"           9000 
    "Christopher"    "Olsen"      30-Mar-2006        153             0.2               80          "COLSEN"     "SA_REP"        145        "South"     333         {4×1 int32}        "011.44.1344.498718"     8000 

results таблица, которая содержит эти переменные:

  • first_name — Имя

  • last_name — Фамилия

  • hire_date — Наймите дату

  • employee_id — Идентификатор сотрудника

  • commission_pct — Уполномочьте процент

  • department_id — Идентификатор отдела

  • email — Адрес электронной почты

  • job_id — Идентификатор задания

  • manager_id — Идентификатор менеджера

  • office — Местоположение Office (таблица, которая содержит две переменные для создания и комнаты),

  • performance_ratings — Оценки эффективности

  • phone_number — Номер телефона

  • salary — Зарплата

Закройте соединение с базой данных Кассандры.

close(conn)

Используя базу данных Apache Cassandra® интерфейс C++, создайте соединение с базой данных Кассандры и импортируйте данные от таблицы базы данных Кассандры в MATLAB®. Использование значение раздела вводит таблицу базы данных, чтобы импортировать данные. Задайте уровень непротиворечивости для того, чтобы возвратить результаты. База данных Кассандры содержит таблицу базы данных с данными сотрудника.

Создайте соединение с базой данных Кассандры с помощью сконфигурированного источника данных CassandraDataSource и пустое имя пользователя и пароль. apacheCassandra функция возвращает conn как connection объект.

datasource = "CassandraDataSource";
username = "";
password = "";
conn = apacheCassandra(datasource,username,password);

Импортируйте данные сотрудника в MATLAB от employeedata ключевое пространство и employees_by_job таблица базы данных при помощи соединения с базой данных Кассандры. Эта таблица базы данных имеет job_id ключ раздела. Задайте IT_PROG значение ключа раздела, чтобы импортировать все данные только для тех сотрудников, которые являются программистами. Кроме того, задайте уровень непротиворечивости как один узел.

keyspace = "employeedata";
tablename = "employees_by_job";
keyValue = "IT_PROG";
level = "ONE";
results = partitionRead(conn,keyspace,tablename,keyValue, ...
    'ConsistencyLevel',level);

Один узел копии отвечает возвращенными данными.

Отобразите возвращенные данные сотрудника.

results
results=5×13 table
     job_id       hire_date     employee_id    commission_pct    department_id      email       first_name      last_name     manager_id         office         performance_ratings     phone_number     salary
                                                                                                                                            building    room                                                   
    _________    ___________    ___________    ______________    _____________    __________    ___________    ___________    __________    ________________    ___________________    ______________    ______

    "IT_PROG"    21-May-2007        104             NaN               60          "BERNST"      "Bruce"        "Ernst"           103        "North"     371         {[      8]}        "590.423.4568"     6000 
    "IT_PROG"    07-Feb-2007        107             NaN               60          "DLORENTZ"    "Diana"        "Lorentz"         103        "West"      133         {3×1 int32}        "590.423.5567"     4200 
    "IT_PROG"    05-Feb-2006        106             NaN               60          "VPATABAL"    "Valli"        "Pataballa"       103        "East"      231         {5×1 int32}        "590.423.4560"     4800 
    "IT_PROG"    03-Jan-2006        103             NaN               60          "AHUNOLD"     "Alexander"    "Hunold"          102        "West"      155         {2×1 int32}        "590.423.4567"     9000 
    "IT_PROG"    25-Jun-2005        105             NaN               60          "DAUSTIN"     "David"        "Austin"          103        "South"     393         {2×1 int32}        "590.423.4569"     4800 

results таблица, которая содержит эти переменные:

  • job_id — Идентификатор задания

  • hire_date — Наймите дату

  • employee_id — Идентификатор сотрудника

  • commission_pct — Уполномочьте процент

  • department_id — Идентификатор отдела

  • email — Адрес электронной почты

  • first_name — Имя

  • last_name — Фамилия

  • manager_id — Идентификатор менеджера

  • office — Местоположение Office (таблица, которая содержит две переменные для создания и комнаты),

  • performance_ratings — Оценки эффективности

  • phone_number — Номер телефона

  • salary — Зарплата

Закройте соединение с базой данных Кассандры.

close(conn)

Входные параметры

свернуть все

Apache соединение с базой данных Кассандры в виде connection объект.

Ключевое пространство в виде вектора символов или строкового скаляра. Если вы не знаете ключевое пространство, то доступ Keyspaces свойство connection объект с помощью записи через точку, чтобы просмотреть ключевые пространства в базе данных Кассандры.

Пример: "employeedata"

Типы данных: char | string

Таблица базы данных Кассандры называет в виде вектора символов или строкового скаляра. Если вы не знаете имя таблицы, то используйте tablenames функционируйте, чтобы найти его.

Пример: "employees_by_job"

Типы данных: char | string

Значения ключа раздела в виде одного из этих типов данных:

  • числовой скаляр

  • числовой массив

  • символьный вектор

  • массив ячеек из символьных векторов

  • скаляр строки

  • массив строк

  • logical

  • logical массив

  • datetime массив

  • duration массив

Если вы не задаете keyValue1...keyValueN входной параметр, затем partitionRead функция импортирует данные от всех разделов таблицы базы данных Кассандры (то же самое, когда CQL запрашивают SELECT * FROM tablename).

Задайте одно значение ключа для каждого ключа раздела таблицы базы данных Кассандры. Максимальное количество значений ключа раздела, которые можно задать, является количеством первичных ключей, которое включает ключи раздела и кластеризирующиеся столбцы в базе данных Кассандры.

Если вы задаете скалярное значение, то CQL запрашивают эквивалентный, = пункт в WHERE CQL пункт. Если вы задаете массив значений, то CQL запрашивают эквивалентный, IN пункт в WHERE CQL пункт.

Если все значения ключа раздела являются скалярными значениями, то partitionRead функция импортирует данные от одного раздела. Если некоторые значения ключа раздела являются массивами, то partitionRead функция импортирует данные путем поиска нескольких разделов, которые соответствуют всем возможным сочетаниям клавиш.

Следующая таблица описывает, поддержал ключи раздела Кассандры.

Поддерживаемый ключ раздела КассандрыMATLAB допустимые типы данных для одного разделаMATLAB допустимые типы данных для нескольких разделов

ascii

вектор символов или строковый скаляр

массив ячеек из символьных векторов или массив строк

bigint

числовой скаляр или logical скаляр

числовой массив или logical массив

blob

числовой массив

массив ячеек числовых массивов

boolean

числовой скаляр или logical скаляр

числовой массив или logical массив

date

datetime массив, строковый скаляр или вектор символов

datetime массив, массив строк или массив ячеек из символьных векторов

decimal

числовой скаляр, logical скаляр или string скаляр

числовой массив, logical массив или string массив

double

числовой скаляр или logical скаляр

числовой массив или logical массив

float

числовой скаляр или logical скаляр

числовой массив или logical массив

inet

вектор символов или строковый скаляр

массив ячеек из символьных векторов или массив строк

int

числовой скаляр или logical скаляр

числовой массив или logical массив

smallint

числовой скаляр или logical скаляр

числовой массив или logical массив

text

вектор символов или строковый скаляр

массив ячеек из символьных векторов или массив строк

time

duration массив, строковый скаляр или вектор символов

duration массив, массив строк или массив ячеек из символьных векторов

timestamp

datetime массив, строковый скаляр или вектор символов

datetime массив, массив строк или массив ячеек из символьных векторов

timeuuid

вектор символов или строковый скаляр

массив ячеек из символьных векторов или массив строк

tinyint

числовой скаляр или logical скаляр

числовой массив или logical массив

uuid

вектор символов или строковый скаляр

массив ячеек из символьных векторов или массив строк

varchar

вектор символов или строковый скаляр

массив ячеек из символьных векторов или массив строк

varint

числовой скаляр, logical скаляр или string

числовой массив, logical массив или string массив

Эти ключи раздела Кассандры не поддерживаются:

  • counter

  • list

  • map

  • set

  • tuple

  • пользовательские типы (UDTs)

Пример: ["MA","CT"]

Пример: 1,2,'DataProvider1','AmbientTemp'

Типы данных: double | logical | char | string | struct | cell | datetime | duration

Аргументы в виде пар имя-значение

Задайте дополнительные разделенные запятой пары Name,Value аргументы. Name имя аргумента и Value соответствующее значение. Name должен появиться в кавычках. Вы можете задать несколько аргументов в виде пар имен и значений в любом порядке, например: Name1, Value1, ..., NameN, ValueN.

Пример: results = partitionRead(conn,keyspace,tablename,'ConsistencyLevel',"ONE",'RequestTimeout',15) возвращает импортированные данные путем получения ответа чтения из одного узла, и база данных должна ожидать 15 секунд, чтобы выполнить операцию чтения прежде, чем выдать ошибку.

Уровень непротиворечивости в виде одного из этих значений.

Значение уровня непротиворечивостиОписание уровня непротиворечивости

"ALL"

Возвратите результаты запроса, когда все узлы копии ответят.

"QUORUM"

Возвратите результаты запроса, когда большинство узлов копии ответит.

"LOCAL_QUORUM"

Возвратите результаты запроса, когда большинство узлов копии в локальном дата-центре ответит.

"ONE" (значение по умолчанию)

Возвратите результаты запроса, когда один узел копии ответит.

"TWO"

Возвратите результаты запроса, когда два узла копии ответят.

"THREE"

Возвратите результаты запроса, когда три узла копии ответят.

"LOCAL_ONE"

Возвратите результаты запроса, когда один узел копии в локальном дата-центре ответит.

"SERIAL"

Возвратите результаты запроса для текущего (и возможно незафиксированный) данные для узлов копии в любом дата-центре.

"LOCAL_SERIAL"

Возвратите результаты запроса для текущего (и возможно незафиксированный) данные для узлов копии в локальном дата-центре.

Можно задать значение уровня непротиворечивости как вектор символов или строковый скаляр.

Для получения дополнительной информации об уровнях непротиворечивости, смотрите непротиворечивость данных Конфигурирования.

Типы данных: char | string

Это свойство доступно только для чтения.

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

Типы данных: double

Выходные аргументы

свернуть все

Импортированные результаты данных, возвращенные как таблица. Таблица содержит импортированные данные от разделов, которые соответствуют keyValue1...keyValueN входной параметр. Каждый столбец базы данных Кассандры от разделов становится переменной в таблице. Имена переменных совпадают с именами столбцов базы данных Кассандры в заданных разделах.

Типы данных переменных в таблице зависят от типов данных Кассандры. Для получения дополнительной информации о том, как типы данных CQL преобразуют в типы данных MATLAB, смотрите, Преобразуют Типы данных CQL в типы данных MATLAB Используя Apache Кассандра Дэйтабэз Интерфейс C++.

Введенный в R2021a