Как я могу передать Феникса в Zeppelin? - PullRequest
Новая
       9

Как я могу передать Феникса в Zeppelin?

0 голосов
/ 17 сентября 2018

У меня есть таблица, определенная как таковая в Фениксе: 

create table if not exists EmailExclusion (
    EmailAddress varchar(255) NOT NULL,
    DeliveryStatusId integer NOT NULL,
    LastExclusionUtc timestamp,
    Count integer,
    CreateUtc timestamp,
    CONSTRAINT pk PRIMARY KEY (EmailAddress, DeliveryStatusId)
)

Используя CSV-загрузку, я смог получить следующую запись в БД: 

TotallyNotReal@kyre.org 5   2018-09-07 00:01:53.241 20  2018-09-06 11:10:00.077

ИспользуяЦеппелин, я попытался изменить эту запись, таким образом: 

%phoenix

UPSERT INTO EmailExclusion(EmailAddress, DeliveryStatusId, LastExclusionUtc, Count) 
VALUES('TotallyNotReal@kyre.org', 5, '2018-09-17', 21)

К сожалению, последующий выбор в таблице обнаруживает, что исходные значения сохраняются.Я прочитал достаточно онлайн, чтобы знать, что мне нужно зафиксировать значение, прежде чем оно зафиксируется, но я не знаю, как это сделать, используя Zeppelin JDBC.Есть ли какие-то настройки, которые я должен использовать в настройках интерпретатора, или какую-то дополнительную команду, которую я могу включить сюда?

...