Я пытался настроить проект Maven, который будет содержать пользовательские функции (UDF), которые я хотел бы использовать в своих запросах Hive. Я начал с проекта Maven, не содержащего исходных файлов, и следующего POM: <?xml version="1.0"...

Я использую Apache Calcite для реализации распределенной системы OLAP, источником данных которой является RDBMS. Итак, я хочу понизить проект/фильтр/агрегацию в дереве RelNode до MyTableScan extends TableScan . В MyTableScan используйте...

Я не был уверен, почему логический план не был правильно оценен в этом примере . Я более подробно изучил базовый код Flink и проверил, что когда кальцит оценивает / оценивает количество строк для запроса в объекте. По какой-то причине он всегда...

Теперь у нас есть SQL с причудливым оконным интерфейсом во Flink, я пытаюсь указать на убывающую скользящую среднюю как «то, что будет возможно в будущих выпусках Flink как для Table API, так и для SQL». из их дорожной карты SQL / предварительной...

Недавно я попытался выполнить запрос в Apache Calcite, используя три файла CSV в виде таблиц. TTLA_ONE содержит 59 строк TTLR_ONE содержит 61390 строк EMPTY_T содержит 0 строк Это запрос, который выполняется: EXPLAIN PLAN FOR SELECT...

Я хочу импортировать файл со следующей схемой Avro, назначенной с помощью Apache NiFi: { "type" : "record", "namespace" : "SomeSpaceName", "name" : "SampleFile", "fields" : [ { "name" : "PersonName" , "type" : "string" }, {...

Я пытаюсь преобразовать запрос SQL в выражение реляционной алгебры, используя Apache Calcite SqlToRelConverter . Он отлично работает для этого запроса (кавычки для обеспечения нижнего регистра): queryToRelationalAlgebraRoot("SELECT \"country\"...

В Calcite, после оптимизации, предоставленной VolcanoPlanner по умолчанию, мы можем получить оптимизированный RelNode, но можем ли мы провести дальнейшую оптимизацию? Например, я хочу добавить ElasticsearchSort или что-то в этом роде, чтобы...

Постановка задачи: У меня есть вход PCollection со следующими полями: { firstname_1, lastname_1, dob, firstname_2, lastname_2, firstname_3, lastname_3, } затем я выполняю операцию Beam SQL, так что вывод...

при выполнении такого теста попадание в разные исключения при каждом запуске теста. private static void testInParallelCaliciteParser() { SqlParser parser = SqlParser.create("select * from test",...

У меня есть проект, который требует использования синтаксического анализатора SQL Calcite для анализа большого количества операторов DDL, которые находятся на тяжелом диалекте MySQL. Я выделил проблему, которую можно проиллюстрировать на этом...