org.processmining.parquetxlog.plugins

Class ParquetReadLogInteractive

java.lang.Object

org.processmining.framework.abstractplugins.AbstractImportPlugin

org.processmining.parquetxlog.plugins.ParquetReadLogInteractive

All Implemented Interfaces:

org.processmining.framework.abstractplugins.ImportPlugin

public class ParquetReadLogInteractive
extends org.processmining.framework.abstractplugins.AbstractImportPlugin

Constructor Summary

Constructors

Constructor and Description
ParquetReadLogInteractive()

Method Summary

Modifier and Type	Method and Description
org.apache.avro.Schema	buildSchemaFromRecordAndUserSelection(org.apache.avro.generic.GenericRecord record, java.util.List<java.lang.String> selectedFields)
void	doAllTest(java.lang.String filePath)
java.util.List<java.lang.String>	getFieldsNamesFromRecord(org.apache.avro.generic.GenericRecord record)
java.lang.Object	importFile(org.processmining.framework.plugin.PluginContext context, java.io.File f)
protected java.lang.Object	importFromStream(org.processmining.framework.plugin.PluginContext context, java.io.InputStream input, java.lang.String filename, long fileSizeInBytes) This method is called by all plugin variants to do the actual importing.
static org.deckfour.xes.model.XLog	readlog_usingSchema(java.lang.String filePath, org.apache.avro.Schema schema)
org.apache.avro.generic.GenericRecord	readRecordFromFile(java.lang.String filePath)

Methods inherited from class org.processmining.framework.abstractplugins.AbstractImportPlugin

getFile, getInputStream, importFile, importFile, importFile

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetReadLogInteractive

public ParquetReadLogInteractive()

Method Detail

doAllTest

public void doAllTest(java.lang.String filePath)

getFieldsNamesFromRecord

public java.util.List<java.lang.String> getFieldsNamesFromRecord(org.apache.avro.generic.GenericRecord record)

buildSchemaFromRecordAndUserSelection

public org.apache.avro.Schema buildSchemaFromRecordAndUserSelection(org.apache.avro.generic.GenericRecord record,
                                                                    java.util.List<java.lang.String> selectedFields)

readRecordFromFile

public org.apache.avro.generic.GenericRecord readRecordFromFile(java.lang.String filePath)

readlog_usingSchema

public static org.deckfour.xes.model.XLog readlog_usingSchema(java.lang.String filePath,
                                                              org.apache.avro.Schema schema)

importFile

public java.lang.Object importFile(org.processmining.framework.plugin.PluginContext context,
                                   java.io.File f)
                            throws java.lang.Exception

Specified by:

importFile in interface org.processmining.framework.abstractplugins.ImportPlugin

Overrides:

importFile in class org.processmining.framework.abstractplugins.AbstractImportPlugin

Throws:

java.lang.Exception

importFromStream

protected java.lang.Object importFromStream(org.processmining.framework.plugin.PluginContext context,
                                            java.io.InputStream input,
                                            java.lang.String filename,
                                            long fileSizeInBytes)
                                     throws java.lang.Exception

Description copied from class: org.processmining.framework.abstractplugins.AbstractImportPlugin

This method is called by all plugin variants to do the actual importing.

Specified by:

importFromStream in class org.processmining.framework.abstractplugins.AbstractImportPlugin

Returns:

Throws:

java.lang.Exception