org.apache.asterix.metadata.declared

Class FeedDataSource

java.lang.Object

org.apache.asterix.metadata.declared.AqlDataSource

org.apache.asterix.metadata.declared.FeedDataSource

All Implemented Interfaces:

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

public class FeedDataSource
extends AqlDataSource

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.asterix.metadata.declared.AqlDataSource

AqlDataSource.AqlDataSourceType

Field Summary

Fields inherited from class org.apache.asterix.metadata.declared.AqlDataSource

domain, schemaTypes

Constructor Summary

Constructors

Constructor and Description
FeedDataSource(AqlSourceId id, String targetDataset, IAType itemType, AqlDataSource.AqlDataSourceType dataSourceType, FeedId sourceFeedId, Feed.FeedType sourceFeedType, IFeedLifecycleListener.ConnectionLocation location, String[] locations)

Method Summary

Methods

Modifier and Type	Method and Description
int	getComputeCardinality()
org.apache.hyracks.algebricks.core.algebra.properties.INodeDomain	getDomain()
Feed	getFeed()
IFeedLifecycleListener.ConnectionLocation	getLocation()
String[]	getLocations()
IAType[]	getSchemaTypes()
FeedId	getSourceFeedId()
Feed.FeedType	getSourceFeedType()
String	getTargetDataset()

Methods inherited from class org.apache.asterix.metadata.declared.AqlDataSource

computeFDs, computeLocalStructuralProperties, getDatasourceDataverse, getDatasourceName, getDatasourceType, getId, getItemType, getProperties, getPropertiesProvider, setProperties, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

FeedDataSource

public FeedDataSource(AqlSourceId id,
              String targetDataset,
              IAType itemType,
              AqlDataSource.AqlDataSourceType dataSourceType,
              FeedId sourceFeedId,
              Feed.FeedType sourceFeedType,
              IFeedLifecycleListener.ConnectionLocation location,
              String[] locations)
               throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

Method Detail

getFeed

public Feed getFeed()

getSchemaTypes

public IAType[] getSchemaTypes()

Specified by:

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

Specified by:

getSchemaTypes in class AqlDataSource

getDomain

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

Specified by:

getDomain in class AqlDataSource

getTargetDataset

public String getTargetDataset()

getSourceFeedId

public FeedId getSourceFeedId()

getLocation

public IFeedLifecycleListener.ConnectionLocation getLocation()

getLocations

public String[] getLocations()

getSourceFeedType

public Feed.FeedType getSourceFeedType()

getComputeCardinality

public int getComputeCardinality()