Class AggregatedStoreMemory

constructor

• new AggregatedStoreMemory(
      store: Store<Quad> | undefined,
      metadataAccumulator: (
          accumulatedMetadata: MetadataBindings,
          appendingMetadata: MetadataBindings,
      ) => Promise<MetadataBindings>,
      emitPartialCardinalities: boolean,
      dataFactory: ComunicaDataFactory,
  ): AggregatedStoreMemory

  Parameters

  • store: Store<Quad> | undefined
  • metadataAccumulator: (
        accumulatedMetadata: MetadataBindings,
        appendingMetadata: MetadataBindings,
    ) => Promise<MetadataBindings>
  • emitPartialCardinalities: boolean
  • dataFactory: ComunicaDataFactory

  Returns AggregatedStoreMemory

containedSources

ReadonlyrunningIterators

started

addAllIteratorsClosedListener

• addAllIteratorsClosedListener(listener: () => void): void

  Register a listener that will be invoked when all match iterators were closed (either through ending this store, or through external calls to .close() or .destroy() on the match iterator).

  Parameters

  • listener: () => void

    A listener.

  Returns void

addIteratorCreatedListener

• addIteratorCreatedListener(listener: () => void): void

  Register a listener that will be invoked when a new iterator is returned from match().

  Parameters

  • listener: () => void

    A listener.

  Returns void

clone

• clone(): IAggregatedStore

  Create a copy of this aggregated store. Independent of the state of the current store, the returned store is safe to use within a new query execution.

  Returns IAggregatedStore

hasRunningIterators

• hasRunningIterators(): boolean

  If iterators created during the match call are still running.

  Returns boolean

import

• import(stream: Stream): EventEmitter

  Consumes the given stream.

  The end and error events are used like described in the Stream interface. Depending on the use case, subtypes of EventEmitter or Stream are used.

  Parameters

  • stream: Stream

    The stream that will be consumed.

  Returns EventEmitter

  The resulting event emitter.

  See

  Stream

importSource

• importSource(
      url: string,
      source: IQuerySource,
      context: IActionContext,
  ): Promise<void>

  Import the given query source into the store.

  Parameters

  • url: string

    The URL of the source.

  • source: IQuerySource

    The query source.

  • context: IActionContext

    The context.

  Returns Promise<void>

match

• match(
      subject?: Term | null,
      predicate?: Term | null,
      object?: Term | null,
      graph?: Term | null,
  ): AsyncIterator<Quad>

  Parameters

  • Optionalsubject: Term | null

    The optional subject.

  • Optionalpredicate: Term | null

    The optional predicate.

  • Optionalobject: Term | null

    The optional object.

  • Optionalgraph: Term | null

    The optional graph.

  Returns AsyncIterator<Quad>

  The resulting quad stream.

removeAllIteratorsClosedListener

• removeAllIteratorsClosedListener(listener: () => void): void

  Remove the given iterators closed listener.

  Parameters

  • listener: () => void

    A listener.

  Returns void

removeIteratorCreatedListener

• removeIteratorCreatedListener(listener: () => void): void

  Remove the given iterator creation listener.

  Parameters

  • listener: () => void

    A listener.

  Returns void

setBaseMetadata

• setBaseMetadata(metadata: MetadataBindings, updateStates: boolean): void

  Update the metadata of the base iterator, from which the aggregated store is being populated.

  Parameters

  • metadata: MetadataBindings

    The metadata object.

  • updateStates: boolean

  Returns void