Abstract
Actor-specific join options.
bus
Readonly
beforeActor that must be registered in the bus before this actor.
Readonly
busThe bus this actor subscribes to.
Protected
Readonly
canIf this actor can handle undefs in the bindings.
If this actor will be logged in the debugger and physical query plan logger
Protected
Readonly
limitCan 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
limitIf true, the limitEntries field is a lower limit, otherwise, it is an upper limit.
Readonly
logicalReadonly
mediatorReadonly
nameThe name for this actor.
{<rdf:subject>}
Readonly
physicalHelper function to create a new metadata object for the join result. For required metadata entries that are not provided, sane defaults are calculated.
Join entries.
Metadata of the join entries.
The action context.
Partial metadata entries.
Protected
getOptional
data: (() => any)Protected
Abstract
getCalculate the join coefficients.
Join action
Array of resolved metadata objects.
The join coefficient estimates.
Protected
Abstract
getReturns the resulting output for joining the given entries. This is called after removing the trivial cases in run.
Protected
logOptional
data: (() => any)Protected
logOptional
data: (() => any)Protected
logOptional
data: (() => any)Protected
logOptional
data: (() => any)Protected
logOptional
data: (() => any)Protected
logOptional
data: (() => any)Returns default input for 0 or 1 entries. Calls the getOutput function otherwise
A bindings result.
Run the given action on this actor AND invokes the Bus#onRun method.
The action to run.
A promise that resolves to the run result.
Default test function for join actors. Checks whether all iterators have metadata. If yes: call the abstract getIterations method, if not: return Infinity.
The input action containing the relevant iterators
The join coefficients.
Static
getGet the estimated number of items from the given metadata.
A metadata object.
The estimated number of items, or Infinity
if cardinality is falsy.
Static
getGet the logger from the given context.
An optional context.
The logger or undefined.
Static
getObtain the join entries witt metadata from all given join entries.
Join entries.
Static
getObtain the metadata from all given join entries.
Join entries.
Static
getCalculate the time to initiate a request for the given metadata entries.
An array of checked metadata.
Static
getCalculate the time to receive a single item for the given metadata entries.
An array of checked metadata.
Static
hashStatic
joinStatic
joinReturns the variables that will occur in the joined bindings.
An array of metadata objects for the entries.
An array of joined variables.
Static
overlappingReturns an array containing all the variable names that occur in all bindings streams.
An array of optional metadata objects for the entries.
An array of variables.
Static
sortOrder the given join entries using the join-entries-sort bus.
A mediator for sorting join entries.
An array of join entries.
The action context.
The sorted join entries.
A comunica actor for joining 2 binding streams.
Actor types:
See