Package org.apache.vxquery.metadata

Class VXQueryCollectionOperatorDescriptor

java.lang.Object

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

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

org.apache.vxquery.metadata.VXQueryCollectionOperatorDescriptor

All Implemented Interfaces:

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

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

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected static Logger	LOGGER

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

displayName, inputArity, odId, outputArity, partitions, recordDescriptors

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

activityNodeId

Constructor Summary

Constructors

Constructor	Description
VXQueryCollectionOperatorDescriptor(org.apache.hyracks.api.job.IOperatorDescriptorRegistry spec, VXQueryCollectionDataSource ds, org.apache.hyracks.api.dataflow.value.RecordDescriptor rDesc, String hdfsConf, Map<String,org.apache.hyracks.api.client.NodeControllerInfo> nodeControllerInfos)

Method Summary

Modifier and Type	Method	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.AbstractOperatorDescriptor

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

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

contributeActivities, getActivityId

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final Logger LOGGER

Constructor Detail

VXQueryCollectionOperatorDescriptor

public VXQueryCollectionOperatorDescriptor(org.apache.hyracks.api.job.IOperatorDescriptorRegistry spec,
                                           VXQueryCollectionDataSource ds,
                                           org.apache.hyracks.api.dataflow.value.RecordDescriptor rDesc,
                                           String hdfsConf,
                                           Map<String,org.apache.hyracks.api.client.NodeControllerInfo> nodeControllerInfos)

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