RealTimeModeAllowlist¶

Check Allowed Sinks¶

checkAllowedSink(
  sink: Table,
  throwException: Boolean): Unit

checkAllowedSink...FIXME

checkAllowedSink is used when:

• DataStreamWriter is requested to start a streaming query (with RealTimeTrigger)

Allowed Sinks¶

allowedSinks: Set[String]

allowedSinks is a collection of the fully-qualified class names of the following Table sinks (Spark SQL):

• ConsoleTable
• ContinuousMemorySink
• ForeachWriterTable
• KafkaTable