Uses of Class
org.apache.drill.exec.proto.ExecProtos.FragmentHandle
Packages that use ExecProtos.FragmentHandle
Package
Description
Collection of classes shared by operators that implement spill-to-disk.
-
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.ops
Methods in org.apache.drill.exec.ops that return ExecProtos.FragmentHandle -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.physical.impl
Methods in org.apache.drill.exec.physical.impl with parameters of type ExecProtos.FragmentHandleModifier and TypeMethodDescriptionvoid
BaseRootExec.receivingFragmentFinished
(ExecProtos.FragmentHandle handle) void
RootExec.receivingFragmentFinished
(ExecProtos.FragmentHandle handle) Inform sender that receiving fragment is finished and doesn't need any more data.void
SingleSenderCreator.SingleSenderRootExec.receivingFragmentFinished
(ExecProtos.FragmentHandle handle) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.physical.impl.partitionsender
Methods in org.apache.drill.exec.physical.impl.partitionsender with parameters of type ExecProtos.FragmentHandleModifier and TypeMethodDescriptionvoid
PartitionSenderRootExec.receivingFragmentFinished
(ExecProtos.FragmentHandle handle) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.physical.impl.spill
Constructors in org.apache.drill.exec.physical.impl.spill with parameters of type ExecProtos.FragmentHandleModifierConstructorDescriptionSpillSet
(DrillConfig config, ExecProtos.FragmentHandle handle, PhysicalOperator popConfig) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.proto
Fields in org.apache.drill.exec.proto with type parameters of type ExecProtos.FragmentHandleModifier and TypeFieldDescriptionstatic final com.google.protobuf.Parser<ExecProtos.FragmentHandle>
ExecProtos.FragmentHandle.PARSER
Deprecated.Methods in org.apache.drill.exec.proto that return ExecProtos.FragmentHandleModifier and TypeMethodDescriptionExecProtos.FragmentHandle.Builder.build()
ExecProtos.FragmentHandle.Builder.buildPartial()
static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.getDefaultInstance()
ExecProtos.FragmentHandle.Builder.getDefaultInstanceForType()
ExecProtos.FragmentHandle.getDefaultInstanceForType()
BitControl.FragmentStatus.Builder.getHandle()
optional .exec.bit.FragmentHandle handle = 2;
BitControl.FragmentStatus.getHandle()
optional .exec.bit.FragmentHandle handle = 2;
BitControl.FragmentStatusOrBuilder.getHandle()
optional .exec.bit.FragmentHandle handle = 2;
BitControl.PlanFragment.Builder.getHandle()
optional .exec.bit.FragmentHandle handle = 1;
BitControl.PlanFragment.getHandle()
optional .exec.bit.FragmentHandle handle = 1;
BitControl.PlanFragmentOrBuilder.getHandle()
optional .exec.bit.FragmentHandle handle = 1;
BitControl.FinishedReceiver.Builder.getReceiver()
optional .exec.bit.FragmentHandle receiver = 1;
BitControl.FinishedReceiver.getReceiver()
optional .exec.bit.FragmentHandle receiver = 1;
BitControl.FinishedReceiverOrBuilder.getReceiver()
optional .exec.bit.FragmentHandle receiver = 1;
BitControl.FinishedReceiver.Builder.getSender()
optional .exec.bit.FragmentHandle sender = 2;
BitControl.FinishedReceiver.getSender()
optional .exec.bit.FragmentHandle sender = 2;
BitControl.FinishedReceiverOrBuilder.getSender()
optional .exec.bit.FragmentHandle sender = 2;
SchemaExecProtos.FragmentHandle.MessageSchema.newMessage()
static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseDelimitedFrom
(InputStream input) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseDelimitedFrom
(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseFrom
(byte[] data) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseFrom
(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseFrom
(com.google.protobuf.ByteString data) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseFrom
(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseFrom
(com.google.protobuf.CodedInputStream input) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseFrom
(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseFrom
(InputStream input) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseFrom
(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseFrom
(ByteBuffer data) static ExecProtos.FragmentHandle
ExecProtos.FragmentHandle.parseFrom
(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) Methods in org.apache.drill.exec.proto that return types with arguments of type ExecProtos.FragmentHandleModifier and TypeMethodDescriptioncom.google.protobuf.Parser<ExecProtos.FragmentHandle>
ExecProtos.FragmentHandle.getParserForType()
static com.google.protobuf.Parser<ExecProtos.FragmentHandle>
ExecProtos.FragmentHandle.parser()
SchemaExecProtos.FragmentHandle.MessageSchema.typeClass()
Methods in org.apache.drill.exec.proto with parameters of type ExecProtos.FragmentHandleModifier and TypeMethodDescriptionboolean
SchemaExecProtos.FragmentHandle.MessageSchema.isInitialized
(ExecProtos.FragmentHandle message) ExecProtos.FragmentHandle.Builder.mergeFrom
(ExecProtos.FragmentHandle other) void
SchemaExecProtos.FragmentHandle.MessageSchema.mergeFrom
(io.protostuff.Input input, ExecProtos.FragmentHandle message) BitControl.FragmentStatus.Builder.mergeHandle
(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle handle = 2;
BitControl.PlanFragment.Builder.mergeHandle
(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle handle = 1;
BitControl.FinishedReceiver.Builder.mergeReceiver
(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle receiver = 1;
BitControl.FinishedReceiver.Builder.mergeSender
(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle sender = 2;
ExecProtos.FragmentHandle.newBuilder
(ExecProtos.FragmentHandle prototype) BitControl.FragmentStatus.Builder.setHandle
(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle handle = 2;
BitControl.PlanFragment.Builder.setHandle
(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle handle = 1;
BitControl.FinishedReceiver.Builder.setReceiver
(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle receiver = 1;
BitControl.FinishedReceiver.Builder.setSender
(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle sender = 2;
void
SchemaExecProtos.FragmentHandle.MessageSchema.writeTo
(io.protostuff.Output output, ExecProtos.FragmentHandle message) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.proto.helper
Methods in org.apache.drill.exec.proto.helper with parameters of type ExecProtos.FragmentHandleModifier and TypeMethodDescriptionstatic String
QueryIdHelper.getExecutorThreadName
(ExecProtos.FragmentHandle fragmentHandle) static String
QueryIdHelper.getFragmentId
(ExecProtos.FragmentHandle fragmentHandle) static String
QueryIdHelper.getQueryIdentifier
(ExecProtos.FragmentHandle h) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.rpc.control
Methods in org.apache.drill.exec.rpc.control that return ExecProtos.FragmentHandleMethods in org.apache.drill.exec.rpc.control with parameters of type ExecProtos.FragmentHandleModifier and TypeMethodDescriptionvoid
ControlTunnel.cancelFragment
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle) WorkEventBus.getFragmentManager
(ExecProtos.FragmentHandle handle) boolean
WorkEventBus.removeFragmentManager
(ExecProtos.FragmentHandle handle, boolean cancel) Optionally cancels and removes fragment manager (for the corresponding the handle) from the work event bus.void
ControlTunnel.unpauseFragment
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle) Constructors in org.apache.drill.exec.rpc.control with parameters of type ExecProtos.FragmentHandleModifierConstructorDescriptionSignalFragment
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, ExecProtos.FragmentHandle handle, BitControl.RpcType type) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.work
Methods in org.apache.drill.exec.work with parameters of type ExecProtos.FragmentHandleModifier and TypeMethodDescriptionWorkManager.WorkerBee.getFragmentRunner
(ExecProtos.FragmentHandle handle) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.work.batch
Methods in org.apache.drill.exec.work.batch with parameters of type ExecProtos.FragmentHandleModifier and TypeMethodDescriptionControlMessageHandler.cancelFragment
(ExecProtos.FragmentHandle handle) ControlMessageHandler.resumeFragment
(ExecProtos.FragmentHandle handle) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.work.foreman
Methods in org.apache.drill.exec.work.foreman that return ExecProtos.FragmentHandleConstructors in org.apache.drill.exec.work.foreman with parameters of type ExecProtos.FragmentHandleModifierConstructorDescriptionFragmentData
(ExecProtos.FragmentHandle handle, CoordinationProtos.DrillbitEndpoint endpoint, boolean isLocal) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.work.fragment
Fields in org.apache.drill.exec.work.fragment declared as ExecProtos.FragmentHandleModifier and TypeFieldDescriptionprotected final ExecProtos.FragmentHandle
AbstractFragmentManager.fragmentHandle
Methods in org.apache.drill.exec.work.fragment that return ExecProtos.FragmentHandleModifier and TypeMethodDescriptionAbstractFragmentManager.getHandle()
FragmentManager.getHandle()
Methods in org.apache.drill.exec.work.fragment with parameters of type ExecProtos.FragmentHandleModifier and TypeMethodDescriptionabstract void
AbstractFragmentManager.receivingFragmentFinished
(ExecProtos.FragmentHandle handle) void
FragmentExecutor.receivingFragmentFinished
(ExecProtos.FragmentHandle handle) Inform this fragment that one of its downstream partners no longer needs additional records.void
FragmentManager.receivingFragmentFinished
(ExecProtos.FragmentHandle handle) void
NonRootFragmentManager.receivingFragmentFinished
(ExecProtos.FragmentHandle handle) void
RootFragmentManager.receivingFragmentFinished
(ExecProtos.FragmentHandle handle)