org.xeslite.external

Class XFactoryExternalStore

java.lang.Object

org.xeslite.external.XFactoryExternalStore

All Implemented Interfaces:

org.deckfour.xes.factory.XFactory

Direct Known Subclasses:

XFactoryExternalStore, XFactoryExternalStore.InMemoryStoreAlignmentAwareImpl, XFactoryExternalStore.InMemoryStoreImpl, XFactoryExternalStore.MapDBDiskImpl

public abstract class XFactoryExternalStore
extends java.lang.Object
implements org.deckfour.xes.factory.XFactory

Factory storing attributes of XAttributable XES objects in a, possibly external, ExternalStore. This implementation stores attributes of XEvent, XTrace objects in a ExternalStore either on a file-backed storage or a memory-backed storage.

Use one of the embedded sub-classes in this class to create a version that fits your needs:

• XFactoryExternalStore.MapDBDiskImpl
• XFactoryExternalStore.MapDBDiskWithoutCacheImpl
• XFactoryExternalStore.MapDBDiskSequentialAccessImpl
• XFactoryExternalStore.InMemoryStoreImpl

PLEASE NOTE: Attributes are generally immutable in this implementation, as they may be serialized and re-created at any time.

Author:

F. Mannhardt

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	XFactoryExternalStore.InMemoryStoreAlignmentAwareImpl Specialized implementation for storing aligned logs.
static class	XFactoryExternalStore.InMemoryStoreImpl A XES factory that stores the attributes in an optimized column-format in the heap memory.
static class	XFactoryExternalStore.MapDBDiskImpl A XES Factory that stores XAttributes with MapDB on disk.
static class	XFactoryExternalStore.MapDBDiskSequentialAccessImpl A XES Factory that stores XAttributes with MapDB on disk.
static class	XFactoryExternalStore.MapDBDiskSequentialAccessWithoutCacheImpl Deprecated.
static class	XFactoryExternalStore.MapDBDiskWithoutCacheImpl A XES Factory that stores XAttributes with MapDB on disk.

Constructor Summary

Constructors

Constructor and Description
XFactoryExternalStore()

Method Summary

Modifier and Type	Method and Description
void	commit()
static boolean	containsFactory(java.lang.Class<? extends XFactoryExternalStore> clazz)
org.deckfour.xes.model.XAttributeBoolean	createAttributeBoolean(java.lang.String key, boolean value, org.deckfour.xes.extension.XExtension extension)
org.deckfour.xes.model.XAttributeContainer	createAttributeContainer(java.lang.String key, org.deckfour.xes.extension.XExtension extension)
org.deckfour.xes.model.XAttributeContinuous	createAttributeContinuous(java.lang.String key, double value, org.deckfour.xes.extension.XExtension extension)
org.deckfour.xes.model.XAttributeDiscrete	createAttributeDiscrete(java.lang.String key, long value, org.deckfour.xes.extension.XExtension extension)
org.deckfour.xes.model.XAttributeID	createAttributeID(java.lang.String key, org.deckfour.xes.id.XID value, org.deckfour.xes.extension.XExtension extension)
org.deckfour.xes.model.XAttributeList	createAttributeList(java.lang.String key, org.deckfour.xes.extension.XExtension extension)
org.deckfour.xes.model.XAttributeLiteral	createAttributeLiteral(java.lang.String key, java.lang.String value, org.deckfour.xes.extension.XExtension extension)
org.deckfour.xes.model.XAttributeMap	createAttributeMap()
org.deckfour.xes.model.XAttributeTimestamp	createAttributeTimestamp(java.lang.String key, java.util.Date value, org.deckfour.xes.extension.XExtension extension)
org.deckfour.xes.model.XAttributeTimestamp	createAttributeTimestamp(java.lang.String key, long millis, org.deckfour.xes.extension.XExtension extension)
org.deckfour.xes.model.XEvent	createEvent()
org.deckfour.xes.model.XEvent	createEvent(org.deckfour.xes.model.XAttributeMap attributes)
org.deckfour.xes.model.XEvent	createEvent(org.deckfour.xes.id.XID id, org.deckfour.xes.model.XAttributeMap attributes)
org.deckfour.xes.model.XLog	createLog()
org.deckfour.xes.model.XLog	createLog(java.util.Collection<org.deckfour.xes.model.XTrace> traces)
org.deckfour.xes.model.XLog	createLog(org.deckfour.xes.model.XAttributeMap attributes)
org.deckfour.xes.factory.XFactory	createPumpTransferFactory()
org.deckfour.xes.model.XTrace	createTrace()
org.deckfour.xes.model.XTrace	createTrace(java.util.Collection<org.deckfour.xes.model.XEvent> events)
org.deckfour.xes.model.XTrace	createTrace(org.deckfour.xes.model.XAttributeMap attributes)
void	dispose()
void	finishPump()
protected java.util.List<org.deckfour.xes.model.XAttribute>	getAttributeList(org.deckfour.xes.model.XAttributable attributable)
java.lang.String	getAuthor()
protected abstract ExternalStore	getStore()
java.net.URI	getUri()
java.lang.String	getVendor()
protected java.lang.Integer	intern(java.lang.String key)
boolean	isPumping()
org.deckfour.xes.model.XLog	loadLogStructure()
org.deckfour.xes.model.XEvent	pumpEvent(org.deckfour.xes.model.XEvent pumpEvent)
org.deckfour.xes.model.XLog	pumpLog(org.deckfour.xes.model.XLog pumpLog)
org.deckfour.xes.model.XTrace	pumpTrace(org.deckfour.xes.model.XTrace pumpTrace)
void	saveLogStructure(org.deckfour.xes.model.XLog log)
void	startPump()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.deckfour.xes.factory.XFactory

