Package org.machanism.machai.bindex

Class Picker

java.lang.Object

org.machanism.machai.bindex.Picker

All Implemented Interfaces:

Closeable, AutoCloseable

public class Picker
extends Object
implements Closeable

Picker handles Bindex registration, lookup, and semantic queries using embeddings and MongoDB.

Provides registration and query operations for Bindex repositories, supporting classification embedding for semantic retrieval and indexing.

Usage example:

 try (Picker picker = new Picker(provider)) {
        List<Bindex> results = picker.pick("search query");
 }
 

Since:

0.0.2

Author:

Viktor Tovstyi

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BINDEX_PROPERTY_NAME
static final String	DEFAULT_MIN_SCORE	Default minimum similarity score for queries.

Constructor Summary

Constructors

Constructor	Description
Picker(org.machanism.machai.ai.manager.GenAIProvider provider, String uri)	Constructs a Picker for registration and semantic search.

Method Summary

Modifier and Type	Method	Description
(package private) void	addDependencies(Set<String> dependencies, String bindexId)	Adds all transitive dependencies of a Bindex into the provided set.
void	close()	Closes the resource-backed connections.
String	create(Bindex bindex)	Registers (inserts or updates) a Bindex document for the supplied Bindex instance.
(package private) org.bson.BsonArray	getEmbeddingBson(Classification classification, Integer dimensions)	Generates a BSON array representing the embedding of a classification for semantic search.
(package private) static String	getNormalizedLanguageName(Language language)	Normalizes a Language name for semantic aggregation queries.
String	getRegistredId(Bindex bindex)	Looks up the registered database ID for a Bindex (if it exists).
Double	getScore(String id)	Retrieves similarity score for a Bindex result by its ID.
List<Bindex>	pick(String query)	Performs a semantic pick/search with a query string, retrieving Bindex results and dependencies.
void	setScore(Double score)	Manually set minimum score for semantic vector search queries.

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_MIN_SCORE

public static final String DEFAULT_MIN_SCORE

Default minimum similarity score for queries.

See Also:

• Constant Field Values

BINDEX_PROPERTY_NAME

public static final String BINDEX_PROPERTY_NAME

See Also:

• Constant Field Values

Constructor Details

Picker

public Picker(org.machanism.machai.ai.manager.GenAIProvider provider,
 String uri)

Constructs a Picker for registration and semantic search.

Parameters:

provider - GenAIProvider instance used for embedding, schema classification, etc.

uri -

Throws:

IllegalStateException - If the required environment variables are missing for DB or OpenAI access

Method Details

close

public void close()
           throws IOException

Closes the resource-backed connections.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException - if closing the MongoDB client fails

create

public String create(Bindex bindex)
              throws com.fasterxml.jackson.core.JsonProcessingException

Registers (inserts or updates) a Bindex document for the supplied Bindex instance.

Parameters:

bindex - Bindex instance to register

Returns:

Generated database ID string

Throws:

com.fasterxml.jackson.core.JsonProcessingException - If conversion to JSON string fails or MongoDB throws exception

com.mongodb.MongoCommandException - On MongoDB insert or connection errors

getEmbeddingBson

org.bson.BsonArray getEmbeddingBson(Classification classification,
 Integer dimensions)
                             throws com.fasterxml.jackson.core.JsonProcessingException

Generates a BSON array representing the embedding of a classification for semantic search.

Parameters:

classification - Classification instance

dimensions - Number of vector dimensions

Returns:

BsonArray of vector values

Throws:

com.fasterxml.jackson.core.JsonProcessingException - On embedding or serialization errors

getRegistredId

public String getRegistredId(Bindex bindex)

Looks up the registered database ID for a Bindex (if it exists).

Parameters:

bindex - Bindex instance

Returns:

String database ID, or null if not present

pick

public List<Bindex> pick(String query)
                  throws IOException

Performs a semantic pick/search with a query string, retrieving Bindex results and dependencies.

Parameters:

query - Query string

Returns:

List of Bindex results related to the query (and their dependencies)

Throws:

IOException - If prompt or IO operation fails

addDependencies

void addDependencies(Set<String> dependencies,
 String bindexId)

Adds all transitive dependencies of a Bindex into the provided set.

Parameters:

dependencies - HashSet of dependency IDs to accumulate

bindexId - Bindex ID to explore

getNormalizedLanguageName

static String getNormalizedLanguageName(Language language)

Normalizes a Language name for semantic aggregation queries.

Parameters:

language - Language object

Returns:

Normalized language name string

setScore

public void setScore(Double score)

Manually set minimum score for semantic vector search queries.

Parameters:

score - Minimum similarity value

getScore

public Double getScore(String id)

Retrieves similarity score for a Bindex result by its ID.

Parameters:

id - Bindex identifier

Returns:

score value for semantic result