How to use the @comunica/bus-rdf-join.ActorRdfJoin.overlappingVariables function in @comunica/bus-rdf-join
To help you get started, we’ve selected a few @comunica/bus-rdf-join examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
comunica / comunica / packages / actor-rdf-join-hash / lib / ActorRdfJoinHash.ts View on Github 
public async getOutput(action: IActionRdfJoin): Promise {
const variables = ActorRdfJoin.overlappingVariables(action);
const join = new HashJoin(
action.entries[0].bindingsStream, action.entries[1].bindingsStream,
(entry) => ActorRdfJoinHash.hash(entry, variables), ActorRdfJoin.join);
return { type: 'bindings', bindingsStream: join, variables: ActorRdfJoin.joinVariables(action) };
}public async getOutput(action: IActionRdfJoin): Promise {
const variables = ActorRdfJoin.overlappingVariables(action);
const join = new SymmetricHashJoin(
action.entries[0].bindingsStream, action.entries[1].bindingsStream,
(entry) => ActorRdfJoinSymmetricHash.hash(entry, variables), ActorRdfJoin.join);
return { type: 'bindings', bindingsStream: join, variables: ActorRdfJoin.joinVariables(action) };
}@comunica/bus-rdf-join
A comunica bus for rdf-join events.
