Questions about flink-sql
Read more about flink-sql
python (65.1k questions)
javascript (44.2k questions)
reactjs (22.7k questions)
java (20.8k questions)
c# (17.4k questions)
html (16.3k questions)
r (13.7k questions)
android (12.9k questions)
Flink create table via table DSL
In order to create table, I use an SQL syntax like
val tableEnv = StreamTableEnvironment.create(env, settings)
tableEnv.executeSql(
"CREATE TABLE asset (smth STRING) " +
...
Sergey Postument
Votes: 0
Answers: 2
How to specify CREATE TABLE in Flink SQL when receiving data stream of non-primitive types (using PyFlink)?
A Flink SQL application receives data from an AWS Kinesis Data Stream, where the received messages are in JSON and where the schema is expressed in JSON Schema and which contains a property which is n...
John
Votes: 0
Answers: 0
Does AWS Glue Scheme Registry support being used as Flink SQL Catalog?
Does AWS Schema Registry support being used as an SQL Catalog within Flink SQLK applications? For instance, the documentation shows an example of using a Hive Catalog:
CREATE CATALOG hive WITH (
'typ...
John
Votes: 0
Answers: 1
Flink SQL behavior
I want to execute Flink SQL on batch data. (CSVs in S3)
However, I explicitly want Flink to execute my query in a streaming fashion because I think it will be faster than the batch mode.
For example, ...
bumpbump
Votes: 0
Answers: 1