org.apache.asterix.metadata.feeds

Class FeedIntakeOperatorDescriptor

java.lang.Object

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

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

org.apache.asterix.metadata.feeds.FeedIntakeOperatorDescriptor

All Implemented Interfaces:

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

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

An operator responsible for establishing connection with external data source and parsing, translating the received content.It uses an instance of feed adaptor to perform these functions.

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
FeedIntakeOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec, PrimaryFeed primaryFeed, IFeedAdapterFactory adapterFactory, ARecordType adapterOutputType, FeedPolicyAccessor policyAccessor)
FeedIntakeOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec, PrimaryFeed primaryFeed, String adapterLibraryName, String adapterFactoryClassName, ARecordType adapterOutputType, FeedPolicyAccessor policyAccessor)

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)
FeedId	getFeedId()

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

FeedIntakeOperatorDescriptor

public FeedIntakeOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec,
                            PrimaryFeed primaryFeed,
                            IFeedAdapterFactory adapterFactory,
                            ARecordType adapterOutputType,
                            FeedPolicyAccessor policyAccessor)

FeedIntakeOperatorDescriptor

public FeedIntakeOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec,
                            PrimaryFeed primaryFeed,
                            String adapterLibraryName,
                            String adapterFactoryClassName,
                            ARecordType adapterOutputType,
                            FeedPolicyAccessor policyAccessor)

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

getFeedId

public FeedId getFeedId()