Я ищу Query и использую потоковую обработку для моего собственного формата.хотя я все еще проверяю, должен ли я использовать паркет, ORC, Avro или что-то еще, но этот источник демонстративно будет проприетарным.
эти данные должны анализироваться с использованием SQL (потоковая передача не в потоке).Флинк отлично подходит для этой работы - я знаю, и он будет использован.я также знаю, что flink использует Calcite для синтаксического анализа SQL.
Вопрос -
, если я реализую адаптер Calcite - который позволит мне работать и с простым JDBC, с его собственными преимуществами, независимо от Flink
или я должен использовать реализовать источник таблицы Flink?я буду демонстративно использовать flink для аналитики - но если я использую реализацию Calcite, я могу использовать JDBC-источник для таблицы Flink и при этом иметь возможность подключаться к стороннему инструменту BI.правильно?
как вы думаете, лучший подход?какой из них проще?
Мне нужно будет управлять всем форматом схемы и вводить текст в обоих случаях.