org.apache.asterix.metadata.feeds

Class FeedMetaOperatorDescriptor

java.lang.Object

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

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

org.apache.asterix.metadata.feeds.FeedMetaOperatorDescriptor

All Implemented Interfaces:

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

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

FeedMetaOperatorDescriptor is a wrapper operator that provides a sanboox like environment for an hyracks operator that is part of a feed ingestion pipeline. The MetaFeed operator provides an interface iden- tical to that offered by the underlying wrapped operator, hereafter referred to as the core operator. As seen by Hyracks, the altered pipeline is identical to the earlier version formed from core operators. The MetaFeed operator enhances each core operator by providing functionality for handling runtime exceptions, saving any state for future retrieval, and measuring/reporting of performance characteristics. We next describe how the added functionality contributes to providing fault- tolerance.

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
FeedMetaOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec, FeedConnectionId feedConnectionId, org.apache.hyracks.api.dataflow.IOperatorDescriptor coreOperatorDescriptor, Map<String,String> feedPolicyProperties, IFeedRuntime.FeedRuntimeType runtimeType, boolean enableSubscriptionMode, String operandId)

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)
org.apache.hyracks.api.dataflow.IOperatorDescriptor	getCoreOperator()
IFeedRuntime.FeedRuntimeType	getRuntimeType()
String	toString()

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, wait, wait, wait

Constructor Detail

FeedMetaOperatorDescriptor

public FeedMetaOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec,
                          FeedConnectionId feedConnectionId,
                          org.apache.hyracks.api.dataflow.IOperatorDescriptor coreOperatorDescriptor,
                          Map<String,String> feedPolicyProperties,
                          IFeedRuntime.FeedRuntimeType runtimeType,
                          boolean enableSubscriptionMode,
                          String operandId)

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

toString

public String toString()

Overrides:

toString in class Object

getCoreOperator

public org.apache.hyracks.api.dataflow.IOperatorDescriptor getCoreOperator()

getRuntimeType

public IFeedRuntime.FeedRuntimeType getRuntimeType()