Struct FieldVersionTracker 

pub struct FieldVersionTracker { /* private fields */ }

Field version tracker for Pregel execution

Tracks version numbers for each field in the state to determine when nodes should be activated based on their trigger fields.

Implementations

impl FieldVersionTracker

pub fn new(num_fields: usize) -> FieldVersionTracker

Create a new version tracker for the given number of fields

Panics

Panics if num_fields is greater than 64 (the maximum number of fields that can be tracked in a FieldsChanged bitmask).

Examples

use juncture_core::pregel::scheduler::FieldVersionTracker;

let tracker = FieldVersionTracker::new(5);
assert_eq!(tracker.versions().len(), 5);

pub fn bump_all(&mut self, changed: &FieldsChanged)

Bump all field versions (used when state changes globally)

Examples

use juncture_core::pregel::scheduler::FieldVersionTracker;
use juncture_core::state::FieldsChanged;

let mut tracker = FieldVersionTracker::new(3);
let changed = FieldsChanged(0b101); // fields 0 and 2 changed
tracker.bump_all(&changed);
assert_eq!(tracker.get(0), 1);
assert_eq!(tracker.get(1), 0);
assert_eq!(tracker.get(2), 1);

pub fn bump(&mut self, field_idx: usize)

Bump version for a specific field

Examples

use juncture_core::pregel::scheduler::FieldVersionTracker;

let mut tracker = FieldVersionTracker::new(3);
tracker.bump(1);
assert_eq!(tracker.get(1), 1);
assert_eq!(tracker.get(0), 0);

pub fn get(&self, field_idx: usize) -> u64

Get the current version of a field

Panics

Panics if field_idx is out of bounds.

Examples

use juncture_core::pregel::scheduler::FieldVersionTracker;

let mut tracker = FieldVersionTracker::new(3);
tracker.bump(0);
assert_eq!(tracker.get(0), 1);

pub fn versions(&self) -> &[u64]

Get all field versions as a slice

Examples

use juncture_core::pregel::scheduler::FieldVersionTracker;

let tracker = FieldVersionTracker::new(3);
let versions = tracker.versions();
assert_eq!(versions, &[0, 0, 0]);

pub const fn len(&self) -> usize

Get the number of fields being tracked

Examples

use juncture_core::pregel::scheduler::FieldVersionTracker;

let tracker = FieldVersionTracker::new(5);
assert_eq!(tracker.len(), 5);

pub const fn is_empty(&self) -> bool

Check if no fields are being tracked

pub fn as_slice(&self) -> &[u64]

Get all field versions as a slice (alias for versions())

Examples

use juncture_core::pregel::scheduler::FieldVersionTracker;

let tracker = FieldVersionTracker::new(3);
assert_eq!(tracker.as_slice(), &[0, 0, 0]);

pub const fn global_max(&self) -> u64

Get the global maximum version

Examples

use juncture_core::pregel::scheduler::FieldVersionTracker;

let mut tracker = FieldVersionTracker::new(3);
tracker.bump(0);
tracker.bump(1);
assert_eq!(tracker.global_max(), 2);

Trait Implementations

impl Clone for FieldVersionTracker

fn clone(&self) -> FieldVersionTracker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FieldVersionTracker

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.