184 похожих чатов

Добрый день Есть вопрос по KafkaEngine Можно ли кушать из json'a в

Array(Tuple()), если да, то какой жсон стоит сделать?

10 ответов

9 просмотров

Можно. а зачем вам Array(Tuple) ? Tuple что? Какие там типы?

Тайка-Тутто Автор вопроса
Denny [Altinity]
Можно. а зачем вам Array(Tuple) ? Tuple что? Каки...

Смешанный тупл в массиве [ (string, int, float) ]

Тайка Тутто
Смешанный тупл в массиве [ (string, int, float) ]

а зачем? в смысле я не люблю бегать с дыркой в ноге, а вы пытаетесь

Тайка-Тутто Автор вопроса
Тайка Тутто
В чем проблема, какая альтернатива?

ну геморрой это в кодировании (с unboxing) и в зависимости от версии КХ может работать ну очень медленно по сравнению с Array(string), Array(int), Array(float)

Тайка-Тутто Автор вопроса
Denny [Altinity]
ну геморрой это в кодировании (с unboxing) и в зав...

А потом гемморой эти данные из массивов мэтчить для аналитики и вообще

Тайка Тутто
А потом гемморой эти данные из массивов мэтчить дл...

короче ладно, если вопрос был про jsoneachrow, А НЕ ПРО JSON, то ответ select [('x', 1, 0.5), ('y', 2, 1.5)] col1 format JSONEachRow; {"col1":[["x",1,0.5],["y",2,1.5]]}

Тайка-Тутто Автор вопроса
Denny [Altinity]
короче ладно, если вопрос был про jsoneachrow, А Н...

Т.е. если я в топике несу JSONEachRow; {"col1":[["x",1,0.5],["y",2,1.5]]} KafkaEngine скушает в Array(Tuple (String ... ))

Тайка Тутто
Т.е. если я в топике несу JSONEachRow; {"col1":...

KafkaEngine ничем не отличается от обычного инсерта, все дело в format. А это абсолютно индифферентно используете ли вы KafkaEngine или не KafkaEngine. Т.е. если вы сделали KafkaEngine таблицу у нее написали формат JSONEachRow и закидываете в kafka message один или несколько json-в, все будет работать, можно закидывать один json, можно несколько разделенных запятой и окруженных [] (типа массив), можно несколько разделенных концом строки \n по сути это ничем не отличается как если бы вы кидали файл в insert Если у вас не JSONEachRow, а свой какой-то JSON, то все делается по другому. Если вы можете сами формировать JSONEachRow, то при более меннее нормальной нагрузке (big data) полный идиотизм использовать JSONEachRow, это как баксами камин топить, JSONEachRow в два три раза дороже по CPU чем TSV/CSV. (пожалуй не баксами, а например туалетной бумагой)

Тайка-Тутто Автор вопроса
Denny [Altinity]
KafkaEngine ничем не отличается от обычного инсерт...

Спасибо большое! Учту про оптимизацию

Похожие вопросы

Обсуждают сегодня

Есть какой-нибудь для Delphi/FPC T*Compression(Decompression)Stream на базе LZ4/Zstd/любой другой быстрый(и хорошо сжимающий) алгоритм А ещё лучше в pure pascal А ещё лучше од...
notme
48
Такой вопросец - есть функция function MySuperDuperConcat(const a: array of AnsiString): AnsiString; Как мне в её теле сделать вот так? Result:=Concat(a); А не грустный вариан...
notme
15
type TObj = object procedure Init; virtual; end; TObj1 = object(TObj) procedure Init; override; end; procedure TObj1.Init; begin inherited; end; procedur...
Alexander 👋
29
А чем вам питонисты не угодили?😂
.
79
Всем привет. Поделитесь, пожалуйста, опытом. Есть форма, на которой имеется dbgrid и кнопки: добавить, редактировать, удалить. Если нет записей в dbgrid, то кнопки редактирова...
Евгений
4
Всем привет, написал код ниже, но он выдает сегфолт, в чем причина? #include <stdio.h> #include <stdlib.h> #include <string.h> struct product { char *name; float price; };...
buzz базз
86
Вот смотрите у меня есть два стрима сейчас fs, cs: TStream; fs := TFileStream.Create('filename'); cs := TCompressionStream.Create(compression_level, fs); Я хочу сделать так: ...
notme
5
type TExtensions<GExtender>=class function GetExtension<GEntityExtenderType>:GEntityExtenderType; end; function TExtensions<GExtender>.GetExtension<GEntityExtenderType...
zamtmn
8
Всем здравствуйте! Я хотел узнать сколько стоит средняя месячная зарплата у Electron js разработчиков? Мне очень это важно и нужно, плиз помогите узнать эту инфу! Для Джунио...
U.K.
10
Можно ли загрузить скрипт py в бота чтобы он работал по нему? как это сделать?
huskadam #RCC Фанат? @hitlerpvp
13
Карта сайта