Skip to content

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)

|===