Index A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W A a_attr (madmatcher_pro.matchflow.Feature property) accept() (madmatcher_pro.serving.BatchToServing method) add_concat_field() (madmatcher_pro.sparkly.index_config.IndexConfig method) add_field() (madmatcher_pro.sparkly.index_config.IndexConfig method) append() (madmatcher_pro.serving.RecordSpool method) appended (madmatcher_pro.serving.RecordSpool property) apply_matcher() (in module madmatcher_pro.matchflow) B b_attr (madmatcher_pro.matchflow.Feature property) batched() (in module madmatcher_pro.serving) BatchToServing (class in madmatcher_pro.serving) BlockingProgram (class in madmatcher_pro.delex.lang.program) BM25TopkPredicate (class in madmatcher_pro.delex.lang.predicate) boost_map (madmatcher_pro.sparkly.query_generator.QuerySpec property) build() (madmatcher_pro.delex.lang.predicate.Predicate method) (madmatcher_pro.matchflow.Feature method) BundleWatcher (class in madmatcher_pro.serving) C CallbackSink (class in madmatcher_pro.serving) candidates (madmatcher_pro.semantic.CandidateSource attribute) CandidateSource (class in madmatcher_pro.semantic) check_candidates() (in module madmatcher_pro.matchflow) check_embedding_store() (in module madmatcher_pro.serving) check_gold_data() (in module madmatcher_pro.matchflow) check_labeled_data() (in module madmatcher_pro.matchflow) check_once() (madmatcher_pro.serving.BundleWatcher method) check_tables() (in module madmatcher_pro.delex.utils.checks) (in module madmatcher_pro.matchflow) check_tables_auto() (in module madmatcher_pro.sparkly.utils) check_tables_manual() (in module madmatcher_pro.sparkly.utils) clear_drained() (madmatcher_pro.serving.RecordSpool method) CLILabeler (class in madmatcher_pro.matchflow) close() (madmatcher_pro.serving.BatchToServing method) (madmatcher_pro.serving.HotSwappableMatcher method) (madmatcher_pro.serving.MatcherPool method) (madmatcher_pro.serving.MicroBatchMatcher method) (madmatcher_pro.serving.ProcessMatcherPool method) (madmatcher_pro.serving.QueueSource method) (madmatcher_pro.serving.RealtimeMatcher method) (madmatcher_pro.serving.RecordSource method) (madmatcher_pro.serving.RecordSpool method) (madmatcher_pro.serving.ResidentEmbeddingStore method) (madmatcher_pro.serving.ResultSink method) close_segment() (madmatcher_pro.serving.RecordSpool method) contains() (madmatcher_pro.delex.lang.predicate.Predicate method) (madmatcher_pro.delex.lang.rule.Rule method) cosine_for_ids() (madmatcher_pro.serving.ResidentEmbeddingStore method) CosinePredicate (class in madmatcher_pro.delex.lang.predicate) create_embeddings() (in module madmatcher_pro.semantic) create_features() (in module madmatcher_pro.matchflow) create_seeds() (in module madmatcher_pro.matchflow) CsvSource (class in madmatcher_pro.serving) current (madmatcher_pro.serving.HotSwappableMatcher property) current_version (madmatcher_pro.serving.BundleWatcher property) CustomLabeler (class in madmatcher_pro.matchflow) D dashboard() (madmatcher_pro.MadMatcherSession.Builder method) DataFrameSink (class in madmatcher_pro.serving) deinit() (madmatcher_pro.delex.lang.predicate.Predicate method) dim (madmatcher_pro.semantic.EmbeddingProvider property) DittoProbeSerializer (class in madmatcher_pro.serving) DittoSerializer (class in madmatcher_pro.semantic) down_sample() (in module madmatcher_pro.matchflow) drain() (madmatcher_pro.serving.BatchToServing method) DropRule (class in madmatcher_pro.delex.lang.rule) E EditDistancePredicate (class in madmatcher_pro.delex.lang.predicate) ef_search (madmatcher_pro.semantic.SemanticQuerySpec attribute) elapsed (madmatcher_pro.serving.MatchRunStats attribute) embed() (madmatcher_pro.semantic.EmbeddingProvider method) EmbeddedSource (class in madmatcher_pro.semantic) EmbeddingProvider (class in madmatcher_pro.semantic) entropy() (madmatcher_pro.matchflow.MLModel method) ExactMatchPredicate (class in madmatcher_pro.delex.lang.predicate) execute() (madmatcher_pro.delex.execution.plan_executor.PlanExecutor method) F FanOutResultSink (class in madmatcher_pro.serving) FastEmbedProvider (class in madmatcher_pro.semantic) Feature (class in madmatcher_pro.matchflow) featurize() (in module madmatcher_pro.matchflow) featurize_one() (in module madmatcher_pro.serving) FileSystemVectorStore (class in madmatcher_pro.semantic) filter (madmatcher_pro.sparkly.query_generator.QuerySpec property) filter() (madmatcher_pro.delex.lang.predicate.Predicate method) filter_batch() (madmatcher_pro.delex.lang.predicate.Predicate method) fingerprint() (madmatcher_pro.matchflow.MLModel method) finish() (madmatcher_pro.matchflow.Labeler method) FlatCodec (class in madmatcher_pro.semantic) flush() (madmatcher_pro.MadMatcherSession method) (madmatcher_pro.serving.ResultSink method) G get_base_sim_functions() (in module madmatcher_pro.matchflow) get_base_tokenizers() (in module madmatcher_pro.matchflow) get_extra_tokenizers() (in module madmatcher_pro.matchflow) get_full_query_spec() (madmatcher_pro.sparkly.index.lucene_index.LuceneIndex method) (madmatcher_pro.sparkly.search.Searcher method) getOrCreate() (madmatcher_pro.MadMatcherSession.Builder method) GoldLabeler (class in madmatcher_pro.matchflow) H host() (madmatcher_pro.MadMatcherSession.Builder method) HotSwappableMatcher (class in madmatcher_pro.serving) HybridCosineLabeler (class in madmatcher_pro.matchflow) I imap_unordered() (madmatcher_pro.serving.MatcherPool method) (madmatcher_pro.serving.ProcessMatcherPool method) in_flight (madmatcher_pro.serving.ProcessMatcherPool property) index_component_sizes() (madmatcher_pro.delex.lang.predicate.Predicate method) index_size_in_bytes() (madmatcher_pro.delex.lang.predicate.Predicate method) indexable (madmatcher_pro.delex.lang.predicate.Predicate property) IndexConfig (class in madmatcher_pro.sparkly.index_config) IndexOptimizer (class in madmatcher_pro.sparkly.index_optimizer.index_optimizer) init() (madmatcher_pro.delex.lang.predicate.Predicate method) is_mrl (madmatcher_pro.semantic.EmbeddingProvider property) is_topk (madmatcher_pro.delex.lang.predicate.Predicate property) IterableSource (class in madmatcher_pro.serving) J JaccardPredicate (class in madmatcher_pro.delex.lang.predicate) JaroPredicate (class in madmatcher_pro.delex.lang.predicate) JaroWinklerPredicate (class in madmatcher_pro.delex.lang.predicate) K KeepRule (class in madmatcher_pro.delex.lang.rule) known_ids() (madmatcher_pro.serving.ServedState method) L label_data() (in module madmatcher_pro.matchflow) label_pair() (madmatcher_pro.matchflow.CustomLabeler method) label_pairs() (in module madmatcher_pro.matchflow) Labeler (class in madmatcher_pro.matchflow) LazyEmbedSource (class in madmatcher_pro.semantic) load() (madmatcher_pro.matchflow.Vectorizer class method) (madmatcher_pro.semantic.SemanticIndex class method) (madmatcher_pro.serving.RealtimeMatcher class method) (madmatcher_pro.serving.ResidentEmbeddingStore class method) (madmatcher_pro.serving.ServedState class method) load_dataframe() (in module madmatcher_pro.matchflow) load_features() (in module madmatcher_pro.matchflow) LuceneIndex (class in madmatcher_pro.sparkly.index.lucene_index) M madmatcher_pro.matchflow module MadMatcherSession (class in madmatcher_pro) MadMatcherSession.Builder (class in madmatcher_pro) make_index_config() (madmatcher_pro.sparkly.index_optimizer.index_optimizer.IndexOptimizer method) map() (madmatcher_pro.serving.MatcherPool method) (madmatcher_pro.serving.ProcessMatcherPool method) match() (madmatcher_pro.serving.BatchToServing method) (madmatcher_pro.serving.HotSwappableMatcher method) (madmatcher_pro.serving.MatcherPool method) (madmatcher_pro.serving.MicroBatchMatcher method) (madmatcher_pro.serving.ProcessMatcherPool method) (madmatcher_pro.serving.RealtimeMatcher method) match_batch() (madmatcher_pro.serving.RealtimeMatcher method) matcher (madmatcher_pro.serving.BatchToServing property) MatcherPool (class in madmatcher_pro.serving) matches (madmatcher_pro.serving.MatchRunStats attribute) MatchRunStats (class in madmatcher_pro.serving) MemmapVectorStore (class in madmatcher_pro.semantic) MemorySink (class in madmatcher_pro.serving) MicroBatchMatcher (class in madmatcher_pro.serving) MLModel (class in madmatcher_pro.matchflow) module madmatcher_pro.matchflow N name (madmatcher_pro.semantic.CandidateSource attribute) nan_fill (madmatcher_pro.matchflow.MLModel attribute) (madmatcher_pro.matchflow.MLModel property) nprobe (madmatcher_pro.semantic.SemanticQuerySpec attribute) O open_browser() (madmatcher_pro.MadMatcherSession.Builder method) OpenAIEmbeddingProvider (class in madmatcher_pro.semantic) optimize() (madmatcher_pro.sparkly.index_optimizer.index_optimizer.IndexOptimizer method) out_col_name() (madmatcher_pro.matchflow.Tokenizer method) OverlapCoeffPredicate (class in madmatcher_pro.delex.lang.predicate) P params_dict() (madmatcher_pro.matchflow.MLModel method) ParquetSink (class in madmatcher_pro.serving) ParquetSource (class in madmatcher_pro.serving) pending() (madmatcher_pro.serving.RecordSpool method) PlainConcatProbeSerializer (class in madmatcher_pro.serving) PlainConcatSerializer (class in madmatcher_pro.semantic) PlanExecutor (class in madmatcher_pro.delex.execution.plan_executor) port() (madmatcher_pro.MadMatcherSession.Builder method) PQCodec (class in madmatcher_pro.semantic) Predicate (class in madmatcher_pro.delex.lang.predicate) predict() (madmatcher_pro.matchflow.MLModel method) predict_with_confidence() (madmatcher_pro.matchflow.MLModel method) prediction_conf() (madmatcher_pro.matchflow.MLModel method) prep_fvs() (madmatcher_pro.matchflow.MLModel method) preprocess() (madmatcher_pro.matchflow.Feature method) preprocess_output_column() (madmatcher_pro.matchflow.Feature method) pretty_str() (madmatcher_pro.delex.lang.program.BlockingProgram method) (madmatcher_pro.delex.lang.rule.Rule method) ProbeSerializer (class in madmatcher_pro.serving) ProcessMatcherPool (class in madmatcher_pro.serving) procs (madmatcher_pro.serving.ProcessMatcherPool property) publish() (madmatcher_pro.serving.BatchToServing method) publish_bundle_version() (in module madmatcher_pro.serving) publish_feature_state() (in module madmatcher_pro.serving) publish_serving_artifacts() (in module madmatcher_pro.serving) put() (madmatcher_pro.serving.QueueSource method) Q QuerySpec (class in madmatcher_pro.sparkly.query_generator) QueueFullError QueueSource (class in madmatcher_pro.serving) R read_bundle_version() (in module madmatcher_pro.serving) RealtimeMatcher (class in madmatcher_pro.serving) reciprocal_rank_fusion() (in module madmatcher_pro.semantic) reciprocal_rank_fusion_local() (in module madmatcher_pro.serving) RecordClaimStore (class in madmatcher_pro.serving) records (madmatcher_pro.serving.MatchRunStats attribute) RecordSource (class in madmatcher_pro.serving) RecordSpool (class in madmatcher_pro.serving) recover_open_segments() (madmatcher_pro.serving.RecordSpool method) register_serializer() (in module madmatcher_pro.serving) remove_field() (madmatcher_pro.sparkly.index_config.IndexConfig method) rerank_window (madmatcher_pro.semantic.SemanticQuerySpec attribute) ResidentDelexProbe (class in madmatcher_pro.serving) ResidentEmbeddingStore (class in madmatcher_pro.serving) ResidentSemanticProbe (class in madmatcher_pro.serving) ResidentSparklyProbe (class in madmatcher_pro.serving) result (madmatcher_pro.serving.DataFrameSink property) ResultSink (class in madmatcher_pro.serving) Rule (class in madmatcher_pro.delex.lang.rule) run_chunked_search() (in module madmatcher_pro.semantic) run_matching() (in module madmatcher_pro.serving) run_matching_durable() (in module madmatcher_pro.serving) S save() (madmatcher_pro.matchflow.Vectorizer method) save_dataframe() (in module madmatcher_pro.matchflow) save_features() (in module madmatcher_pro.matchflow) scale() (madmatcher_pro.serving.MatcherPool method) (madmatcher_pro.serving.MicroBatchMatcher method) search() (madmatcher_pro.delex.lang.predicate.Predicate method) (madmatcher_pro.semantic.SemanticSearcher method) (madmatcher_pro.sparkly.search.Searcher method) search_batch() (madmatcher_pro.delex.lang.predicate.Predicate method) Searcher (class in madmatcher_pro.sparkly.search) segments() (madmatcher_pro.serving.RecordSpool method) SemanticIndex (class in madmatcher_pro.semantic) SemanticQuerySpec (class in madmatcher_pro.semantic) SemanticSearcher (class in madmatcher_pro.semantic) SentenceTransformerProvider (class in madmatcher_pro.semantic) serialize() (madmatcher_pro.serving.ResidentEmbeddingStore method) Serializer (class in madmatcher_pro.semantic) ServedState (class in madmatcher_pro.serving) SetSimPredicate (class in madmatcher_pro.delex.lang.predicate) ShardClaimStore (class in madmatcher_pro.serving) shards_done (madmatcher_pro.serving.MatchRunStats property) shards_skipped (madmatcher_pro.serving.MatchRunStats property) shrink_mrl() (in module madmatcher_pro.semantic) sim (madmatcher_pro.delex.lang.predicate.Predicate property) SKLearnModel (class in madmatcher_pro.matchflow) SmithWatermanPredicate (class in madmatcher_pro.delex.lang.predicate) source_for() (madmatcher_pro.serving.RecordSpool method) SparkMLModel (class in madmatcher_pro.matchflow) spool (madmatcher_pro.serving.BatchToServing property) SQ8Codec (class in madmatcher_pro.semantic) start() (madmatcher_pro.serving.BundleWatcher method) start_serving() (madmatcher_pro.serving.BatchToServing method) state (madmatcher_pro.serving.BatchToServing property) stop() (madmatcher_pro.MadMatcherSession method) (madmatcher_pro.serving.BundleWatcher method) streamable (madmatcher_pro.delex.lang.predicate.Predicate property) StringSimPredicate (class in madmatcher_pro.delex.lang.predicate) submit() (madmatcher_pro.serving.MatcherPool method) (madmatcher_pro.serving.MicroBatchMatcher method) (madmatcher_pro.serving.ProcessMatcherPool method) submitted (madmatcher_pro.serving.ProcessMatcherPool property) swap() (madmatcher_pro.serving.HotSwappableMatcher method) T ThresholdPredicate (class in madmatcher_pro.delex.lang.predicate) to_frame() (madmatcher_pro.serving.MemorySink method) tokenize() (madmatcher_pro.matchflow.Tokenizer method) tokenize_set() (madmatcher_pro.matchflow.Tokenizer method) tokenize_spark() (madmatcher_pro.matchflow.Tokenizer method) Tokenizer (class in madmatcher_pro.matchflow) train() (madmatcher_pro.matchflow.MLModel method) train_matcher() (in module madmatcher_pro.matchflow) trained_model (madmatcher_pro.matchflow.MLModel property) U undrained (madmatcher_pro.serving.HotSwappableMatcher property) units_done (madmatcher_pro.serving.MatchRunStats attribute) units_skipped (madmatcher_pro.serving.MatchRunStats attribute) upsert_docs() (madmatcher_pro.semantic.SemanticIndex method) (madmatcher_pro.sparkly.index.lucene_index.LuceneIndex method) url (madmatcher_pro.MadMatcherSession property) use_floats (madmatcher_pro.matchflow.MLModel attribute) (madmatcher_pro.matchflow.MLModel property) use_vectors (madmatcher_pro.matchflow.MLModel attribute) (madmatcher_pro.matchflow.MLModel property) V validate() (madmatcher_pro.delex.lang.program.BlockingProgram method) (madmatcher_pro.delex.lang.rule.DropRule method) (madmatcher_pro.delex.lang.rule.KeepRule method) Vectorizer (class in madmatcher_pro.matchflow) version (madmatcher_pro.serving.HotSwappableMatcher property) W WebUILabeler (class in madmatcher_pro.matchflow) weight (madmatcher_pro.semantic.CandidateSource attribute) workers (madmatcher_pro.serving.MatcherPool property) (madmatcher_pro.serving.MicroBatchMatcher property) write() (madmatcher_pro.serving.ResultSink method)