Questions about pyflink
Read more about pyflink
python (65.2k questions)
javascript (44.3k questions)
reactjs (22.7k questions)
java (20.8k questions)
c# (17.4k questions)
html (16.3k questions)
r (13.7k questions)
android (13k questions)
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
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
How to find any factory for identifier 'elasticsearch-7' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath
I am trying to create a pyflink application with table API and elasticsearch as sink.
from pyflink.table import TableEnvironment, EnvironmentSettings
def log_processing():
env_settings = Enviro...
kell
Votes: 0
Answers: 1
Invoking Flink stateful function using REST API
I'm writing an Apache Flink Statefun application using python. I'm looking for help/pointers to invoke existing stateful function via a REST POST/GET call.
I referred to https://github.com/apache/flin...
Himanshu
Votes: 0
Answers: 1