Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ActorRdfJoin

A comunica actor for joining 2 binding streams.

Actor types:

  • Input: IActionRdfJoin: The streams that need to be joined.
  • Test:
  • Output: IActorRdfJoinOutput: The resulting joined stream.
see

IActionRdfJoin

see

IActorQueryOperationOutput

Hierarchy

Implements

Index

Constructors

constructor

Properties

Readonly beforeActors

Readonly bus

Protected canHandleUndefs

canHandleUndefs: boolean

If this actor can handle undefs in the bindings.

Protected limitEntries

limitEntries: number

Can be used by subclasses to indicate the max or min number of streams that can be joined. 0 for infinity. By default, this indicates the max number, but can be inverted by setting limitEntriesMin to true.

Protected limitEntriesMin

limitEntriesMin: boolean

If true, the limitEntries field is a lower limit, otherwise, it is an upper limit.

Readonly name

name: string

Methods

deinitialize

  • deinitialize(): Promise<any>
  • Deinitialize this actor. This should be used for cleaning up things when the application is shut down, such as closing files and removing temporary files.

    Returns Promise<any>

    A promise that resolves when the actor has been deinitialized.

Protected getDefaultLogData

  • getDefaultLogData(context: ActionContext | undefined, data?: undefined | (() => any)): any

Protected Abstract getIterations

  • Used when calculating the number of iterations in the test function. All metadata objects are guaranteed to have a value for the totalItems key.

    Parameters

    Returns Promise<number>

    The estimated number of iterations when joining the given iterators.

Protected Abstract getOutput

initialize

  • initialize(): Promise<any>
  • Initialize this actor. This should be used for doing things that take a while, such as opening files.

    Returns Promise<any>

    A promise that resolves when the actor has been initialized.

Protected logDebug

  • logDebug(context: ActionContext | undefined, message: string, data?: undefined | (() => any)): void

Protected logError

  • logError(context: ActionContext | undefined, message: string, data?: undefined | (() => any)): void

Protected logFatal

  • logFatal(context: ActionContext | undefined, message: string, data?: undefined | (() => any)): void

Protected logInfo

  • logInfo(context: ActionContext | undefined, message: string, data?: undefined | (() => any)): void

Protected logTrace

  • logTrace(context: ActionContext | undefined, message: string, data?: undefined | (() => any)): void

Protected logWarn

  • logWarn(context: ActionContext | undefined, message: string, data?: undefined | (() => any)): void

run

runObservable

test

Static getContextLogger

Static iteratorsHaveMetadata

  • iteratorsHaveMetadata(action: IActionRdfJoin, key: string): Promise<boolean>

Static join

Static joinVariables

Static overlappingVariables

Generated using TypeDoc