Class ActorRdfJoinInnerMemoryBind

A comunica Multi-way Bind RDF Join Actor.

Hierarchy

ActorRdfJoin
- ActorRdfJoinInnerMemoryBind

Constructors

constructor

new ActorRdfJoinInnerMemoryBind(
args: IActorRdfJoinInnerMemoryMultiBindArgs,
): ActorRdfJoinInnerMemoryBind
Parameters
- args: IActorRdfJoinInnerMemoryMultiBindArgs
Returns ActorRdfJoinInnerMemoryBind
Overrides ActorRdfJoin.constructor
- Defined in packages/actor-rdf-join-inner-memory-bind/lib/ActorRdfJoinInnerMemoryBind.ts:46

Properties

`Readonly`beforeActors

beforeActors: Actor<
    IActionRdfJoin,
    IMediatorTypeJoinCoefficients,
    IQueryOperationResultBindings,
    IActorRdfJoinTestSideData,
>[]

Actor that must be registered in the bus before this actor.

`Readonly`bus

bus: Bus<
    Actor<
        IActionRdfJoin,
        IMediatorTypeJoinCoefficients,
        IQueryOperationResultBindings,
        IActorRdfJoinTestSideData,
    >,
    IActionRdfJoin,
    IMediatorTypeJoinCoefficients,
    IQueryOperationResultBindings,
    IActorRdfJoinTestSideData,
>

The bus this actor subscribes to.

`Protected` `Readonly`canHandleUndefs

canHandleUndefs: boolean

If this actor can handle undefs overlapping variable bindings.

includeInLogs

includeInLogs: boolean

If this actor will be logged in the debugger and physical query plan logger

`Protected` `Readonly`isLeaf

isLeaf: boolean

If this join operator will not invoke any other join or query operations below, and can therefore be considered a leaf of the join plan.