getDescription, getName

Constructor Detail

XFactoryExternalStore

public XFactoryExternalStore()

Method Detail

getStore

protected abstract ExternalStore getStore()

containsFactory

public static boolean containsFactory(java.lang.Class<? extends XFactoryExternalStore> clazz)

intern

protected java.lang.Integer intern(java.lang.String key)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getAuthor

public java.lang.String getAuthor()

Specified by:

getAuthor in interface org.deckfour.xes.factory.XFactory

getUri

public java.net.URI getUri()

Specified by:

getUri in interface org.deckfour.xes.factory.XFactory

getVendor

public java.lang.String getVendor()

Specified by:

getVendor in interface org.deckfour.xes.factory.XFactory

createLog

public org.deckfour.xes.model.XLog createLog()

Specified by:

createLog in interface org.deckfour.xes.factory.XFactory

createLog

public org.deckfour.xes.model.XLog createLog(org.deckfour.xes.model.XAttributeMap attributes)

Specified by:

createLog in interface org.deckfour.xes.factory.XFactory

createLog

public org.deckfour.xes.model.XLog createLog(java.util.Collection<org.deckfour.xes.model.XTrace> traces)

createTrace

public org.deckfour.xes.model.XTrace createTrace()

Specified by:

createTrace in interface org.deckfour.xes.factory.XFactory

createTrace

public org.deckfour.xes.model.XTrace createTrace(java.util.Collection<org.deckfour.xes.model.XEvent> events)

createTrace

public org.deckfour.xes.model.XTrace createTrace(org.deckfour.xes.model.XAttributeMap attributes)

Specified by:

createTrace in interface org.deckfour.xes.factory.XFactory

createEvent

public org.deckfour.xes.model.XEvent createEvent()

Specified by:

createEvent in interface org.deckfour.xes.factory.XFactory

createEvent

public org.deckfour.xes.model.XEvent createEvent(org.deckfour.xes.model.XAttributeMap attributes)

Specified by:

createEvent in interface org.deckfour.xes.factory.XFactory

createEvent

public org.deckfour.xes.model.XEvent createEvent(org.deckfour.xes.id.XID id,
                                                 org.deckfour.xes.model.XAttributeMap attributes)

