public class SupervisedGraphWiseModel extends GraphWiseModel<oracle.pgx.config.mllib.SupervisedGraphWiseModelConfig,oracle.pgx.api.internal.mllib.SupervisedGraphWiseModelMetadata,SupervisedGraphWiseModel>
SupervisedGraphWiseModelBuilder
for documentation of the hyperparameters.Modifier and Type | Class and Description |
---|---|
static class |
SupervisedGraphWiseModel.SupervisedGraphWiseInferenceType |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ALGORITHM_NAME |
Constructor and Description |
---|
SupervisedGraphWiseModel(PgxSession session, oracle.pgx.api.internal.Core core, java.util.function.Supplier<java.lang.String> keystorePathSupplier, java.util.function.Supplier<char[]> keystorePasswordSupplier, oracle.pgx.api.internal.mllib.ModelMetadata modelMetadata) |
SupervisedGraphWiseModel(PgxSession session, oracle.pgx.api.internal.Core core, java.util.function.Supplier<java.lang.String> keystorePathSupplier, java.util.function.Supplier<char[]> keystorePasswordSupplier, oracle.pgx.api.internal.mllib.SupervisedGraphWiseModelMetadata modelMetadata)
This constructor should never be used to get a model.
|
Modifier and Type | Method and Description |
---|---|
<ID> PgxFrame |
evaluateLabels(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
Blocking version of
evaluateLabelsAsync(PgxGraph, Iterable) . |
<ID> PgxFuture<PgxFrame> |
evaluateLabelsAsync(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
Evaluates (macro averaged) classification performance statistics for the specified vertices.
|
double |
fit(PgxGraph graph)
Blocking version of
fitAsync(PgxGraph) . |
PgxFuture<java.lang.Double> |
fitAsync(PgxGraph graph)
Trains the GraphWise model on the input graph.
|
java.util.Map<?,java.lang.Float> |
getClassWeights()
Gets the class weights
|
oracle.pgx.config.mllib.SupervisedGraphWiseModelConfig.LossFunction |
getLossFunction()
Gets the loss function
|
oracle.pgx.config.mllib.GraphWisePredictionLayerConfig[] |
getPredictionLayerConfigs()
Gets the configuration objects for the prediction layers
|
java.lang.String |
getVertexTargetPropertyName()
Gets the target property name
|
<ID> PgxFrame |
inferEmbeddings(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
Blocking version of
inferEmbeddingsAsync(PgxGraph, Iterable) . |
<ID> PgxFuture<PgxFrame> |
inferEmbeddingsAsync(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
Infers the embeddings for the specified vertices.
|
<ID> PgxFrame |
inferLabels(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
Blocking version of
inferLabelsAsync(PgxGraph, Iterable) . |
<ID> PgxFuture<PgxFrame> |
inferLabelsAsync(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
Infers the labels for the specified vertices.
|
<ID> PgxFrame |
inferLogits(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
Blocking version of
inferLogitsAsync(PgxGraph, Iterable) . |
<ID> PgxFuture<PgxFrame> |
inferLogitsAsync(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
Infers the prediction logits for the specified vertices.
|
void |
store(java.lang.String path, java.lang.String key)
Blocking version of
storeAsync(String, String) . |
void |
store(java.lang.String path, java.lang.String key, boolean overwrite)
Blocking version of
storeAsync(String, String) . |
PgxFuture<java.lang.Void> |
storeAsync(java.lang.String path, java.lang.String key)
Stores the GraphWise model in the specified path, with encryption.
|
PgxFuture<java.lang.Void> |
storeAsync(java.lang.String path, java.lang.String key, boolean overwrite)
Stores the GraphWise model in the specified path, with encryption.
|
destroy, destroyAsync, getBatchSize, getConfig, getConvLayerConfigs, getEmbeddingDim, getInputFeatureDim, getLearningRate, getNumEpochs, getSeed, getTrainingLoss, getVertexInputPropertyNames, isFitted
public static final java.lang.String ALGORITHM_NAME
public SupervisedGraphWiseModel(PgxSession session, oracle.pgx.api.internal.Core core, java.util.function.Supplier<java.lang.String> keystorePathSupplier, java.util.function.Supplier<char[]> keystorePasswordSupplier, oracle.pgx.api.internal.mllib.ModelMetadata modelMetadata)
public SupervisedGraphWiseModel(PgxSession session, oracle.pgx.api.internal.Core core, java.util.function.Supplier<java.lang.String> keystorePathSupplier, java.util.function.Supplier<char[]> keystorePasswordSupplier, oracle.pgx.api.internal.mllib.SupervisedGraphWiseModelMetadata modelMetadata)
SupervisedGraphWiseModelBuilder
instead.session
- PgxSession to which the model is connectedcore
- Core to which the model is connectedmodelMetadata
- Metadata concerning the different hyper-parameters of the GraphWise Modelpublic <ID> PgxFrame evaluateLabels(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
evaluateLabelsAsync(PgxGraph, Iterable)
. Evaluates (macro averaged) classification performance statistics for the specified vertices.public <ID> PgxFuture<PgxFrame> evaluateLabelsAsync(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
public double fit(PgxGraph graph) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
fitAsync(PgxGraph)
. Calls fitAsync(PgxGraph)
and waits for the returned PgxFuture
to complete.graph
- input graph to fit on.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Double> fitAsync(PgxGraph graph)
graph
- input graph to fit on.public java.util.Map<?,java.lang.Float> getClassWeights()
public oracle.pgx.config.mllib.SupervisedGraphWiseModelConfig.LossFunction getLossFunction()
public oracle.pgx.config.mllib.GraphWisePredictionLayerConfig[] getPredictionLayerConfigs()
public java.lang.String getVertexTargetPropertyName()
public <ID> PgxFrame inferEmbeddings(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
inferEmbeddingsAsync(PgxGraph, Iterable)
. Infers the embeddings for the specified vertices.public <ID> PgxFuture<PgxFrame> inferEmbeddingsAsync(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
public <ID> PgxFrame inferLabels(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
inferLabelsAsync(PgxGraph, Iterable)
. Infers the labels for the specified vertices.public <ID> PgxFuture<PgxFrame> inferLabelsAsync(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
public <ID> PgxFrame inferLogits(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
inferLogitsAsync(PgxGraph, Iterable)
. Infers the prediction logits for the specified vertices.public <ID> PgxFuture<PgxFrame> inferLogitsAsync(PgxGraph graph, java.lang.Iterable<PgxVertex<ID>> vertices)
public void store(java.lang.String path, java.lang.String key) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(String, String)
. Calls storeAsync(String, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public void store(java.lang.String path, java.lang.String key, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(String, String)
. Calls storeAsync(String, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Void> storeAsync(java.lang.String path, java.lang.String key)
path
- path to store the modelkey
- the encryption key, or null if no encryption should be used.public PgxFuture<java.lang.Void> storeAsync(java.lang.String path, java.lang.String key, boolean overwrite)
path
- path to store the modelkey
- the encryption key, or null if no encryption should be used.