`Protected` `Readonly`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` `Readonly`limitEntriesMin

limitEntriesMin: boolean

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

`Readonly`logicalType

logicalType: LogicalJoinType

`Readonly`mediatorHashBindings

mediatorHashBindings: MediatorHashBindings

`Readonly`mediatorJoinEntriesSort

mediatorJoinEntriesSort: MediatorRdfJoinEntriesSort

`Readonly`mediatorJoinSelectivity

mediatorJoinSelectivity: MediatorRdfJoinSelectivity

`Readonly`mediatorMergeBindingsContext

mediatorMergeBindingsContext: MediatorMergeBindingsContext

`Readonly`mediatorQueryOperation

mediatorQueryOperation: MediatorQueryOperation

`Readonly`name

name: string

The name for this actor.

Default

{<rdf:subject>}

`Readonly`physicalName

physicalName: string

`Protected` `Optional` `Readonly`requiresVariableOverlap

requiresVariableOverlap?: boolean

If this join operator must only be used for join entries with (at least partially) common variables.

`Readonly`selectivityModifier

selectivityModifier: number

Methods

canBindWithOperation

canBindWithOperation(operation: Operation): boolean
Parameters
- operation: Operation
Returns boolean
- Defined in packages/actor-rdf-join-inner-memory-bind/lib/ActorRdfJoinInnerMemoryBind.ts:346

constructResultMetadata

constructResultMetadata(
    entries: IJoinEntry[],
    metadatas: MetadataBindings[],
    context: IActionContext,
    partialMetadata?: Partial<MetadataBindings>,
    optional?: boolean,
): Promise<MetadataBindings>
Helper function to create a new metadata object for the join result. For required metadata entries that are not provided, sane defaults are calculated.
Parameters
- entries: IJoinEntry[]
  Join entries.
- metadatas: MetadataBindings[]
  Metadata of the join entries.
- context: IActionContext
  The action context.
- OptionalpartialMetadata: Partial<MetadataBindings>
  Partial metadata entries.
- Optionaloptional: boolean
  If metadata for an optional operation must be calculated.
Returns Promise<MetadataBindings>
Inherited from ActorRdfJoin.constructResultMetadata
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:119

constructState

constructState(metadatas: MetadataBindings[]): MetadataValidationState
Construct a metadata validation state for the given metadata entries.
Parameters
- metadatas: MetadataBindings[]
  An array of checked metadata.
Returns MetadataValidationState
Inherited from ActorRdfJoin.constructState
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:109

`Protected`getDefaultLogData

getDefaultLogData(context: IActionContext, data?: () => any): any
Parameters
- context: IActionContext
- Optionaldata: () => any
Returns any
Inherited from ActorRdfJoin.getDefaultLogData
- Defined in node_modules/@comunica/core/lib/Actor.d.ts:69

getJoinCoefficients

getJoinCoefficients(
    action: IActionRdfJoin,
    sideData: IActorRdfJoinTestSideData,
): Promise<
    TestResult<
        IMediatorTypeJoinCoefficients,
        IActorRdfJoinMemoryMultiBindTestSideData,
    >,
>
Calculate the join coefficients.
Parameters
- action: IActionRdfJoin
  Join action
- sideData: IActorRdfJoinTestSideData
  The test side data.
Returns Promise<
    TestResult<
        IMediatorTypeJoinCoefficients,
        IActorRdfJoinMemoryMultiBindTestSideData,
    >,
>
The join coefficient estimates.
Overrides ActorRdfJoin.getJoinCoefficients
- Defined in packages/actor-rdf-join-inner-memory-bind/lib/ActorRdfJoinInnerMemoryBind.ts:362

getOutput

getOutput(
action: IActionRdfJoin,
sideData: IActorRdfJoinMemoryMultiBindTestSideData,
): Promise<IActorRdfJoinOutputInner>
Returns the resulting output for joining the given entries. This is called after removing the trivial cases in run.
Parameters
- action: IActionRdfJoin
- sideData: IActorRdfJoinMemoryMultiBindTestSideData
  Side data from the test method
Returns Promise<IActorRdfJoinOutputInner>
Overrides ActorRdfJoin.getOutput
- Defined in packages/actor-rdf-join-inner-memory-bind/lib/ActorRdfJoinInnerMemoryBind.ts:274

`Protected`logDebug

logDebug(context: IActionContext, message: string, data?: () => any): void
Parameters
- context: IActionContext
- message: string
- Optionaldata: () => any
Returns void
Inherited from ActorRdfJoin.logDebug
- Defined in node_modules/@comunica/core/lib/Actor.d.ts:71

`Protected`logError

logError(context: IActionContext, message: string, data?: () => any): void
Parameters
- context: IActionContext
- message: string
- Optionaldata: () => any
Returns void
Inherited from ActorRdfJoin.logError
- Defined in node_modules/@comunica/core/lib/Actor.d.ts:74

`Protected`logFatal

logFatal(context: IActionContext, message: string, data?: () => any): void
Parameters
- context: IActionContext
- message: string
- Optionaldata: () => any
Returns void
Inherited from ActorRdfJoin.logFatal
- Defined in node_modules/@comunica/core/lib/Actor.d.ts:75

`Protected`logInfo

logInfo(context: IActionContext, message: string, data?: () => any): void
Parameters
- context: IActionContext
- message: string
- Optionaldata: () => any
Returns void
Inherited from ActorRdfJoin.logInfo
- Defined in node_modules/@comunica/core/lib/Actor.d.ts:72

`Protected`logTrace

logTrace(context: IActionContext, message: string, data?: () => any): void
Parameters
- context: IActionContext
- message: string
- Optionaldata: () => any
Returns void
Inherited from ActorRdfJoin.logTrace
- Defined in node_modules/@comunica/core/lib/Actor.d.ts:70

`Protected`logWarn

logWarn(context: IActionContext, message: string, data?: () => any): void
Parameters
- context: IActionContext
- message: string
- Optionaldata: () => any
Returns void
Inherited from ActorRdfJoin.logWarn
- Defined in node_modules/@comunica/core/lib/Actor.d.ts:73

run

run(
action: IActionRdfJoin,
sideData: IActorRdfJoinTestSideData,
): Promise<IQueryOperationResultBindings>
Returns default input for 0 or 1 entries. Calls the getOutput function otherwise
Parameters
- action: IActionRdfJoin
- sideData: IActorRdfJoinTestSideData
  Side data from the test method
Returns Promise<IQueryOperationResultBindings>
A bindings result.
Inherited from ActorRdfJoin.run
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:142

runObservable

runObservable(
action: IActionRdfJoin,
sideData: IActorRdfJoinTestSideData,
): Promise<IQueryOperationResultBindings>
Run the given action on this actor AND invokes the Bus#onRun method.
Parameters
- action: IActionRdfJoin
  The action to run.
- sideData: IActorRdfJoinTestSideData
Returns Promise<IQueryOperationResultBindings>
A promise that resolves to the run result.
Inherited from ActorRdfJoin.runObservable
- Defined in node_modules/@comunica/core/lib/Actor.d.ts:68

sortJoinEntries

sortJoinEntries(
entries: IJoinEntryWithMetadata[],
context: IActionContext,
): Promise<TestResult<IJoinEntryWithMetadata[]>>
Order the given join entries using the join-entries-sort bus.
Parameters
- entries: IJoinEntryWithMetadata[]
  An array of join entries.
- context: IActionContext
  The action context.
Returns Promise<TestResult<IJoinEntryWithMetadata[]>>
The sorted join entries.
- Defined in packages/actor-rdf-join-inner-memory-bind/lib/ActorRdfJoinInnerMemoryBind.ts:208

test

test(
action: IActionRdfJoin,
): Promise<
TestResult<IMediatorTypeJoinCoefficients, IActorRdfJoinTestSideData>,
>
Default test function for join actors. Checks whether all iterators have metadata. If yes: call the abstract getIterations method, if not: return Infinity.
Parameters
- action: IActionRdfJoin
  The input action containing the relevant iterators
Returns Promise<TestResult<IMediatorTypeJoinCoefficients, IActorRdfJoinTestSideData>>
The join coefficients.
Inherited from ActorRdfJoin.test
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:135

`Static`createBindStream

createBindStream(
    baseStream: AsyncIterator<Bindings>,
    operations: Operation[],
    operationBinder: (
        boundOperations: Operation[],
        operationBindings: Bindings,
    ) => Promise<AsyncIterator<Bindings>>,
    optional: boolean,
    algebraFactory: Factory,
    bindingsFactory: BindingsFactory,
    hashInputBindings: (bindings: Bindings) => number,
    hashOutputBindings: (bindings: Bindings) => number,
): Promise<AsyncIterator<Bindings>>
Create a new bindings stream that takes every binding of the base stream and binds it to the remaining patterns, evaluates those patterns, and emits all their bindings.
Parameters
- baseStream: AsyncIterator<Bindings>
  The base stream.
- operations: Operation[]
  The operations to bind with each binding of the base stream.
- operationBinder: (
  boundOperations: Operation[],
  operationBindings: Bindings,
  ) => Promise<AsyncIterator<Bindings>>
  A callback to retrieve the bindings stream of bound operations.
- optional: boolean
  If the original bindings should be emitted when the resulting bindings stream is empty.
- algebraFactory: Factory
  The algebra factory.
- bindingsFactory: BindingsFactory
  The bindingsFactory created with bindings context merger.
- hashInputBindings: (bindings: Bindings) => number
- hashOutputBindings: (bindings: Bindings) => number
Returns Promise<AsyncIterator<Bindings>>
- Defined in packages/actor-rdf-join-inner-memory-bind/lib/ActorRdfJoinInnerMemoryBind.ts:68

`Static`getCardinality

getCardinality(metadata: MetadataBindings): QueryResultCardinality
Get the estimated number of items from the given metadata.
Parameters
- metadata: MetadataBindings
  A metadata object.
Returns QueryResultCardinality
The estimated number of items, or Infinity if cardinality is falsy.
Inherited from ActorRdfJoin.getCardinality
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:84

`Static`getContextLogger

getContextLogger(context: IActionContext): undefined | Logger
Get the logger from the given context.
Parameters
- context: IActionContext
  An optional context.
Returns undefined | Logger
The logger or undefined.
Inherited from ActorRdfJoin.getContextLogger
- Defined in node_modules/@comunica/core/lib/Actor.d.ts:42

`Static`getEntriesWithMetadatas

getEntriesWithMetadatas(
entries: IJoinEntry[],
): Promise<IJoinEntryWithMetadata[]>
Obtain the join entries witt metadata from all given join entries.
Parameters
- entries: IJoinEntry[]
  Join entries.
Returns Promise<IJoinEntryWithMetadata[]>
Inherited from ActorRdfJoin.getEntriesWithMetadatas
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:94

`Static`getMetadatas

getMetadatas(entries: IJoinEntry[]): Promise<MetadataBindings[]>
Obtain the metadata from all given join entries.
Parameters
- entries: IJoinEntry[]
  Join entries.
Returns Promise<MetadataBindings[]>
Inherited from ActorRdfJoin.getMetadatas
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:89

`Static`getRequestInitialTimes

getRequestInitialTimes(metadatas: MetadataBindings[]): number[]
Calculate the time to initiate a request for the given metadata entries.
Parameters
- metadatas: MetadataBindings[]
  An array of checked metadata.
Returns number[]
Inherited from ActorRdfJoin.getRequestInitialTimes
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:99

`Static`getRequestItemTimes

getRequestItemTimes(metadatas: MetadataBindings[]): number[]
Calculate the time to receive a single item for the given metadata entries.
Parameters
- metadatas: MetadataBindings[]
  An array of checked metadata.
Returns number[]
Inherited from ActorRdfJoin.getRequestItemTimes
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:104

`Static`joinBindings

joinBindings(...bindings: Bindings[]): null | Bindings
Returns the result of joining bindings, or null if no join is possible.
Parameters
- ...bindings: Bindings[]
Returns null | Bindings
Inherited from ActorRdfJoin.joinBindings
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:78

`Static`joinVariables

joinVariables(
    dataFactory: ComunicaDataFactory,
    metadatas: MetadataBindings[],
    optional?: boolean,
): MetadataVariable[]
Returns the variables that will occur in the joined bindings.
Parameters
- dataFactory: ComunicaDataFactory
  The data factory.
- metadatas: MetadataBindings[]
  An array of metadata objects for the entries.
- Optionaloptional: boolean
  If an optional join is being performed.
Returns MetadataVariable[]
An array of joined variables.
Inherited from ActorRdfJoin.joinVariables
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:72

`Static`overlappingVariables

overlappingVariables(metadatas: MetadataBindings[]): MetadataVariable[]
Returns an array containing all the variable names that occur in all bindings streams.
Parameters
- metadatas: MetadataBindings[]
  An array of optional metadata objects for the entries.
Returns MetadataVariable[]
An array of variables.
Inherited from ActorRdfJoin.overlappingVariables
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:64

`Static`sortJoinEntries

sortJoinEntries(
    mediatorJoinEntriesSort: MediatorRdfJoinEntriesSort,
    entries: IJoinEntryWithMetadata[],
    context: IActionContext,
): Promise<TestResult<IJoinEntryWithMetadata[]>>
Order the given join entries using the join-entries-sort bus.
Parameters
- mediatorJoinEntriesSort: MediatorRdfJoinEntriesSort
  A mediator for sorting join entries.
- entries: IJoinEntryWithMetadata[]
  An array of join entries.
- context: IActionContext
  The action context.
Returns Promise<TestResult<IJoinEntryWithMetadata[]>>
The sorted join entries.
Inherited from ActorRdfJoin.sortJoinEntries
- Defined in node_modules/@comunica/bus-rdf-join/lib/ActorRdfJoin.d.ts:127

Class ActorRdfJoinInnerMemoryBind

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

Returns ActorRdfJoinInnerMemoryBind

Properties

ReadonlybeforeActors

Readonlybus

Protected ReadonlycanHandleUndefs

includeInLogs

Protected ReadonlyisLeaf

Protected ReadonlylimitEntries

Protected ReadonlylimitEntriesMin

ReadonlylogicalType

ReadonlymediatorHashBindings

ReadonlymediatorJoinEntriesSort

ReadonlymediatorJoinSelectivity

ReadonlymediatorMergeBindingsContext

ReadonlymediatorQueryOperation

Readonlyname

Default

ReadonlyphysicalName

Protected Optional ReadonlyrequiresVariableOverlap

ReadonlyselectivityModifier

Methods

canBindWithOperation

Parameters

Returns boolean

constructResultMetadata

Parameters

Returns Promise<MetadataBindings>

constructState

Parameters

Returns MetadataValidationState

ProtectedgetDefaultLogData

Parameters

Returns any

getJoinCoefficients

Parameters

Returns Promise< TestResult< IMediatorTypeJoinCoefficients, IActorRdfJoinMemoryMultiBindTestSideData, >,>

getOutput

Parameters

Returns Promise<IActorRdfJoinOutputInner>

ProtectedlogDebug

Parameters

Returns void

ProtectedlogError

Parameters

Returns void

ProtectedlogFatal

Parameters

Returns void

ProtectedlogInfo

Parameters

Returns void

ProtectedlogTrace

Parameters

Returns void

ProtectedlogWarn

Parameters

Returns void

run

Parameters

Returns Promise<IQueryOperationResultBindings>

runObservable

Parameters

Returns Promise<IQueryOperationResultBindings>

sortJoinEntries

Parameters

Returns Promise<TestResult<IJoinEntryWithMetadata[]>>

test

Parameters

Returns Promise<TestResult<IMediatorTypeJoinCoefficients, IActorRdfJoinTestSideData>>

StaticcreateBindStream

Parameters

`Readonly`beforeActors

`Readonly`bus

`Protected` `Readonly`canHandleUndefs

`Protected` `Readonly`isLeaf

`Protected` `Readonly`limitEntries

`Protected` `Readonly`limitEntriesMin

`Readonly`logicalType

`Readonly`mediatorHashBindings

`Readonly`mediatorJoinEntriesSort

`Readonly`mediatorJoinSelectivity

`Readonly`mediatorMergeBindingsContext

`Readonly`mediatorQueryOperation

`Readonly`name

`Readonly`physicalName

`Protected` `Optional` `Readonly`requiresVariableOverlap

`Readonly`selectivityModifier

`Protected`getDefaultLogData

Returns Promise<
TestResult<
IMediatorTypeJoinCoefficients,
IActorRdfJoinMemoryMultiBindTestSideData,
>,
>

`Protected`logDebug

`Protected`logError

`Protected`logFatal

`Protected`logInfo

`Protected`logTrace

`Protected`logWarn

`Static`createBindStream

`Static`getCardinality

`Static`getContextLogger

`Static`getEntriesWithMetadatas

`Static`getMetadatas

`Static`getRequestInitialTimes

`Static`getRequestItemTimes

`Static`joinBindings

`Static`joinVariables

`Static`overlappingVariables

`Static`sortJoinEntries