Package app.ductape.sdk.warehouse.executor.joins

Class WarehouseSemanticJoinExecutor

java.lang.Object

app.ductape.sdk.warehouse.executor.joins.WarehouseSemanticJoinExecutor

public final class WarehouseSemanticJoinExecutor
extends Object

TS parity: sdk/ts/src/warehouse/executor/joins/semantic-join.ts

Constructor Summary

Constructors

Constructor	Description
WarehouseSemanticJoinExecutor(VectorDatabaseService vectorService)
WarehouseSemanticJoinExecutor(VectorDatabaseService vectorService, WarehouseTypes.TextEmbedder embedFn)
WarehouseSemanticJoinExecutor(VectorDatabaseService vectorService, WarehouseTypes.TextEmbedder embedFn, boolean parallelSemanticBatch)
WarehouseSemanticJoinExecutor(VectorDatabaseService vectorService, WarehouseTypes.TextEmbedder embedFn, WarehouseTypes.AsyncTextEmbedder asyncEmbedFn, boolean parallelSemanticBatch)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	execute(List<Map<String,Object>> left, Map<String,Object> joinClause, String leftAlias, String env, String product)
Map<String,Object>	executeBatch(List<Map<String,Object>> left, Map<String,Object> joinClause, String leftAlias, String env, String product, int batchSize)	TS parity: SemanticJoinExecutor.executeBatch — slices left rows; embedding errors yield empty matches (TS returns null embeddings without throwing for text missing embedFn).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WarehouseSemanticJoinExecutor

public WarehouseSemanticJoinExecutor(VectorDatabaseService vectorService)

WarehouseSemanticJoinExecutor

public WarehouseSemanticJoinExecutor(VectorDatabaseService vectorService,
 WarehouseTypes.TextEmbedder embedFn)

WarehouseSemanticJoinExecutor

public WarehouseSemanticJoinExecutor(VectorDatabaseService vectorService,
 WarehouseTypes.TextEmbedder embedFn,
 boolean parallelSemanticBatch)

WarehouseSemanticJoinExecutor

public WarehouseSemanticJoinExecutor(VectorDatabaseService vectorService,
 WarehouseTypes.TextEmbedder embedFn,
 WarehouseTypes.AsyncTextEmbedder asyncEmbedFn,
 boolean parallelSemanticBatch)

Method Details

execute

public Map<String,Object> execute(List<Map<String,Object>> left,
 Map<String,Object> joinClause,
 String leftAlias,
 String env,
 String product)

executeBatch

public Map<String,Object> executeBatch(List<Map<String,Object>> left,
 Map<String,Object> joinClause,
 String leftAlias,
 String env,
 String product,
 int batchSize)

TS parity: SemanticJoinExecutor.executeBatch — slices left rows; embedding errors yield empty matches (TS returns null embeddings without throwing for text missing embedFn).