RatePerMicroBatchTable¶

RatePerMicroBatchTable is a Table (Spark SQL) that SupportsRead (Spark SQL).

Creating Instance¶

RatePerMicroBatchTable takes the following to be created:

• rowsPerBatch
• numPartitions
• startTimestamp
• advanceMillisPerBatch

RatePerMicroBatchTable is created when:

• RatePerMicroBatchProvider is requested for the table

Table Capabilities¶

capabilities(): Set[TableCapability]

capabilities is exactly MICRO_BATCH_READ table capability.

Schema¶

schema(): StructType

Create ScanBuilder¶

newScanBuilder(
  options: CaseInsensitiveStringMap): ScanBuilder

newScanBuilder creates a new Scan (Spark SQL) that creates a RatePerMicroBatchStream when requested for a MicroBatchStream (Spark SQL).