Module xl.impl

Package de.grogra.xl.impl.base

Class GraphQueue

java.lang.Object

java.io.OutputStream

de.grogra.util.OutputQueue

de.grogra.util.HierarchicalQueue

de.grogra.xl.impl.base.GraphQueue

All Implemented Interfaces:

Queue, Closeable, DataOutput, Flushable, ObjectOutput, AutoCloseable, Executor

Direct Known Subclasses:

GraphQueueImpl, QueueImpl

public abstract class GraphQueue
extends HierarchicalQueue
implements Queue, Executor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	GraphQueue.AddEdgeDescriptor
static final class	GraphQueue.AddNodeDescriptor
static final class	GraphQueue.AddUndirectedEdgeDescriptor
static final class	GraphQueue.ConnectDescriptor
static final class	GraphQueue.DeleteEdgeDescriptor
static final class	GraphQueue.DeleteNodeDescriptor
static final class	GraphQueue.ExecuteDescriptor
protected class	GraphQueue.Processor

Nested classes/interfaces inherited from class de.grogra.util.HierarchicalQueue

HierarchicalQueue.Cursor, HierarchicalQueue.Data, HierarchicalQueue.Reader

Field Summary

Fields

Modifier and Type	Field	Description
static final GraphQueue.AddEdgeDescriptor	ADD_EDGE_DESCRIPTOR
static final GraphQueue.AddNodeDescriptor	ADD_NODE_DESCRIPTOR
static final GraphQueue.AddUndirectedEdgeDescriptor	ADD_UNDIRECTED_EDGE_DESCRIPTOR
static final GraphQueue.ConnectDescriptor	CONNECT_DESCRIPTOR
static final GraphQueue.DeleteEdgeDescriptor	DELETE_EDGE_DESCRIPTOR
static final GraphQueue.DeleteNodeDescriptor	DELETE_NODE_DESCRIPTOR
static final GraphQueue.ExecuteDescriptor	EXECUTE_DESCRIPTOR
static final QueueDescriptor	FIRST_QUEUE
static final QueueDescriptor	LAST_QUEUE

Fields inherited from class de.grogra.util.HierarchicalQueue

BEGIN_LEVEL, IS_FINISHED, ITEM_AND_BITS_MASK, ITEM_MASK, MAX_UNUSED_BIT, MIN_UNUSED_BIT, MIN_UNUSED_ITEM, NEXT_EXISTS, out

Constructor Summary

Constructors

Constructor	Description
GraphQueue(QueueDescriptor<?> descr, boolean usesObjectQueue, boolean createBackLinks)

Method Summary

Modifier and Type	Method	Description
abstract void	addEdgeBits(Object source, Object target, int edges)
abstract void	addNode(Object node)
abstract void	addUndirectedEdgeBits(Object source, Object target, int edges)
void	clear()	Clears the queue.
protected void	clearSegmentsToExcludeImpl(int[] segs)
abstract <N, P> void	connect(N source, N target, P param, Connector<N,P> redirector)
abstract void	connectAdjacent(Object start, Object end, int edges)
abstract <N> void	connectIncoming(N source, N target, Operator<N> operator)
abstract <N> void	connectOutgoing(N source, N target, Operator<N> operator)
abstract void	copyIncoming(Object source, Object target, int edges)
abstract void	copyIncoming(Object source, Object target, int edges, int copyMask, int addMask)
abstract void	copyOutgoing(Object source, Object target, int edges)
abstract void	copyOutgoing(Object source, Object target, int edges, int copyMask, int addMask)
protected abstract GraphQueue.Processor	createProcessor()
abstract void	deleteCurrentEdges(Object node, int edges, boolean outgoing)
abstract void	deleteEdgeBits(Object source, Object target, int edges)
abstract void	deleteNode(Object node)
abstract void	embedInterpretive(Object interpreted, Object start, Object end)
QueueDescriptor<?>	getDescriptor()	Returns the descriptor which was used to create this queue.
protected abstract RuntimeModel	getModel()
void	markSegment(int n)
abstract void	moveIncoming(Object source, Object target, int edges)
abstract void	moveOutgoing(Object source, Object target, int edges)
boolean	process(int[] segments)	Processes all queued tasks.
void	resetToSegment(int n)

Methods inherited from class de.grogra.util.HierarchicalQueue

beginLevel, beginSkipBlock, cloneData, createData, discardLevel, endLevel, endSkipBlock, getCursor, getData, hasItems, hasItemsInCurrentLevel, moveTo, restore, setItemSize, writeItem, writeObject, writeObjectInStream

Methods inherited from class de.grogra.util.OutputQueue

close, dump, flush, write, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeObjectInQueue, writeShort, writeUTF

