|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object datafu.pig.linkanalysis.PageRankImpl
public class PageRankImpl
An implementation of PageRank, used by the PageRank
UDF.
It is not intended to be used directly.
Constructor Summary | |
---|---|
PageRankImpl()
|
Method Summary | |
---|---|
void |
addNode(java.lang.Integer sourceId,
java.util.ArrayList<java.util.Map<java.lang.String,java.lang.Object>> sourceEdges)
|
void |
addNode(java.lang.Integer sourceId,
java.util.ArrayList<java.util.Map<java.lang.String,java.lang.Object>> sourceEdges,
float bias)
|
void |
clear()
|
void |
commit(datafu.pig.linkanalysis.ProgressIndicator progressIndicator)
|
void |
disableDanglingNodeHandling()
Disables dangling node handling (disabled by default). |
void |
disableEdgeDiskCaching()
Disable disk caching of edges once there are too many (disabled by default). |
void |
disableNodeBiasing()
|
void |
distribute(datafu.pig.linkanalysis.ProgressIndicator progressIndicator)
|
long |
edgeCount()
|
void |
enableDanglingNodeHandling()
Enables dangling node handling (disabled by default). |
void |
enableEdgeDiskCaching()
Enable disk caching of edges once there are too many (disabled by default). |
void |
enableNodeBiasing()
|
float |
getAlpha()
Gets the page rank alpha value. |
long |
getEdgeCachingThreshold()
Gets the number of edges past which they will be cached on disk instead of in memory. |
float |
getNodeBias(int nodeId)
|
it.unimi.dsi.fastutil.ints.Int2IntMap.FastEntrySet |
getNodeIds()
|
float |
getNodeRank(int nodeId)
|
float |
getTotalRankChange()
|
void |
init()
|
void |
init(datafu.pig.linkanalysis.ProgressIndicator progressIndicator)
|
boolean |
isEdgeDiskCachingEnabled()
Gets whether edge disk caching is enabled. |
boolean |
isNodeBiasingEnabled()
|
boolean |
isUsingEdgeDiskCache()
Gets whether disk is being used to cache edges. |
float |
nextIteration()
|
float |
nextIteration(datafu.pig.linkanalysis.ProgressIndicator progressIndicator)
|
long |
nodeCount()
|
void |
setAlpha(float alpha)
Sets the page rank alpha value (default is 0.85); |
void |
setEdgeCachingThreshold(long count)
Set the number of edges past which they will be cached on disk instead of in memory. |
void |
setNodeBias(int nodeId,
float bias)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public PageRankImpl()
Method Detail |
---|
public void clear() throws java.io.IOException
java.io.IOException
public float getAlpha()
public void setAlpha(float alpha)
alpha
- public boolean isNodeBiasingEnabled()
public void enableNodeBiasing()
public void disableNodeBiasing()
public boolean isUsingEdgeDiskCache()
public void enableEdgeDiskCaching()
public void disableEdgeDiskCaching()
public boolean isEdgeDiskCachingEnabled()
public long getEdgeCachingThreshold()
public void setEdgeCachingThreshold(long count)
count
- Edge count past which caching occurspublic void enableDanglingNodeHandling()
public void disableDanglingNodeHandling()
public long nodeCount()
public long edgeCount()
public it.unimi.dsi.fastutil.ints.Int2IntMap.FastEntrySet getNodeIds()
public float getNodeRank(int nodeId)
public float getTotalRankChange()
public float getNodeBias(int nodeId)
public void setNodeBias(int nodeId, float bias)
public void addNode(java.lang.Integer sourceId, java.util.ArrayList<java.util.Map<java.lang.String,java.lang.Object>> sourceEdges) throws java.io.IOException
java.io.IOException
public void addNode(java.lang.Integer sourceId, java.util.ArrayList<java.util.Map<java.lang.String,java.lang.Object>> sourceEdges, float bias) throws java.io.IOException
java.io.IOException
public void init() throws java.io.IOException
java.io.IOException
public void init(datafu.pig.linkanalysis.ProgressIndicator progressIndicator) throws java.io.IOException
java.io.IOException
public float nextIteration(datafu.pig.linkanalysis.ProgressIndicator progressIndicator) throws java.io.IOException
java.io.IOException
public float nextIteration() throws java.io.IOException
java.io.IOException
public void distribute(datafu.pig.linkanalysis.ProgressIndicator progressIndicator) throws java.io.IOException
java.io.IOException
public void commit(datafu.pig.linkanalysis.ProgressIndicator progressIndicator)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |