partitionRead

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

свернуть все на странице

Синтаксис

results = partitionRead(conn,keyspace,tablename)
results = partitionRead(conn,keyspace,tablename,keyValue1...keyValueN)
results = partitionRead(___,'ConsistencyLevel',level)

Описание

пример

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

пример

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

пример

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

Примеры

свернуть все

Скрипт Open Live Script

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

Создайте соединение с базой данных Кассандры с помощью локального адреса хоста. conn является объектом cassandra .

contactPoints = "localhost";
conn = cassandra(contactPoints);

Импортируйте данные сотрудника в 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)
Скрипт Open Live Script

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

Создайте соединение с базой данных Кассандры с помощью локального адреса хоста. conn является объектом cassandra .

contactPoints = "localhost";
conn = cassandra(contactPoints);

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

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

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

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)
Скрипт Open Live Script

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

Создайте соединение с базой данных Кассандры с помощью локального адреса хоста. conn является объектом cassandra .

contactPoints = "localhost";
conn = cassandra(contactPoints);

Импортируйте данные сотрудника в 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)
Скрипт Open Live Script

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

Создайте соединение с базой данных Кассандры с помощью локального адреса хоста. conn является объектом cassandra .

contactPoints = "localhost";
conn = cassandra(contactPoints);

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

keyspace = "employeedata";
tablename = "employees_by_job";
keyValue = "IT_PROG";
level = "QUORUM";
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)

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

свернуть все

Соединение с базой данных Кассандры, заданное как объект cassandra.

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

Пример: "employeedata"

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

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

Пример: "employees_by_job"

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

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

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

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

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

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

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

  • stringArray

  • 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 или скаляр java.math.BigDecimal

числовой массив, массив logical или массив java.math.BigDecimal

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 или java.math.BigInteger

числовой массив, массив logical или массив java.math.BigInteger

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

  • counter

  • list

  • map

  • set

  • tuple

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

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

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

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

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

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

"ALL"

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

"QUORUM"

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

"LOCAL_QUORUM"

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

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

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

"TWO"

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

"THREE"

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

"LOCAL_ONE"

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

"SERIAL"

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

"LOCAL_SERIAL"

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

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

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

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

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

свернуть все

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

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

Смотрите также

| | | |

Темы

Внешние веб-сайты

Введенный в R2018b

Документация Database Toolbox
Поддержка
Для просмотра документации необходимо авторизоваться на сайте