The rule of thumb in Beam says that all IO connectors (and other transforms)
are supported by all runners written with the same SDK by default (thanks to
Beam model).
Since both SnowflakeIO and FlinkRunner are written natively in Java, so answer
to your question is YES, SnowflakeIO should be
Hello,
As per the document on
https://beam.apache.org/documentation/io/built-in/snowflake/#running-main-command-with-pipeline-options,
I can only see DirectRunner and DataflowRunner, and I have tested the
DirectRunner which is working fine. Just wonder if it supports Flink
officially. Any
