XesLogSource (framework 0.2.4 API)

java.lang.Object
- org.apache.flink.api.common.functions.AbstractRichFunction
- - org.apache.flink.streaming.api.functions.source.RichSourceFunction<BEvent>
  - - beamline.sources.BeamlineAbstractSource
    - - beamline.sources.XesLogSource

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, org.apache.flink.streaming.api.functions.source.SourceFunction<BEvent>
```
public class XesLogSource
extends BeamlineAbstractSource
```
This implementation of a BeamlineAbstractSource produces events according to the events contained in an XLog. The events are first sorted according to their timestamp and then sent.

Author:

Andrea Burattin

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.source.SourceFunction
  org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T extends Object>

Constructor Summary

Constructors
Constructor	Description
`XesLogSource(String fileName)`	Constructs a source from the path of a log
`XesLogSource(org.deckfour.xes.model.XLog log)`	Constructs a source from the given log

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method Description

void run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<BEvent> ctx)
- Methods inherited from class beamline.sources.BeamlineAbstractSource
  cancel, isRunning
- Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction
  close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - XesLogSource
```
public XesLogSource(String fileName)
```
    Constructs a source from the path of a log
    
    Parameters:
    
    fileName - the file containing the log to use. The file can be either a file parsed by XesXmlGZIPParser or XesXmlParser (i.e., extensions .xes.gz or .xes) or any other parser currently supported by the OpenXES library.
  - XesLogSource
```
public XesLogSource(org.deckfour.xes.model.XLog log)
             throws IOException
```
    Constructs a source from the given log
    
    Parameters:
    
    log - the log to use as source
    
    Throws:
    
    IOException - an exception that might occur when a temporary file is created
- Method Detail
  - run
```
public void run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<BEvent> ctx)
         throws Exception
```
    Throws:
    
    Exception