Package com.astrolabsoftware.FinkBrowser.Januser

Class FinkGremlinRecipies

java.lang.Object

com.Lomikel.Januser.GremlinRecipies

com.astrolabsoftware.FinkBrowser.Januser.FinkGremlinRecipies

public class FinkGremlinRecipies
extends GremlinRecipies

Fink-specific graph mutation and lifecycle recipes.

The package documentation defines the graph model, label-mirror invariant, and transaction ownership shared by this class and the Groovy traversal recipes.

Author:

J.Hrivnac

Field Summary

Fields

Modifier and Type	Field	Description
private ThreadLocal<Map<String,Vertex>>	_classificationObjects	Objects already selected or created by this thread's classification transaction.
private ThreadLocal<Boolean>	_classificationTransaction	Whether this thread's registration participates in a classification transaction.
private FinkHBaseClient	_fhclient
private String	_fhclientUrl
private static String	FINK_ANOMALY_WS
private static String	FINK_LATESTS_WS
private static String	FINK_OBJECTS_WS
private static org.apache.logging.log4j.Logger	log	Logging .

Constructor Summary

Constructors

Constructor	Description
FinkGremlinRecipies(ModifyingGremlinClient client)	Create and attach to ModifyingGremlinClient.
FinkGremlinRecipies(GraphTraversalSource g)	Create and attach to GraphTraversalSource.

Method Summary

Modifier and Type	Method	Description
void	classifySource(Classifier classifier, String objectId)	Classify object.
void	classifySource(Classifier classifier, String objectId, String hbaseUrl)	Classify object.
void	classifySources(Classifier[] classifiers, Set<String> oids, String hbaseUrl)	Classify object .
void	cleanOCol(Classifier classifier, String cls)	Clean tree under OCol.
private static String	correlationScope(String survey, String classifier, String flavor)	Build an unambiguous identity for a correlation-generation scope.
private Edge	createRegistrationEdge(Vertex ocol, Vertex object, Map<String,Object> attributes)	Create a complete registration edge or remove its partial state on failure.
FinkHBaseClient	fhclient()	Get existing FinkHBaseClient.
FinkHBaseClient	fhclient(String hbaseUrl)	Create a new FinkHBaseClient.
protected Vertex	findOCol(OCol cls)	Find the endpoint selected by the existing indexed OCol lookup.
void	generateCorrelations(Classifier... classifiers)	Generate overlaps Edges between OCol.
private void	generateCorrelationsInTransaction(Classifier... classifiers)	Generate correlations inside one caller-owned transaction.
String	hbaseUrl()	Give HBase url.
void	registerOCol(Classifier classifier, String cls, String objectId, double weight, String instancesS, String weightsS)	Register object in OCol.
void	registerOCol(Classifier classifier, String cls, String objectId, double weight, List<String> instances, List<Double> weights)	Register object in OCol.
void	registerOCol(Classifier classifier, String cls, String objectId, Map<String,?> attributes, boolean replace)	Register object in OCol.
private void	replaceRegistrationEdge(Vertex ocol, Vertex object, Map<String,Object> attributes)	Replace all parallel registrations with one fully prepared edge.
private static void	validateWeight(double weight, String description)	Validate scientific registration weights before graph mutation.

Methods inherited from class com.Lomikel.Januser.GremlinRecipies

addEdge, addEdge, addEdge, addEdge, allV, attachDataLink, checkEdge, client, commit, created, createMetaSchema, drop, g, getEdge, getOrCreate, getOrCreate, gimme, graph, rollback, supportsTransactions

Methods inherited from class java.lang.Object

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

Field Details

_fhclient

private FinkHBaseClient _fhclient

_fhclientUrl

private String _fhclientUrl

_classificationTransaction

private ThreadLocal<Boolean> _classificationTransaction

Whether this thread's registration participates in a classification transaction.

_classificationObjects

private ThreadLocal<Map<String,Vertex>> _classificationObjects

Objects already selected or created by this thread's classification transaction.

FINK_OBJECTS_WS

private static String FINK_OBJECTS_WS

FINK_LATESTS_WS

private static String FINK_LATESTS_WS

FINK_ANOMALY_WS

private static String FINK_ANOMALY_WS

log

private static org.apache.logging.log4j.Logger log

Logging .

Constructor Details

FinkGremlinRecipies

public FinkGremlinRecipies(GraphTraversalSource g)

Create and attach to GraphTraversalSource.

Parameters:

g - The attached GraphTraversalSource.

FinkGremlinRecipies

public FinkGremlinRecipies(ModifyingGremlinClient client)

Create and attach to ModifyingGremlinClient.

Parameters:

client - The attached ModifyingGremlinClient.

Method Details

classifySources

