Class MappingOpExtract<DDS extends DataObject,DC1 extends DataObject,DC2 extends DataObject,QL1 extends Query,QL2 extends Query>

java.lang.Object

se.liu.ida.hefquin.mappings.algebra.ops.BaseForMappingOperator

se.liu.ida.hefquin.mappings.algebra.ops.MappingOpExtract<DDS,DC1,DC2,QL1,QL2>

All Implemented Interfaces:

MappingOperator

Direct Known Subclasses:

MappingOpExtractJSON

public class MappingOpExtract<DDS extends DataObject,DC1 extends DataObject,DC2 extends DataObject,QL1 extends Query,QL2 extends Query>
extends BaseForMappingOperator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	MappingOpExtract.MappingRelationCreator
protected class	MappingOpExtract.MyCursor
protected class	MappingOpExtract.MyMappingRelation

Field Summary

Fields

Modifier and Type	Field	Description
protected final String[]	attributesOfP
protected final List<QL2>	queriesOfP
protected final QL1	query
protected final Set<String>	schema
protected final SourceReference	sr
protected final SourceType<DDS,DC1,DC2,QL1,QL2>	type

Fields inherited from class se.liu.ida.hefquin.mappings.algebra.ops.BaseForMappingOperator

id

Constructor Summary

Constructors

Constructor	Description
MappingOpExtract(SourceReference sr, SourceType<DDS,DC1,DC2,QL1,QL2> type, QL1 query, Map<String,QL2> P)

Method Summary

Modifier and Type	Method	Description
protected MappingRelation	createMappingRelation(DDS d, DC1 cxtObj)
protected List<org.apache.jena.graph.Node[]>	determineValuesPerAttribute(DDS d, DC1 cxtObj)	The returned list contains one array per each of the attributes in attributesOfP, where the i-th array in the list is for the i-th attribute and contains the values that have been determined by evaluating the i-th query in queriesOfP in the context of the given context object.
MappingRelation	evaluate(Map<SourceReference,DataObject> srMap)
String	getIthAttributeOfP(int i)
Iterable<QL2>	getQueriesOfP()
QL1	getQuery()
Set<String>	getSchema()
int	getSizeOfP()
SourceReference	getSourceReference()
SourceType<DDS,DC1,DC2,QL1,QL2>	getSourceType()
boolean	isValid()
boolean	isValidInput(Map<SourceReference,DataObject> srMap)
void	visit(MappingOperatorVisitor visitor)

Methods inherited from class se.liu.ida.hefquin.mappings.algebra.ops.BaseForMappingOperator

getID

Methods inherited from class java.lang.Object

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

Field Details

sr

protected final SourceReference sr

type

protected final SourceType<DDS extends DataObject,DC1 extends DataObject,DC2 extends DataObject,QL1 extends Query,QL2 extends Query> type

query

protected final QL1 extends Query query

attributesOfP

protected final String[] attributesOfP

queriesOfP

protected final List<QL2 extends Query> queriesOfP

schema

protected final Set<String> schema

Constructor Details

MappingOpExtract

public MappingOpExtract(SourceReference sr,
 SourceType<DDS,DC1,DC2,QL1,QL2> type,
 QL1 query,
 Map<String,QL2> P)

Method Details

getSourceReference

public SourceReference getSourceReference()

getSourceType

public SourceType<DDS,DC1,DC2,QL1,QL2> getSourceType()

getQuery

public QL1 getQuery()

getSizeOfP

public int getSizeOfP()

getIthAttributeOfP

public String getIthAttributeOfP(int i)

getQueriesOfP

public Iterable<QL2> getQueriesOfP()

getSchema

public Set<String> getSchema()

isValid

public boolean isValid()

visit

public void visit(MappingOperatorVisitor visitor)

isValidInput

public boolean isValidInput(Map<SourceReference,DataObject> srMap)

evaluate

public MappingRelation evaluate(Map<SourceReference,DataObject> srMap)

createMappingRelation

protected MappingRelation createMappingRelation(DDS d,
 DC1 cxtObj)

determineValuesPerAttribute

protected List<org.apache.jena.graph.Node[]> determineValuesPerAttribute(DDS d,
 DC1 cxtObj)

The returned list contains one array per each of the attributes in attributesOfP, where the i-th array in the list is for the i-th attribute and contains the values that have been determined by evaluating the i-th query in queriesOfP in the context of the given context object.