Описание тега apache-calcite
Apache Calcite - это фреймворк для управления данными. Не путать с Apache (HTTP-сервером).
0
ответов
Адаптер Apache Arrow Интеграция с Apache Calcite
Есть ли какая-либо опция, доступная для интеграции apache arrow и apache calcite? Я заметил, что CSV, JSON имеет эту функцию интеграции. но у Apache Arrow этого нет.
27 ноя '18 в 19:14
1
ответ
Использование ROW() для вложенной структуры данных
Я успешно использовал JsonRowSerializationSchema из артефакта flink-json для создания TableSink<Row> и вывести JSON из SQL, используя ROW. Он отлично работает для передачи плоских данных: INSERT INTO outputTable SELECT ROW(col1, col1) FROM inp…
16 янв '19 в 19:39
0
ответов
Apache Calcite запрос JSON вложенных данных
Я сделал, чтобы прочитать простые данные в формате JSON из Кафки с помощью кальцита SQL. Существует специальное требование, что есть вложенные данные, как показано ниже {"ДАННЫЕ":{"СКОРОСТЬ":80},"USER_ID":100200,"USER_NAME":"User1"} И я хочу, чтобы …
23 янв '19 в 05:15
0
ответов
Apache calcite: сбой синтаксического анализа: обнаружен "от \""
В настоящее время я пытаюсь подключиться MySQL с помощью кальцита. Однако у меня были проблемы с выполнением операторов SQL Когда я использую этот sql для оправдания, это работает. ResultSet resultSet = Statement.executeQuery( "select * from ex.dept…
26 фев '19 в 03:48
1
ответ
Почему Flink SQL использует оценку мощности в 100 строк для всех таблиц?
Я не был уверен, почему логический план не был правильно оценен в этом примере. Я посмотрел более глубоко в базовом коде Flink и проверил это, когда кальцит оценивает / оценивает количество строк для запроса в объекте. По какой-то причине он всегда …
08 янв '19 в 23:25
2
ответа
Добавление пользовательской функции в Calcite
Мне нужно добавить пользовательскую функцию в Calcite, которая принимает целое число в качестве параметра и возвращает целое число. public class SquareFunction { public int eval(int a) { return a*a; } } и соответствующий код, который создает схему и…
24 май '17 в 02:13
0
ответов
Ошибка драйвера JDBC Avatica Calcite
Я получаю приведенную ниже ошибку при попытке получить соединение через Java Web App. Кто-нибудь сталкивался с этой проблемой? com.fasterxml.jackson.databind.JsonMappingException: Class org.apache.calcite.avatica.remote.Service$ResultSetResponse not…
28 ноя '18 в 19:21
0
ответов
Apache Calcite - Как интегрировать CSV и MySQL
Каждый адаптер легко использовать по команде connect. например:!connect jdbc:calcite:model=target/test-classes/model.json admin admin но я не нашел в документации, как делать запросы с использованием разнородных источников. Я хотел бы сделать запрос…
14 ноя '18 в 12:32
0
ответов
Глядя на мой собственный формат запроса - я должен реализовать адаптер Clacite против Flink TableSource
Я ищу запрос и использую потоковую обработку для моего собственного формата. хотя я все еще проверяю, стоит ли мне использовать паркет, ORC, Avro или что-то еще, но этот источник демонстративно будет частным. эти данные должны быть проанализированы …
05 дек '18 в 08:45
0
ответов
Кальцит эластичный поиск адаптера эффективное соединение
Как правильно реализовать перезапись JOIN, чтобы запрос получал результаты подзапроса? Например: SELECT state FROM zips_view WHERE j IN (select j from people_view) Этот запрос переписывается в SemiJoin, который выполняет внутренний запрос сканирован…
15 ноя '18 в 19:20
0
ответов
Как сделать преобразование DateTime в Query Record Processor
Я новичок в Apache NiFi, я преобразовал данные типа Date в метку времени в Query Record Processor, используя следующий запрос select ${fn Convert(<ColumnName>,<Datatype as 'timestamp'>) as ColumnName from flowfile} Но я столкнулся с проб…
07 авг '18 в 05:04
1
ответ
Apache Calcite Geode JDBC адаптироваться не работает с Gemfire 8.x и 9.X
Я пытаюсь подключить Gemfire 8.2, используя Apache Calcite Geode. Согласно следующим журналам, он подключен правильно, но при попытке выполнить запрос получает исключение. Примечание: http://calcite.apache.org/news/2018/03/19/release-1.16.0/ Кроме т…
21 мар '18 в 16:02
1
ответ
Экспоненциально убывающая скользящая средняя по скачкообразному окну в Flink SQL: время приведения
Теперь у нас есть SQL с причудливым управлением окнами во Flink, я пытаюсь, чтобы затухающая скользящая средняя называлась "что будет возможно в будущих выпусках Flink как для Table API, так и для SQL". из их дорожной карты SQL / превью 2017-03 пост…
12 фев '19 в 16:56
1
ответ
Apache Calcite - не могу разобрать операторы DDL
Ниже приведена конфигурация, которую я использую для разбора операторов MySQL. Я могу нормально анализировать и обрабатывать операторы DML, но не могу разобрать любые операторы DDL (CREATE TABLE, ALTER TABLE, DROP TABLE и т. Д.). public static SqlNo…
16 дек '18 в 09:38
1
ответ
Как я могу создать таблицу внешнего каталога в Apache Flink
Я попытался создать и ExternalCatalog для использования в Apache Flink Table. Я создал и добавил в среду Flink table (здесь официальная документация). По какой-то причине единственная внешняя таблица присутствует в "каталоге", она не найдена во врем…
20 янв '19 в 16:27
1
ответ
apache calcite, запрос без использования API JDBC
Я хотел бы использовать apache calcite api raw без использования соединений jdbc. Я могу использовать API jdbc просто отлично, но я получаю исключения null ptr при попытке использовать API. Что я сделал до сих пор: package calcite.examples import ja…
29 мар '16 в 11:36
0
ответов
Настройка производительности Calcite sql
Я использую calcite, чтобы выполнить какую-то работу sql, ниже приведен простой тестовый код: String json = "{\"DATA\":{\"CAR_NO\":123123},\"USER_ID\":300,\"USER_NAME\":\"user1\"}"; ResultSet resultSet = null; long begin = System.currentTimeMillis()…
21 фев '19 в 02:38
0
ответов
Определение схемы для JdbcAdapter
Я запрашиваю таблицу базы данных H2 через кальцит. Я создал следующую таблицу в H2, используя драйвер jdbc H2 CREATE TABLE EMP(ENAME VARCHAR(10), DEPTNO INT, GENDER VARCHAR(1)) В кальците я использую следующую схему для подключения { "version": "1.0…
26 дек '18 в 20:34
1
ответ
Apache Calcite выдает ошибку при использовании COALESCE только с нетипизированными нулями
Когда бег SELECT COALESCE(NULL, NULL); на Apache Calcite я получаю ошибку, которая говорит, что Предложение ELSE или хотя бы одно предложение THEN должно быть ненулевым Это происходит потому, что COALESCE функция преобразуется в CASE выражение и пос…
21 янв '19 в 11:59
1
ответ
Наличие эквивалента HOP_START внутри примитива агрегации в Flink
Я пытаюсь сделать экспоненциально убывающую скользящую среднюю по скользящему окну в Flink SQL. Мне нужен доступ к одной из границ окна, HOP_START в следующем: SELECT lb_index one_key, -- I have access to this one: HOP_START(proctime, INTERVAL '0.05…
13 фев '19 в 11:16