Class WindowStore

RDF store wrapper with a possibly set size for processing RDF streams.

Index

Constructors

Properties

_done queue stepSize store stream streamInitialized streamIter windowSize?

Accessors

Methods

initStream moveWindow

Constructors

constructor

new WindowStore(
    store: Quadstore,
    stream: Stream<Quad>,
    windowSize?: number,
    stepSize?: undefined | number,
): WindowStore
Parameters
- store: Quadstore
- stream: Stream<Quad>
- OptionalwindowSize: number
- stepSize: undefined | number = ...
Returns WindowStore
- Defined in packages/core/src/lib/rdf2csvw/window-store.ts:18

Properties

`Private`_done

_done: boolean = false

`Private`queue

queue: CircularBuffer<Quad>

stepSize

stepSize: undefined | number = ...

store

store: Quadstore

`Private`stream

stream: Stream<Quad>

`Private`streamInitialized

streamInitialized: boolean = false

`Private`streamIter

streamIter: AsyncIterator<Quad>

`Optional`windowSize

windowSize?: number

Accessors

done

get done(): boolean
Returns boolean
- Defined in packages/core/src/lib/rdf2csvw/window-store.ts:13

Methods

initStream

initStream(): Promise<void>
Initializes the stream and populates the window store.

Returns Promise<void>
- Defined in packages/core/src/lib/rdf2csvw/window-store.ts:60

moveWindow

moveWindow(): Promise<[added: Quad[], removed: Quad[]]>
Advances the underlying stream by stepSize quads.

Returns Promise<[added: Quad[], removed: Quad[]]>
[array of quads added to store; array of quads removed from store]
- Defined in packages/core/src/lib/rdf2csvw/window-store.ts:33