Specified by:

createEvent in interface org.deckfour.xes.factory.XFactory

createAttributeMap

public org.deckfour.xes.model.XAttributeMap createAttributeMap()

Specified by:

createAttributeMap in interface org.deckfour.xes.factory.XFactory

createAttributeBoolean

public org.deckfour.xes.model.XAttributeBoolean createAttributeBoolean(java.lang.String key,
                                                                       boolean value,
                                                                       org.deckfour.xes.extension.XExtension extension)

Specified by:

createAttributeBoolean in interface org.deckfour.xes.factory.XFactory

createAttributeContinuous

public org.deckfour.xes.model.XAttributeContinuous createAttributeContinuous(java.lang.String key,
                                                                             double value,
                                                                             org.deckfour.xes.extension.XExtension extension)

Specified by:

createAttributeContinuous in interface org.deckfour.xes.factory.XFactory

createAttributeDiscrete

public org.deckfour.xes.model.XAttributeDiscrete createAttributeDiscrete(java.lang.String key,
                                                                         long value,
                                                                         org.deckfour.xes.extension.XExtension extension)

Specified by:

createAttributeDiscrete in interface org.deckfour.xes.factory.XFactory

createAttributeLiteral

public org.deckfour.xes.model.XAttributeLiteral createAttributeLiteral(java.lang.String key,
                                                                       java.lang.String value,
                                                                       org.deckfour.xes.extension.XExtension extension)

Specified by:

createAttributeLiteral in interface org.deckfour.xes.factory.XFactory

createAttributeTimestamp

public org.deckfour.xes.model.XAttributeTimestamp createAttributeTimestamp(java.lang.String key,
                                                                           java.util.Date value,
                                                                           org.deckfour.xes.extension.XExtension extension)

Specified by:

createAttributeTimestamp in interface org.deckfour.xes.factory.XFactory

createAttributeTimestamp

public org.deckfour.xes.model.XAttributeTimestamp createAttributeTimestamp(java.lang.String key,
                                                                           long millis,
                                                                           org.deckfour.xes.extension.XExtension extension)

Specified by:

createAttributeTimestamp in interface org.deckfour.xes.factory.XFactory

createAttributeID

public org.deckfour.xes.model.XAttributeID createAttributeID(java.lang.String key,
                                                             org.deckfour.xes.id.XID value,
                                                             org.deckfour.xes.extension.XExtension extension)

Specified by:

createAttributeID in interface org.deckfour.xes.factory.XFactory

createAttributeContainer

public org.deckfour.xes.model.XAttributeContainer createAttributeContainer(java.lang.String key,
                                                                           org.deckfour.xes.extension.XExtension extension)

Specified by:

createAttributeContainer in interface org.deckfour.xes.factory.XFactory

createAttributeList

public org.deckfour.xes.model.XAttributeList createAttributeList(java.lang.String key,
                                                                 org.deckfour.xes.extension.XExtension extension)

Specified by:

createAttributeList in interface org.deckfour.xes.factory.XFactory

startPump

public void startPump()

isPumping

public boolean isPumping()

pumpEvent

public org.deckfour.xes.model.XEvent pumpEvent(org.deckfour.xes.model.XEvent pumpEvent)

pumpTrace

public org.deckfour.xes.model.XTrace pumpTrace(org.deckfour.xes.model.XTrace pumpTrace)

pumpLog

public org.deckfour.xes.model.XLog pumpLog(org.deckfour.xes.model.XLog pumpLog)

getAttributeList

protected java.util.List<org.deckfour.xes.model.XAttribute> getAttributeList(org.deckfour.xes.model.XAttributable attributable)

finishPump

public void finishPump()
                throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

createPumpTransferFactory

public org.deckfour.xes.factory.XFactory createPumpTransferFactory()

commit

public void commit()

dispose

public void dispose()

saveLogStructure

public void saveLogStructure(org.deckfour.xes.model.XLog log)

loadLogStructure

public org.deckfour.xes.model.XLog loadLogStructure()