MemorySinkBase¶

[[contract]] .MemorySinkBase Contract [cols="30m,70",options="header",width="100%"] |=== | Method | Description

| allData a| [[allData]]

[source, scala]¶

allData: Seq[Row]¶

| dataSinceBatch a| [[dataSinceBatch]]

[source, scala]¶

dataSinceBatch( sinceBatchId: Long): Seq[Row]

| latestBatchData a| [[latestBatchData]]

[source, scala]¶

latestBatchData: Seq[Row]¶

| latestBatchId a| [[latestBatchId]]

[source, scala]¶

latestBatchId: Option[Long]¶

|===

[[implementations]] .MemorySinkBases [cols="30,70",options="header",width="100%"] |=== | MemorySinkBase | Description

| MemorySink | [[MemorySink]] Streaming sink for Micro-Batch Stream Processing (based on Data Source API V1)

| MemorySinkV2 | [[MemorySinkV2]] Streaming sink for Continuous Stream Processing (based on Data Source API V2)

|===