public void classifySources(Classifier[] classifiers,
 Set<String> oids,
 String hbaseUrl)
                     throws LomikelException

Classify object .

Parameters:

classifiers - The Classifiers to be used.

oids - The Set of objectIds of object to be added.

hbaseUrl - The url of HBase with alerts as ip:port:table:schema.

Throws:

LomikelException - If anything fails.

classifySource

public void classifySource(Classifier classifier,
 String objectId,
 String hbaseUrl)
                    throws LomikelException

Classify object.

Parameters:

classifier - The Classifier to be used.

objectId - The objectId of object to be added.

hbaseUrl - The url of HBase with alerts as ip:port:table:schema.

Throws:

LomikelException - If anything fails.

classifySource

public void classifySource(Classifier classifier,
 String objectId)
                    throws LomikelException

Classify object.

Parameters:

classifier - The Classifier to be used.

objectId - The objectId of object to be added.

Throws:

LomikelException - If anything fails.

registerOCol

public void registerOCol(Classifier classifier,
 String cls,
 String objectId,
 double weight,
 String instancesS,
 String weightsS)

Register object in OCol.

Parameters:

classifier - The Classifier to be used.

cls - The type (class) of OCol Vertex. It will be created if not yet exists.

objectId - The objectId of the new Source Vertex. It will be created if not yet exists.

weight - The weight of the connection. Usualy the number of Alerts of this type.

instancesS - The jd of related Alerts as strings separated by comma. Potential square brackets are removed. May be null or empty.

weightsS - The corresponding per-alert weights, separated by comma.

registerOCol

public void registerOCol(Classifier classifier,
 String cls,
 String objectId,
 double weight,
 List<String> instances,
 List<Double> weights)

Register object in OCol. Replace possible existing registration.

Parameters:

classifier - The Classifier to be used.

cls - The type (class) of OCol Vertex. It will be created if not yet exists.

objectId - The objectId of the new Source Vertex. It will be created if not yet exists.

weight - The total weight of the connection. Usualy the number of Alerts of this type.

instances - The jd of related Alerts.

weights - The weights of related Alerts.

registerOCol

public void registerOCol(Classifier classifier,
 String cls,
 String objectId,
 Map<String,?> attributes,
 boolean replace)

Register object in OCol.

Parameters:

classifier - The Classifier to be used.

cls - The type (class) of OCol Vertex. It will be created if not yet exists.

objectId - The objectId of the new Source Vertex. It will be created if not yet exists.

attributes - The additional Edge attributes.

replace - Whether to replace existing resistration.

replaceRegistrationEdge

private void replaceRegistrationEdge(Vertex ocol,
 Vertex object,
 Map<String,Object> attributes)

Replace all parallel registrations with one fully prepared edge.

createRegistrationEdge

private Edge createRegistrationEdge(Vertex ocol,
 Vertex object,
 Map<String,Object> attributes)

Create a complete registration edge or remove its partial state on failure.

validateWeight

private static void validateWeight(double weight,
 String description)

Validate scientific registration weights before graph mutation.

cleanOCol

public void cleanOCol(Classifier classifier,
 String cls)
               throws LomikelException

Clean tree under OCol. Drop alerts. Alerts are dropped even if they have other Edges.

Parameters:

classifier - The Classifier to be used. All its flavors are handled.

cls - The type (class) of OCol.

Throws:

LomikelException - If anything goes wrong.

generateCorrelations

public void generateCorrelations(Classifier... classifiers)

Generate overlaps Edges between OCol. Possibly between two Classifiers.

Parameters:

classifiers - The Classifiers to be used.

generateCorrelationsInTransaction

private void generateCorrelationsInTransaction(Classifier... classifiers)

Generate correlations inside one caller-owned transaction.

findOCol

protected Vertex findOCol(OCol cls)

Find the endpoint selected by the existing indexed OCol lookup.

Parameters:

cls - The logical OCol identity.

Returns:

The first matching physical OCol endpoint.

fhclient

public FinkHBaseClient fhclient(String hbaseUrl)
                         throws LomikelException

Create a new FinkHBaseClient. Singleton when url unchanged.

Parameters:

hbaseUrl - The HBase url as ip:port:table[:schema].

Returns:

The corresponding FinkHBaseClient, created and initialised if needed.

Throws:

LomikelException - If cannot be created.

fhclient

public FinkHBaseClient fhclient()
                         throws LomikelException

Get existing FinkHBaseClient.

Returns:

The corresponding FinkHBaseClient.

Throws:

LomikelException - If not yet created.

hbaseUrl

public String hbaseUrl()

Give HBase url.

Returns:

The HBase url as ip:port:table[:schema].

correlationScope

private static String correlationScope(String survey,
 String classifier,
 String flavor)

Build an unambiguous identity for a correlation-generation scope.