Package com.astrolabsoftware.FinkBrowser.Januser

Class FinkGremlinRecipies

java.lang.Object

com.Lomikel.Januser.GremlinRecipies

com.astrolabsoftware.FinkBrowser.Januser.FinkGremlinRecipies

public class FinkGremlinRecipies
extends GremlinRecipies

FinkGremlinRecipies provides various recipies to handle and modify Gremlin Graphs for Fink.

Author:

J.Hrivnac

Field Summary

Fields

Modifier and Type	Field	Description
private FinkHBaseClient	_fhclient
private String	_fhclientUrl
private String	_now
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.
FinkHBaseClient	fhclient()	Get existing FinkHBaseClient.
FinkHBaseClient	fhclient(String hbaseUrl)	Create a new FinkHBaseClient.
void	generateCorrelations(Classifier... classifiers)	Generate overlaps Edges between OCol.
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,String> attributes, boolean replace)	Register object in OCol.

Methods inherited from class com.Lomikel.Januser.GremlinRecipies

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

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

_now

private String _now

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.

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

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,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.

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:

classifier - The Classifiers to be used.

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].