Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,8 @@ graphframes page-rank \

Vertices must contain an Int64 `id` column; edges must contain Int64 `src` and `dst` columns. If your input uses different names, map them with `--id-col-name`, `--src-col-name`, and `--dst-col-name`. The input format defaults to parquet; `--format csv` and `--format json` are also available.

String keys are also accepted: if `id`/`src`/`dst` are string columns, the CLI remaps them to synthetic Int64 ids (Spark's `monotonically_increasing_id`-style partition stamping via `from_string_ids`) and keeps the original values in an `origin_id` column of the vertices output.

Two input-adjacent flags exist: `--symmetrize` adds the reverse of every edge
after loading (for algorithms defined on undirected graphs whose input stores
each edge only once, e.g. LDBC undirected datasets — note that PageRank is
Expand Down
1 change: 1 addition & 0 deletions src/expressions.rs
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ mod linalg;
mod most_common;

pub(crate) use common::as_f32_list_like;
pub(crate) use common::downcast_int64;
pub(crate) use finite_axpb::{axpb, finite_axpb};
pub(crate) use hll::{hll_long, hll_long_aggregate, hll_long_estimate, hll_long_union};
pub(crate) use kcore_merge::kcore_merge_expr;
Expand Down
Loading
Loading