Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/XiangpengHao/pq-vector
/ functions
Functions
167 in github.com/XiangpengHao/pq-vector
⨍
Functions
167
◇
Types & classes
36
↓ 1 callers
Function
read_vector_at_row
( path: &Path, vector_column: &str, row: usize, )
benches/query.rs:410
↓ 1 callers
Function
recall_at_k
(ground_truth: &[Key], candidates: &[Key])
benches/query.rs:562
↓ 1 callers
Method
record_batch
(&self, batch: &RecordBatch)
src/df_vector/exec.rs:423
↓ 1 callers
Function
resolve_parquet_paths
( args: &BenchArgs, data_dir: &Path, )
benches/query.rs:309
↓ 1 callers
Method
rewrite_children
( &self, plan: Arc<dyn ExecutionPlan>, has_offset: bool, )
src/df_vector/physical.rs:93
↓ 1 callers
Function
rewrite_with_access_plans
( plan: Arc<dyn ExecutionPlan>, access_plans: &HashMap<String, ParquetAccessPlan>, )
src/df_vector/access.rs:65
↓ 1 callers
Function
row_to_scalar_values
(batch: &RecordBatch, row: usize)
src/df_vector/exec.rs:486
↓ 1 callers
Function
sample_embeddings
( embeddings: &Embeddings, sample_size: usize, seed: u64, )
src/ivf/index.rs:222
↓ 1 callers
Function
scalar_to_f32_list
(value: &ScalarValue)
src/df_vector/expr.rs:8
↓ 1 callers
Method
search
(self)
src/ivf/search.rs:76
↓ 1 callers
Method
statistics
(&self)
src/df_vector/exec.rs:400
↓ 1 callers
Function
topk
( parquet_path: &Path, query: &[f32], k: NonZeroUsize, nprobe: NonZeroUsize, )
src/ivf/search.rs:83
↓ 1 callers
Method
topk_from_batches
( &self, batches: Vec<RecordBatch>, metrics: &VectorTopKMetricHandles, )
src/df_vector/exec.rs:257
↓ 1 callers
Function
update_topk_heap
( heap: &mut BinaryHeap<TopKRow>, batch: &RecordBatch, vector_idx: usize, query: &[f32], k
src/df_vector/exec.rs:457
↓ 1 callers
Method
vector_column_index
(&self)
src/df_vector/exec.rs:247
↓ 1 callers
Function
write_parquet_with_index
(plan: ParquetWritePlan<'_>)
src/ivf/parquet.rs:316
Method
as_any
(&self)
src/df_vector/index_exec.rs:228
Method
as_u32
(self)
src/ivf/mod.rs:67
Method
children
(&self)
src/df_vector/index_exec.rs:240
Method
default
()
src/df_vector/options.rs:13
Method
eq
(&self, other: &Self)
src/ivf/search.rs:19
Method
eq
(&self, other: &Self)
src/df_vector/exec.rs:436
Method
execute
( &self, partition: usize, context: Arc<TaskContext>, )
src/df_vector/exec.rs:377
Method
execute
( &self, partition: usize, context: Arc<TaskContext>, )
src/df_vector/index_exec.rs:256
Method
fmt
(&self, f: &mut fmt::Formatter<'_>)
src/df_vector/exec.rs:297
Method
fmt
(&self, f: &mut fmt::Formatter<'_>)
src/df_vector/index_exec.rs:192
Method
fmt_as
(&self, t: DisplayFormatType, f: &mut fmt::Formatter<'_>)
src/df_vector/exec.rs:303
Method
fmt_as
(&self, t: DisplayFormatType, f: &mut fmt::Formatter<'_>)
src/df_vector/index_exec.rs:198
Method
from_bytes
(bytes: &[u8])
src/ivf/index.rs:85
Method
from_env
()
benches/query.rs:215
Method
from_str
(value: &str)
benches/query.rs:293
Function
main
()
benches/index_build.rs:19
Function
main
()
benches/query.rs:34
Function
main
()
examples/topk_search.rs:18
Function
main
()
examples/datafusion_sql.rs:20
Function
main
()
examples/build_index.rs:13
Method
max_iters
(mut self, max_iters: usize)
src/ivf/parquet.rs:47
Method
metrics
(&self)
src/df_vector/index_exec.rs:274
Method
name
(&self)
src/df_vector/index_exec.rs:224
Method
new
(name: impl Into<String>)
src/ivf/mod.rs:22
Method
new
(count: usize)
src/ivf/index.rs:21
Method
new
(source: impl AsRef<Path>, embedding_column: impl AsRef<str>)
src/ivf/parquet.rs:32
Method
new
(parquet_path: impl AsRef<Path>, query: &'a [f32])
src/ivf/search.rs:57
Method
new
(metrics: &ExecutionPlanMetricsSet, partition: usize)
src/df_vector/exec.rs:412
Method
new
Create a new optimizer rule.
src/df_vector/physical.rs:28
Method
new
( files: Vec<ScanFile>, vector_column: String, query: Vec<f32>, options: Vecto
src/df_vector/index_exec.rs:53
Method
new
(file_count: usize)
src/df_vector/access.rs:200
Method
new_inner
( index_plan: Arc<dyn ExecutionPlan>, scan_plan: Arc<dyn ExecutionPlan>, vector_column
src/df_vector/exec.rs:52
Method
optimize
( &self, plan: Arc<dyn ExecutionPlan>, _config: &ConfigOptions, )
src/df_vector/physical.rs:181
Method
properties
(&self)
src/df_vector/exec.rs:343
Method
properties
(&self)
src/df_vector/index_exec.rs:232
Method
required_input_distribution
(&self)
src/df_vector/exec.rs:347
Method
required_input_distribution
(&self)
src/df_vector/index_exec.rs:236
Method
schema_check
(&self)
src/df_vector/physical.rs:193
Method
seed
(mut self, seed: u64)
src/ivf/parquet.rs:52
Method
statistics
(&self)
src/df_vector/index_exec.rs:278
Function
test_build_index_inplace_appends_footer
()
src/ivf/parquet.rs:624
Function
test_index_serialization
()
src/ivf/index.rs:496
Function
test_squared_l2_distance
()
src/ivf/index.rs:488
Function
to_mb
(bytes: u64)
benches/bench_util.rs:80
Method
try_from
(value: &str)
src/ivf/mod.rs:38
Method
try_from
(value: usize)
src/ivf/index.rs:40
Method
try_new
( scan_plan: Arc<dyn ExecutionPlan>, vector_column: String, query: Vec<f32>, k
src/df_vector/exec.rs:81
Function
vector_topk_applies_filters_after_candidate_pruning
()
src/df_vector/tests.rs:152
Function
vector_topk_end_to_end
()
src/df_vector/tests.rs:17
Function
vector_topk_vldb_tree_snapshot
()
src/df_vector/tests.rs:107
Method
with_new_children
( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )
src/df_vector/index_exec.rs:244
← previous
101–167 of 167, ranked by callers