Methods inherited from class java.io.OutputStream

nullOutputStream

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.DataOutput

writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.io.ObjectOutput

close, flush, write, write, write

Methods inherited from interface de.grogra.xl.impl.queues.Queue

clearSegmentsToExclude

Field Details

ADD_NODE_DESCRIPTOR

public static final GraphQueue.AddNodeDescriptor ADD_NODE_DESCRIPTOR

CONNECT_DESCRIPTOR

public static final GraphQueue.ConnectDescriptor CONNECT_DESCRIPTOR

ADD_EDGE_DESCRIPTOR

public static final GraphQueue.AddEdgeDescriptor ADD_EDGE_DESCRIPTOR

ADD_UNDIRECTED_EDGE_DESCRIPTOR

public static final GraphQueue.AddUndirectedEdgeDescriptor ADD_UNDIRECTED_EDGE_DESCRIPTOR

DELETE_EDGE_DESCRIPTOR

public static final GraphQueue.DeleteEdgeDescriptor DELETE_EDGE_DESCRIPTOR

DELETE_NODE_DESCRIPTOR

public static final GraphQueue.DeleteNodeDescriptor DELETE_NODE_DESCRIPTOR

EXECUTE_DESCRIPTOR

public static final GraphQueue.ExecuteDescriptor EXECUTE_DESCRIPTOR

FIRST_QUEUE

public static final QueueDescriptor FIRST_QUEUE

LAST_QUEUE

public static final QueueDescriptor LAST_QUEUE

Constructor Details

GraphQueue

public GraphQueue(QueueDescriptor<?> descr,
 boolean usesObjectQueue,
 boolean createBackLinks)

Method Details

getDescriptor

public QueueDescriptor<?> getDescriptor()

Description copied from interface: Queue

Returns the descriptor which was used to create this queue.

Specified by:

getDescriptor in interface Queue

Returns:

descriptor of this queue

See Also:

• QueueCollection.getQueue(QueueDescriptor)
• QueueDescriptor.createQueue(QueueCollection)

createProcessor

protected abstract GraphQueue.Processor createProcessor()

process

public boolean process(int[] segments)
                throws RuntimeModelException

Description copied from interface: Queue

Processes all queued tasks. This method is invoked by QueueCollection.process(int[]).

Specified by:

process in interface Queue

Returns:

true iff the execution of tasks resulted in modifications to the Graph

Throws:

RuntimeModelException - if some error occurs during execution

clearSegmentsToExcludeImpl

protected void clearSegmentsToExcludeImpl(int[] segs)

markSegment

public void markSegment(int n)

Specified by:

markSegment in interface Queue

resetToSegment

public void resetToSegment(int n)

Specified by:

resetToSegment in interface Queue

clear

public void clear()

Description copied from interface: Queue

Clears the queue. This is invoked by the QueueCollection in order to reuse the queue for a new transformation step.

Specified by:

clear in interface Queue

Overrides:

clear in class HierarchicalQueue

getModel

protected abstract RuntimeModel getModel()

addNode

public abstract void addNode(Object node)

addEdgeBits

public abstract void addEdgeBits(Object source,
 Object target,
 int edges)

addUndirectedEdgeBits

public abstract void addUndirectedEdgeBits(Object source,
 Object target,
 int edges)

deleteEdgeBits

public abstract void deleteEdgeBits(Object source,
 Object target,
 int edges)

deleteNode

public abstract void deleteNode(Object node)

deleteCurrentEdges

public abstract void deleteCurrentEdges(Object node,
 int edges,
 boolean outgoing)

moveIncoming

public abstract void moveIncoming(Object source,
 Object target,
 int edges)

copyIncoming

public abstract void copyIncoming(Object source,
 Object target,
 int edges)

copyIncoming

public abstract void copyIncoming(Object source,
 Object target,
 int edges,
 int copyMask,
 int addMask)

moveOutgoing

public abstract void moveOutgoing(Object source,
 Object target,
 int edges)

copyOutgoing

public abstract void copyOutgoing(Object source,
 Object target,
 int edges)

copyOutgoing

public abstract void copyOutgoing(Object source,
 Object target,
 int edges,
 int copyMask,
 int addMask)

connectIncoming

public abstract <N> void connectIncoming(N source,
 N target,
 Operator<N> operator)

connectOutgoing

public abstract <N> void connectOutgoing(N source,
 N target,
 Operator<N> operator)

connect

public abstract <N,
P> void connect(N source,
 N target,
 P param,
 Connector<N,P> redirector)

connectAdjacent

public abstract void connectAdjacent(Object start,
 Object end,
 int edges)

embedInterpretive

public abstract void embedInterpretive(Object interpreted,
 Object start,
 Object end)