Edges#
- class Edges#
Bases:
object
A list of edges that can be iterated over.
Methods:
after
(start)Create a view of the Edges including all events after start (exclusive).
at
(time)Create a view of the Edges including all events at time.
before
(end)Create a view of the Edges including all events before end (exclusive).
collect
()Collect all edges into a list
count
()Returns the number of edges
Return a view of Edges containing only the default edge layer :returns: The layered view :rtype: Edges
Returns all timestamps of edges where an edge is deleted
Returns all timestamps of edges where an edge is deleted
exclude_layer
(name)Return a view of Edges containing all layers except the excluded name Errors if any of the layers do not exist.
exclude_layers
(names)Return a view of Edges containing all layers except the excluded names Errors if any of the layers do not exist.
exclude_valid_layer
(name)Return a view of Edges containing all layers except the excluded name :param name: layer name that is excluded for the new view :type name: str
exclude_valid_layers
(names)Return a view of Edges containing all layers except the excluded names :param names: list of layer names that are excluded for the new view :type names: list[str]
expanding
(step)Creates a WindowSet with the given step size using an expanding window.
explode
()Explodes returns an edge object for each update within the original edge.
Explode layers returns an edge object for each layer within the original edge.
has_layer
(name)Check if Edges has the layer "name"
history
()Returns all timestamps of edges, when an edge is added or change to an edge is made.
Returns all timestamps of edges, when an edge is added or change to an edge is made.
Check if the edges are deleted
Check if the edges are on the same node
is_valid
()Check if the edges are valid (i.e. not deleted).
latest
()Create a view of the Edges including all events at the latest time.
layer
(name)Return a view of Edges containing the layer "name" Errors if the layer does not exist
layers
(names)Return a view of Edges containing all layers names Errors if any of the layers do not exist.
rolling
(window[, step])Creates a WindowSet with the given window size and optional step using a rolling window.
shrink_end
(end)Set the end of the window to the smaller of end and self.end()
shrink_start
(start)Set the start of the window to the larger of start and self.start()
shrink_window
(start, end)Shrink both the start and end of the window (same as calling shrink_start followed by shrink_end but more efficient)
snapshot_at
(time)Create a view of the Edges including all events that have not been explicitly deleted at time.
Create a view of the Edges including all events that have not been explicitly deleted at the latest time.
to_df
([include_property_history, ...])Converts the graph's edges into a Pandas DataFrame.
valid_layers
(names)Return a view of Edges containing all layers names Any layers that do not exist are ignored
window
(start, end)Create a view of the Edges including all events between start (inclusive) and end (exclusive)
Attributes:
Returns the date times of exploded edges
Returns the destination node of the edge.
Returns the earliest date time of the edges.
Returns the earliest time of the edges.
Gets the latest time that this Edges is valid.
Gets the latest datetime that this Edges is valid
Returns all ids of the edges.
Returns the latest date time of the edges.
Returns the latest time of the edges.
Get the layer name that all edges belong to - assuming they only belong to one layer
Get the layer names that all edges belong to - assuming they only belong to one layer
Returns the node at the other end of the edge (same as dst() for out-edges and src() for in-edges)
Returns all properties of the edges
Returns the source node of the edge.
Gets the start time for rolling and expanding windows for this Edges
Gets the earliest datetime that this Edges is valid
Returns the times of exploded edges
Get the window size (difference between start and end) for this Edges
- after(start)#
Create a view of the Edges including all events after start (exclusive).
- at(time)#
Create a view of the Edges including all events at time.
- before(end)#
Create a view of the Edges including all events before end (exclusive).
- count()#
Returns the number of edges
- date_time#
Returns the date times of exploded edges
- Returns:
A list of date times.
- default_layer()#
Return a view of Edges containing only the default edge layer :returns: The layered view :rtype: Edges
- deletions()#
Returns all timestamps of edges where an edge is deleted
- Returns:
A list of lists of unix timestamps
- deletions_date_time()#
Returns all timestamps of edges where an edge is deleted
- Returns:
A list of lists of DateTime objects
- dst#
Returns the destination node of the edge.
- earliest_date_time#
Returns the earliest date time of the edges.
- Returns:
Earliest date time of the edges.
- earliest_time#
Returns the earliest time of the edges.
Returns: Earliest time of the edges.
- end#
Gets the latest time that this Edges is valid.
- end_date_time#
Gets the latest datetime that this Edges is valid
- exclude_layer(name)#
Return a view of Edges containing all layers except the excluded name Errors if any of the layers do not exist.
- exclude_layers(names)#
Return a view of Edges containing all layers except the excluded names Errors if any of the layers do not exist.
- exclude_valid_layer(name)#
Return a view of Edges containing all layers except the excluded name :param name: layer name that is excluded for the new view :type name: str
- Returns:
The layered view
- Return type:
- exclude_valid_layers(names)#
Return a view of Edges containing all layers except the excluded names :param names: list of layer names that are excluded for the new view :type names: list[str]
- Returns:
The layered view
- Return type:
- expanding(step)#
Creates a WindowSet with the given step size using an expanding window.
An expanding window is a window that grows by step size at each iteration.
- explode()#
Explodes returns an edge object for each update within the original edge.
- explode_layers()#
Explode layers returns an edge object for each layer within the original edge. These new edge object contains only updates from respective layers.
- has_layer(name)#
Check if Edges has the layer “name”
- history()#
Returns all timestamps of edges, when an edge is added or change to an edge is made.
- Returns:
A list of lists unix timestamps.
- history_counts()#
- history_date_time()#
Returns all timestamps of edges, when an edge is added or change to an edge is made.
- Returns:
A list of lists of timestamps.
- id#
Returns all ids of the edges.
- is_active()#
- is_deleted()#
Check if the edges are deleted
- is_self_loop()#
Check if the edges are on the same node
- is_valid()#
Check if the edges are valid (i.e. not deleted)
- latest_date_time#
Returns the latest date time of the edges.
- Returns:
Latest date time of the edges.
- latest_time#
Returns the latest time of the edges.
- Returns:
Latest time of the edges.
- layer(name)#
Return a view of Edges containing the layer “name” Errors if the layer does not exist
- layer_name#
Get the layer name that all edges belong to - assuming they only belong to one layer
- Returns:
The name of the layer
- layer_names#
Get the layer names that all edges belong to - assuming they only belong to one layer
- Returns:
A list of layer names
- layers(names)#
Return a view of Edges containing all layers names Errors if any of the layers do not exist.
- nbr#
Returns the node at the other end of the edge (same as dst() for out-edges and src() for in-edges)
- properties#
Returns all properties of the edges
- rolling(window, step=None)#
Creates a WindowSet with the given window size and optional step using a rolling window.
A rolling window is a window that moves forward by step size at each iteration.
- shrink_end(end)#
Set the end of the window to the smaller of end and self.end()
- shrink_start(start)#
Set the start of the window to the larger of start and self.start()
- shrink_window(start, end)#
Shrink both the start and end of the window (same as calling shrink_start followed by shrink_end but more efficient)
- snapshot_at(time)#
Create a view of the Edges including all events that have not been explicitly deleted at time.
This is equivalent to before(time + 1) for Graph and at(time) for PersistentGraph
- snapshot_latest()#
Create a view of the Edges including all events that have not been explicitly deleted at the latest time.
This is equivalent to a no-op for Graph and latest() for PersistentGraph
- Return type:
- src#
Returns the source node of the edge.
- start#
Gets the start time for rolling and expanding windows for this Edges
- start_date_time#
Gets the earliest datetime that this Edges is valid
- time#
Returns the times of exploded edges
- Returns:
Time of edge
- to_df(include_property_history=True, convert_datetime=False, explode=False)#
Converts the graph’s edges into a Pandas DataFrame.
This method will create a DataFrame with the following columns: - “src”: The source node of the edge. - “dst”: The destination node of the edge. - “layer”: The layer of the edge. - “properties”: The properties of the edge. - “update_history”: The update history of the edge. This column will be included if include_update_history is set to true.
- Parameters:
include_property_history (bool) – A boolean, if set to True, the history of each property is included, if False, only the latest value is shown. Ignored if exploded. Defaults to True.
convert_datetime (bool) – A boolean, if set to True will convert the timestamp to python datetimes. Defaults to False.
explode (bool) – A boolean, if set to True, will explode each edge update into its own row. Defaults to False.
- Returns:
If successful, this PyObject will be a Pandas DataFrame.
- Return type:
- valid_layers(names)#
Return a view of Edges containing all layers names Any layers that do not exist are ignored
- window(start, end)#
Create a view of the Edges including all events between start (inclusive) and end (exclusive)