Serializable
, org.apache.hyracks.api.dataflow.IActivity
, org.apache.hyracks.api.dataflow.IOperatorDescriptor
public class VXQueryCollectionOperatorDescriptor
extends org.apache.hyracks.dataflow.std.base.AbstractSingleActivityOperatorDescriptor
Modifier and Type | Field | Description |
---|---|---|
protected static Logger |
LOGGER |
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) |
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) |
contributeSchedulingConstraints, getDisplayName, getInputArity, getOperatorId, getOutputArity, getOutputRecordDescriptors, setDisplayName, toJSON
protected static final Logger LOGGER
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)
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
org.apache.hyracks.api.exceptions.HyracksDataException
Copyright © 2019 Apache Software Foundation. All rights reserved.