partitionRead

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

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

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

Синтаксис

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

Описание

пример

results = partitionRead(conn,keyspace,tablename) возвращает импортированные данные путем чтения всех столбцов базы данных Кассандры из всех разделов таблицы базы данных Кассандры. 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

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

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

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

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

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

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

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

  • 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

Поддержка

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