org.apache.asterix.metadata.feeds

Class ExternalDataScanOperatorDescriptor

java.lang.Object

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

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

org.apache.asterix.metadata.feeds.ExternalDataScanOperatorDescriptor

All Implemented Interfaces:

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

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

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
ExternalDataScanOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec, org.apache.hyracks.api.dataflow.value.RecordDescriptor rDesc, IAdapterFactory dataSourceAdapterFactory)

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)

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

ExternalDataScanOperatorDescriptor

public ExternalDataScanOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec,
                                  org.apache.hyracks.api.dataflow.value.RecordDescriptor rDesc,
                                  IAdapterFactory dataSourceAdapterFactory)

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