Functions — github.com/ShisoftResearch/Nebuchadnezzar

hub / github.com/ShisoftResearch/Nebuchadnezzar / functions

Functions2,177 in github.com/ShisoftResearch/Nebuchadnezzar

⨍ Functions 2,177◇ Types & classes 366

↓ 2,265 callersMethodunwrap

(self)

src/server/transactions/mod.rs:37

↓ 929 callersMethodclone

(&self)

src/index/full_text/shard.rs:1139

↓ 472 callersMethodto_string

(&self)

src/index/ranged/tree/btree/cell_ref.rs:92

↓ 417 callersMethodmap

(&self, input: impl Iterator<Item = I>, func: F)

src/exec/funcs/mapper/map.rs:13

↓ 270 callersMethoditer

Iterate over all (key, segment) pairs Uses bitmap for efficient iteration

src/ram/segment_list.rs:252

↓ 233 callersMethodclone

(&self)

src/index/ranged/tree/btree/cell_ref.rs:150

↓ 224 callersMethodpush

(&mut self, inst: Instruction<'a>)

src/ram/io/writer.rs:36

↓ 171 callersMethodget

(&self, id: &u32)

src/ram/schema/mod.rs:663

↓ 161 callersMethodcollect

(field: &Field, path: &mut CompressedFieldPath, out: &mut CompressedFieldPlans)

src/ram/schema/mod.rs:564

↓ 159 callersMethodinsert

Insert or update a segment at the given key (segment ID) Returns the old segment if one existed

src/ram/segment_list.rs:123

↓ 149 callersMethodlen

(&self)

src/index/entry.rs:56

↓ 139 callersMethodinsert

Insert an entry into the ranged index

src/client/ranged.rs:200

↓ 134 callersMethoddebug_only_new_schema

(&self, schema: Schema)

src/ram/schema/mod.rs:666

↓ 132 callersMethodchunks

(&self)

src/server/mod.rs:572

↓ 129 callersMethodinto_iter

(self)

src/index/entry.rs:171

↓ 119 callersMethodnew_schema_with_id

( &self, schema: Schema, )

src/client/mod.rs:516

↓ 113 callersMethodpush

( &mut self, level: usize, node: &NodeCellRef, left_node: Option<&mut NodeWrit

src/index/ranged/tree/btree/reconstruct.rs:58

↓ 111 callersMethodto_owned

(&self)

src/ram/cell.rs:423

↓ 107 callersMethodlen

Count the number of active segments Uses bitmap with population count for O(capacity/64) performance

src/ram/segment_list.rs:265

↓ 106 callersMethodwrite_cell

( &self, cell: OwnedCell, )

src/client/mod.rs:318

↓ 103 callersMethodas_slice

(&self)

src/index/entry.rs:61

↓ 101 callersMethodlen

(&self)

src/index/ranged/tree/btree/mod.rs:310

↓ 99 callersMethodlock

(&self, k: K)

src/utils/raii_mutex_table.rs:28

↓ 94 callersMethodread_cell

(&self, hash: u64)

src/ram/chunk.rs:625

↓ 90 callersMethodnext

(&mut self)

src/query/data_client/cursor.rs:45

↓ 88 callersMethodwrite_cell

(&self, cell: &mut OwnedCell)

src/ram/chunk.rs:687

↓ 79 callersMethodsegments

(&self)

src/ram/chunk.rs:1148

↓ 78 callersMethoditer

Iterate all entries: (doc_id, version, term_freq, doc_length)

src/index/full_text/shard.rs:447

↓ 77 callersMethoddata_client

(&self, members: &Vec<String>)

src/server/mod.rs:612

↓ 77 callersMethodindexed_data_client

(&self)

src/server/mod.rs:600

↓ 72 callersMethodis_empty

(&self)

src/ram/schema/mod.rs:594

↓ 61 callersMethodmeta

(&self)

src/server/mod.rs:576

↓ 59 callersMethodis_empty

(&self)

src/index/ranged/tree/btree/node.rs:43

↓ 53 callersFunctioncreate_test_server

Helper function to create a test server for ranged query tests

src/query/data_client/tests.rs:525

↓ 53 callersMethodmax

()

src/index/entry.rs:71

↓ 46 callersMethodshutdown

Gracefully shutdown the server, flushing all data to disk

src/server/mod.rs:1172

↓ 44 callersMethodindexer

(&self)

src/server/mod.rs:588

↓ 44 callersMethodis_none

(&self)

src/index/ranged/tree/btree/node.rs:37

↓ 44 callersFunctionnow

()

src/ram/clock.rs:27

↓ 42 callersMethodto_vec

(&self, len: usize)

src/index/ranged/tree/btree/internal.rs:98

↓ 40 callersMethodnext

TODO: Copy current after next

src/index/ranged/tree/btree/cursor.rs:207

↓ 39 callersMethodarchive

archive this segment and write the data to backup storage Backup files are opened on demand and closed immediately after use

src/ram/segs.rs:540

↓ 39 callersFunctiondefault_fields

()

src/ram/tests/mod.rs:18

↓ 38 callersMethodchunks

(&self)

src/server/transactions/data_site.rs:233

↓ 38 callersFunctionsetup_test_schema

()

src/ram/recovery.rs:1167

↓ 33 callersMethodas_slice_immute

(&self)

src/index/ranged/trees.rs:10

↓ 33 callersMethodbegin

(&self)

src/server/transactions/manager.rs:367

↓ 30 callersMethodid

(&self)

src/server/database.rs:88

↓ 29 callersMethodinsert

(&self, hash_id: &Id, cell_id: &Id)

src/index/hash/mod.rs:357

↓ 29 callersMethodwrite

(&self, addr: usize)

src/ram/tombstone.rs:31

↓ 28 callersMethodid

(&self)

src/index/ranged/sm.rs:162

↓ 28 callersMethodread

/////////////////////// STARTING IMPL RPC CALLS// ///////////////////////

src/server/transactions/manager.rs:194

↓ 27 callersFunctionalign_address_with_ty

(ty: Type, addr: usize)

↓ 27 callersMethodresponse_with

(&self, data: T)

src/server/transactions/data_site.rs:225

↓ 26 callersMethodquery_ids

( &'a self, schema: u32, selection: Expr, ordering: QueryOrdering, )

src/query/data_client.rs:445

↓ 26 callersMethodwrite_undo_entry

Write an undo entry to the log

src/server/transactions/undo_log.rs:338

↓ 25 callersMethodrecover

Recover undo log from disk on startup Returns a HashMap of incomplete transactions for rollback

src/server/transactions/undo_log.rs:819

↓ 24 callersFunctioncreate_entry_key

(schema_id: u32, field: u64, feature_value: u64, id: Id)

src/index/ranged/tree/service_test.rs:15

↓ 24 callersMethodinsert

Insert an entry into the tree

src/index/ranged/tree/tree.rs:176

↓ 23 callersMethodcount

(&self)

src/ram/schema/mod.rs:691

↓ 23 callersMethodis_default

(&self)

src/index/ranged/tree/btree/cell_ref.rs:88

↓ 23 callersMethodquery_ids_with_options

( &'a self, schema: u32, selection: Expr, ordering: QueryOrdering, ord

src/query/data_client.rs:468

↓ 22 callersMethodadd_document

Add a document to the index Writes posting lists to the SAME Chunk as the document (based on partition). This ensures data locality - document and it

src/index/full_text/shard.rs:561

↓ 22 callersMethoddistributed_search

Search across all partitions and aggregate results This provides a unified BM25 search interface that: 1. Queries all nodes in parallel 2. Collects l

src/index/full_text/coordinator.rs:90

↓ 22 callersMethodensure_indices

Ensure indices are properly set for a cell

src/index/builder.rs:414

↓ 22 callersMethodis_hot

(&self)

src/ram/segs.rs:909

↓ 21 callersFunctiondefault_fields

Helper to create default test fields

src/ram/tiered/tests.rs:34

↓ 21 callersMethodinsert

( &self, _cell_id: &Id, _schema_id: u32, _field_id: u64, _metric_encod

src/query/data_client/tests.rs:46

↓ 21 callersMethodinto_iter

(self)

src/exec/funcs/reducer/mod.rs:43

↓ 21 callersMethodis_cold

(&self)

src/ram/segs.rs:919

↓ 20 callersMethodcmp

(field: AlignField, op: AlignOp, value: u64)

src/query/data_client/alignment_tests.rs:120

↓ 20 callersMethodfulltext_indexer

Get the inverted indexer if initialized

src/index/mod.rs:101

↓ 20 callersFunctionis_symbol_named

(expr: &Expr, name: &str)

src/query/planner/expr.rs:1510

↓ 19 callersMethodbackup_path

Generate backup file path for a segment

src/ram/file_manager.rs:60

↓ 19 callersMethodcurrent

TODO: Use copied key reference

src/index/ranged/tree/btree/cursor.rs:216

↓ 19 callersMethoddatabase_name

(&self)

src/client/mod.rs:122

↓ 19 callersMethodgroup_name

(&self)

src/client/mod.rs:126

↓ 19 callersMethodseek

Seek to a position in the tree

src/index/ranged/tree/tree.rs:211

↓ 19 callersFunctiontemp_raft_dir

()

src/ram/recovery.rs:1225

↓ 19 callersMethodupdate

( &self, tid: TxnId, cell: OwnedCell, )

src/server/transactions/manager.rs:432

↓ 18 callersMethodcontains_key

Check if a segment exists at the given key

src/ram/segment_list.rs:203

↓ 18 callersFunctionwait_until_updated

()

src/index/ranged/tree/btree/storage.rs:128

↓ 17 callersFunctioncreate_test_cell

(schema_id: u32, id: &Id, name: &str, score: u64)

src/ram/tests/chunk.rs:1297

↓ 17 callersMethodkeys

(&self)

src/index/ranged/tree/btree/node.rs:101

↓ 17 callersMethodread

(addr: usize)

src/ram/tombstone.rs:56

↓ 16 callersMethodbm25_search

Search using BM25 by iterating ALL Chunks on this server Each Chunk has its own posting lists for terms in documents stored in that Chunk. We iterate

src/index/full_text/shard.rs:778

↓ 16 callersMethodcleaner

(&self)

src/server/mod.rs:584

↓ 16 callersFunctiondefault_cell

(id: &Id)

src/ram/recovery.rs:1152

↓ 16 callersMethodinsert

(&self, key: &EntryKey)

src/index/ranged/tree/btree/mod.rs:202

↓ 16 callersMethodprepare

(&self, tid: TxnId)

src/server/transactions/manager.rs:311

↓ 16 callersMethodrange_index_scan

( &'a self, schema: u32, field: u64, range: ValueRange, projection: Ve

src/query/data_client.rs:175

↓ 16 callersMethodstop

(&self)

src/ram/cleaner/mod.rs:210

↓ 15 callersMethodadd_index

(&self, cell_id: &Id, index_id: &Id)

src/index/hash/mod.rs:51

↓ 15 callersFunctionbuild_indexed_predicate_plan

( schema: &Schema, selection: &Expr, schema_stats: Option<&SchemaStatistics>, order_by_field:

src/query/planner/expr.rs:234

↓ 15 callersMethodclear

Non-atomic

src/index/ranged/tree/btree/mod.rs:126

↓ 15 callersMethodget_field_stats

Get field statistics from memory, loading from disk if not found

src/index/full_text/shard.rs:679

↓ 15 callersMethodget_ptr

(&self)

src/ram/chunk.rs:1986

↓ 15 callersMethodget_root

(&self)

src/index/ranged/tree/btree/mod.rs:178

↓ 15 callersMethodnext

Get the next document ID

src/client/ranged.rs:238

next →1–100 of 2,177, ranked by callers