oracle.pgx.api.expansion

Class AbstractGraphExpander<E extends AbstractGraphExpander<E>>

java.lang.Object

oracle.pgx.api.expansion.AbstractGraphExpander<E>

Type Parameters:

E - The expansion type.

Direct Known Subclasses:

GenericGraphExpander, PgqlViewGraphExpander

public abstract class AbstractGraphExpander<E extends AbstractGraphExpander<E>>
extends java.lang.Object

Base for graph expanders.

Constructor Summary

Constructors

Constructor and Description
AbstractGraphExpander(PartitionedGraphConfig graphConfig, PgxSession session, java.util.function.Function<oracle.pgx.api.expansion.internal.GraphExpansionConfig,PgxFuture<PgxGraph>> expansionFunction, oracle.pgx.api.subgraph.internal.KeystoreLookup keystoreLookup)

Method Summary

Modifier and Type	Method and Description
E	edgePropertiesMergingStrategy(PropertyMergeStrategy edgePropertyMergeStrategy) Set the strategy for how edge properties of duplicate elements are handled.
PgxGraph	expand() Call the expand operation and await execution.
PgxGraph	expand(java.lang.String newGraphName) Call the expand operation and await execution.
PgxFuture<PgxGraph>	expandAsync() Call the expand operation.
PgxFuture<PgxGraph>	expandAsync(java.lang.String newGraphName) Call the expand operation.
PgxGraph	expandNewSnapshot() Blocking version of expandNewSnapshotAsync().
PgxFuture<PgxGraph>	expandNewSnapshotAsync() Call the expand operation.
E	vertexPropertiesMergingStrategy(PropertyMergeStrategy vertexPropertyMergeStrategy) Set the strategy for how vertex properties of duplicate elements are handled.
E	withConfig(PartitionedGraphConfig config) Specify a graph config used to load the additional graph data.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractGraphExpander

public AbstractGraphExpander(PartitionedGraphConfig graphConfig,
                             PgxSession session,
                             java.util.function.Function<oracle.pgx.api.expansion.internal.GraphExpansionConfig,PgxFuture<PgxGraph>> expansionFunction,
                             oracle.pgx.api.subgraph.internal.KeystoreLookup keystoreLookup)

Method Detail

edgePropertiesMergingStrategy

public E edgePropertiesMergingStrategy(PropertyMergeStrategy edgePropertyMergeStrategy)

Set the strategy for how edge properties of duplicate elements are handled. The default strategy is defined by PropertyMergeStrategy.getDefault().

Parameters:

edgePropertyMergeStrategy - The edge property merge strategy.

Returns:

This expander.

expand

public PgxGraph expand()
                throws java.util.concurrent.ExecutionException,
                       java.lang.InterruptedException

Call the expand operation and await execution.

Returns:

The new graph.

Throws:

java.util.concurrent.ExecutionException - when the execution fails.

java.lang.InterruptedException - when the operation gets interrupted.

expand

public PgxGraph expand(java.lang.String newGraphName)
                throws java.util.concurrent.ExecutionException,
                       java.lang.InterruptedException

Call the expand operation and await execution.

Parameters:

newGraphName - The new graph name.

Returns:

The new graph.

Throws:

java.util.concurrent.ExecutionException - when the execution fails.

java.lang.InterruptedException - when the operation gets interrupted.

expandAsync

public PgxFuture<PgxGraph> expandAsync()

Call the expand operation.

Returns:

The new graph.

expandAsync

public PgxFuture<PgxGraph> expandAsync(java.lang.String newGraphName)

Call the expand operation.

Returns:

The new graph.

expandNewSnapshot

public PgxGraph expandNewSnapshot()
                           throws java.util.concurrent.ExecutionException,
                                  java.lang.InterruptedException

Blocking version of expandNewSnapshotAsync(). Calls the expand operation and awaits execution. This creates a new snapshot, instead of a new graph.

Returns:

The new graph.

Throws:

java.util.concurrent.ExecutionException - when the execution fails.

java.lang.InterruptedException - when the operation gets interrupted.

expandNewSnapshotAsync

public PgxFuture<PgxGraph> expandNewSnapshotAsync()

Call the expand operation. This creates a new snapshot of the base graph, instead of a new graph.

Returns:

The new graph.

vertexPropertiesMergingStrategy

public E vertexPropertiesMergingStrategy(PropertyMergeStrategy vertexPropertyMergeStrategy)

Set the strategy for how vertex properties of duplicate elements are handled. The default strategy is defined by PropertyMergeStrategy.getDefault().

Parameters:

vertexPropertyMergeStrategy - The vertex property merge strategy.

Returns:

This expander.

withConfig

public E withConfig(PartitionedGraphConfig config)

Specify a graph config used to load the additional graph data. This config will always be used instead of the config of the base graph.

Parameters:

config - The graph config.

Returns:

This expander.