Skip to content

MemoryStreamBaseClass¶

MemoryStreamBaseClass is a marker extension of the MemoryStreamBase and MicroBatchStream abstractions for memory streaming data sources for Micro-Batch Stream Processing that support Trigger.AvailableNow.

Implementations¶

Creating Instance¶

MemoryStreamBaseClass takes the following to be created:

ID (unused)
SparkSession (Spark SQL)
Number of partitions (optional; default: undefined)

Abstract Class

MemoryStreamBaseClass is an abstract class and cannot be created directly. It is created indirectly for the concrete CLASSs.