org.apache.asterix.metadata.declared

Class AqlDataSource

java.lang.Object

org.apache.asterix.metadata.declared.AqlDataSource

All Implemented Interfaces:

org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId>

Direct Known Subclasses:

DatasetDataSource, FeedDataSource, LoadableDataSource

public abstract class AqlDataSource
extends Object
implements org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AqlDataSource.AqlDataSourceType

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hyracks.algebricks.core.algebra.properties.INodeDomain	domain
protected IAType[]	schemaTypes

Constructor Summary

Constructors

Constructor and Description
AqlDataSource(AqlSourceId id, String datasourceDataverse, String datasourceName, IAType itemType, AqlDataSource.AqlDataSourceType datasourceType)

Method Summary

Methods

Modifier and Type	Method and Description
void	computeFDs(List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> scanVariables, List<org.apache.hyracks.algebricks.core.algebra.properties.FunctionalDependency> fdList)
void	computeLocalStructuralProperties(List<org.apache.hyracks.algebricks.core.algebra.properties.ILocalStructuralProperty> localProps, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> variables)
String	getDatasourceDataverse()
String	getDatasourceName()
AqlDataSource.AqlDataSourceType	getDatasourceType()
abstract org.apache.hyracks.algebricks.core.algebra.properties.INodeDomain	getDomain()
AqlSourceId	getId()
IAType	getItemType()
Map<String,Serializable>	getProperties()
org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourcePropertiesProvider	getPropertiesProvider()
abstract IAType[]	getSchemaTypes()
void	setProperties(Map<String,Serializable> properties)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

schemaTypes

protected IAType[] schemaTypes

domain

protected org.apache.hyracks.algebricks.core.algebra.properties.INodeDomain domain

Constructor Detail

AqlDataSource

public AqlDataSource(AqlSourceId id,
             String datasourceDataverse,
             String datasourceName,
             IAType itemType,
             AqlDataSource.AqlDataSourceType datasourceType)
              throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Method Detail

getDatasourceDataverse

public String getDatasourceDataverse()

getDatasourceName

public String getDatasourceName()

getSchemaTypes

public abstract IAType[] getSchemaTypes()

Specified by:

getSchemaTypes in interface org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId>

getDomain

public abstract org.apache.hyracks.algebricks.core.algebra.properties.INodeDomain getDomain()

computeLocalStructuralProperties

public void computeLocalStructuralProperties(List<org.apache.hyracks.algebricks.core.algebra.properties.ILocalStructuralProperty> localProps,
                                    List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> variables)

getId

public AqlSourceId getId()

Specified by:

getId in interface org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId>

toString

public String toString()

Overrides:

toString in class Object

getPropertiesProvider

public org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourcePropertiesProvider getPropertiesProvider()

Specified by:

getPropertiesProvider in interface org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId>

computeFDs

public void computeFDs(List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> scanVariables,
              List<org.apache.hyracks.algebricks.core.algebra.properties.FunctionalDependency> fdList)

Specified by:

computeFDs in interface org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId>

getDatasourceType

public AqlDataSource.AqlDataSourceType getDatasourceType()

getProperties

public Map<String,Serializable> getProperties()

getItemType

public IAType getItemType()

setProperties

public void setProperties(Map<String,Serializable> properties)