Struct PageRank 

pub struct PageRank { /* private fields */ }

PageRank centrality kernel.

Calculates PageRank centrality using power iteration with teleportation. This is a Ring kernel for low-latency queries after graph is loaded.

Implementations

impl PageRank

pub fn new() -> Self

Create a new PageRank kernel.

pub fn initialize(&self, graph: CsrGraph, damping: f32)

Initialize the kernel with a graph for Ring mode operations.

pub fn query_score(&self, node_id: u64) -> Option<f64>

Query the score for a specific node.

pub fn current_iteration(&self) -> u32

Get current iteration count.

pub fn is_converged(&self) -> bool

Check if converged.

pub fn iterate(&self) -> f64

Perform one iteration step using internal state.

pub fn iterate_step(state: &mut PageRankState) -> f64

Perform one iteration of PageRank on the given state.

pub fn initialize_state(graph: CsrGraph, damping: f32) -> PageRankState

Initialize state for a graph.

pub fn run_to_convergence( graph: CsrGraph, damping: f32, max_iterations: u32, threshold: f64, ) -> Result<CentralityResult>

Run PageRank to convergence.

impl PageRank

PageRank can be used in both batch and ring modes. This is the batch mode implementation.

pub async fn compute_batch( &self, graph: CsrGraph, damping: f32, max_iterations: u32, threshold: f64, ) -> Result<CentralityResult>

Execute PageRank as a batch operation.

Convenience method that runs the algorithm to convergence.

Trait Implementations

impl BatchKernel<CentralityInput, CentralityOutput> for PageRank

fn execute<'life0, 'async_trait>( &'life0 self, input: CentralityInput, ) -> Pin<Box<dyn Future<Output = Result<CentralityOutput>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the kernel with the given input.

fn validate_input(&self, _input: &I) -> Result<(), KernelError>

Validate the input before execution.

impl Clone for PageRank

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PageRank

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

Formats the value using the given formatter.

impl Default for PageRank

fn default() -> Self

Returns the “default value” for a type.

impl GpuKernel for PageRank

fn metadata(&self) -> &KernelMetadata

Returns the kernel metadata.

fn validate(&self) -> Result<(), KernelError>

Validate kernel configuration.

fn id(&self) -> &str

Returns the kernel ID.

fn requires_gpu_native(&self) -> bool

Returns true if this kernel requires GPU-native execution.

impl RingKernelHandler<K2KBarrier, K2KBarrierRelease> for PageRank

RingKernelHandler for K2K barrier synchronization.

Implements barrier synchronization for distributed PageRank iterations.

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, msg: K2KBarrier, ) -> Pin<Box<dyn Future<Output = Result<K2KBarrierRelease>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle an incoming message.

fn initialize<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, ) -> Pin<Box<dyn Future<Output = Result<(), KernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Initialize the kernel state.

fn shutdown<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, ) -> Pin<Box<dyn Future<Output = Result<(), KernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Called when the kernel is being shut down.

impl RingKernelHandler<K2KIterationSync, K2KIterationSyncResponse> for PageRank

RingKernelHandler for K2K iteration synchronization.

Used in distributed PageRank to synchronize iterations across partitions. In a single-instance setting, this validates the worker’s iteration state and returns convergence status based on the reported delta.

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, msg: K2KIterationSync, ) -> Pin<Box<dyn Future<Output = Result<K2KIterationSyncResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle an incoming message.

fn initialize<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, ) -> Pin<Box<dyn Future<Output = Result<(), KernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Initialize the kernel state.

fn shutdown<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, ) -> Pin<Box<dyn Future<Output = Result<(), KernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Called when the kernel is being shut down.

impl RingKernelHandler<PageRankConvergeRing, PageRankConvergeResponse> for PageRank

RingKernelHandler for PageRank convergence.

Runs PageRank to convergence using K2K coordination for iterative state.

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, msg: PageRankConvergeRing, ) -> Pin<Box<dyn Future<Output = Result<PageRankConvergeResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle an incoming message.

fn initialize<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, ) -> Pin<Box<dyn Future<Output = Result<(), KernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Initialize the kernel state.

fn shutdown<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, ) -> Pin<Box<dyn Future<Output = Result<(), KernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Called when the kernel is being shut down.

impl RingKernelHandler<PageRankIterateRing, PageRankIterateResponse> for PageRank

RingKernelHandler for PageRank single iteration.

Performs one power iteration step in Ring mode.

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, msg: PageRankIterateRing, ) -> Pin<Box<dyn Future<Output = Result<PageRankIterateResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle an incoming message.

fn initialize<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, ) -> Pin<Box<dyn Future<Output = Result<(), KernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Initialize the kernel state.

fn shutdown<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, ) -> Pin<Box<dyn Future<Output = Result<(), KernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Called when the kernel is being shut down.

impl RingKernelHandler<PageRankQueryRing, PageRankQueryResponse> for PageRank

RingKernelHandler for PageRank queries.

Enables low-latency score queries for individual nodes in Ring mode.

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, msg: PageRankQueryRing, ) -> Pin<Box<dyn Future<Output = Result<PageRankQueryResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle an incoming message.

fn initialize<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, ) -> Pin<Box<dyn Future<Output = Result<(), KernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Initialize the kernel state.

fn shutdown<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 mut RingContext<'_>, ) -> Pin<Box<dyn Future<Output = Result<(), KernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sync + 'async_trait,

Called when the kernel is being shut down.