org.apache.asterix.metadata.feeds

Class FeedCollectOperatorDescriptor

java.lang.Object

org.apache.hyracks.dataflow.std.base.AbstractOperatorDescriptor

org.apache.hyracks.dataflow.std.base.AbstractSingleActivityOperatorDescriptor

org.apache.asterix.metadata.feeds.FeedCollectOperatorDescriptor

All Implemented Interfaces:

Serializable, org.apache.hyracks.api.dataflow.IActivity, org.apache.hyracks.api.dataflow.IOperatorDescriptor

public class FeedCollectOperatorDescriptor
extends org.apache.hyracks.dataflow.std.base.AbstractSingleActivityOperatorDescriptor

FeedCollectOperatorDescriptor is responsible for ingesting data from an external source. This operator uses a user specified for a built-in adaptor for retrieving data from the external data source.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.hyracks.dataflow.std.base.AbstractSingleActivityOperatorDescriptor

activityNodeId

Fields inherited from class org.apache.hyracks.dataflow.std.base.AbstractOperatorDescriptor

displayName, inputArity, odId, outputArity, partitions, recordDescriptors

Constructor Summary

Constructors

Constructor and Description
FeedCollectOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec, FeedConnectionId feedConnectionId, FeedId sourceFeedId, ARecordType atype, org.apache.hyracks.api.dataflow.value.RecordDescriptor rDesc, Map<String,String> feedPolicyProperties, IFeedLifecycleListener.ConnectionLocation subscriptionLocation)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hyracks.api.dataflow.IOperatorNodePushable	createPushRuntime(org.apache.hyracks.api.context.IHyracksTaskContext ctx, org.apache.hyracks.api.dataflow.value.IRecordDescriptorProvider recordDescProvider, int partition, int nPartitions)
FeedConnectionId	getFeedConnectionId()
Map<String,String>	getFeedPolicyProperties()
IAType	getOutputType()
org.apache.hyracks.api.dataflow.value.RecordDescriptor	getRecordDescriptor()
FeedId	getSourceFeedId()
IFeedLifecycleListener.ConnectionLocation	getSubscriptionLocation()

Methods inherited from class org.apache.hyracks.dataflow.std.base.AbstractSingleActivityOperatorDescriptor

contributeActivities, getActivityId

Methods inherited from class org.apache.hyracks.dataflow.std.base.AbstractOperatorDescriptor

contributeSchedulingConstraints, getDisplayName, getInputArity, getOperatorId, getOutputArity, getOutputRecordDescriptors, setDisplayName, toJSON

Methods inherited from class java.lang.Object

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

Constructor Detail

FeedCollectOperatorDescriptor

public FeedCollectOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec,
                             FeedConnectionId feedConnectionId,
                             FeedId sourceFeedId,
                             ARecordType atype,
                             org.apache.hyracks.api.dataflow.value.RecordDescriptor rDesc,
                             Map<String,String> feedPolicyProperties,
                             IFeedLifecycleListener.ConnectionLocation subscriptionLocation)

Method Detail

createPushRuntime

public org.apache.hyracks.api.dataflow.IOperatorNodePushable createPushRuntime(org.apache.hyracks.api.context.IHyracksTaskContext ctx,
                                                                      org.apache.hyracks.api.dataflow.value.IRecordDescriptorProvider recordDescProvider,
                                                                      int partition,
                                                                      int nPartitions)
                                                                        throws org.apache.hyracks.api.exceptions.HyracksDataException

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

getFeedConnectionId

public FeedConnectionId getFeedConnectionId()

getFeedPolicyProperties

public Map<String,String> getFeedPolicyProperties()

getOutputType

public IAType getOutputType()

getRecordDescriptor

public org.apache.hyracks.api.dataflow.value.RecordDescriptor getRecordDescriptor()

getSourceFeedId

public FeedId getSourceFeedId()

getSubscriptionLocation

public IFeedLifecycleListener.ConnectionLocation getSubscriptionLocation()