Skip to content

MemoryStreamBase

MemoryStreamBase is an extension of the SparkDataStream abstraction for data streams that keep data in memory.

Contract

Adding Data

addData(
  data: A*): Offset
addData(
  data: TraversableOnce[A]): Offset

Adds new data to this memory stream (and advances the current Offset)

See MemoryStream

Implementations

Creating Instance

MemoryStreamBase takes the following to be created:

Abstract Class

MemoryStreamBase is an abstract class and cannot be created directly. It is created indirectly for the concrete MemoryStreamBases.