Uses of Class
org.apache.drill.exec.proto.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
-
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.physical.impl
Modifier 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
Modifier and TypeMethodDescriptionvoid
PartitionSenderRootExec.receivingFragmentFinished
(ExecProtos.FragmentHandle handle) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.physical.impl.spill
ModifierConstructorDescriptionSpillSet
(DrillConfig config, ExecProtos.FragmentHandle handle, PhysicalOperator popConfig) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.proto
Modifier and TypeFieldDescriptionstatic final com.google.protobuf.Parser<ExecProtos.FragmentHandle>
ExecProtos.FragmentHandle.PARSER
Deprecated.Modifier 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) Modifier and TypeMethodDescriptioncom.google.protobuf.Parser<ExecProtos.FragmentHandle>
ExecProtos.FragmentHandle.getParserForType()
static com.google.protobuf.Parser<ExecProtos.FragmentHandle>
ExecProtos.FragmentHandle.parser()
SchemaExecProtos.FragmentHandle.MessageSchema.typeClass()
Modifier 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
Modifier 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
Modifier 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) ModifierConstructorDescriptionSignalFragment
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, ExecProtos.FragmentHandle handle, BitControl.RpcType type) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.work
Modifier and TypeMethodDescriptionWorkManager.WorkerBee.getFragmentRunner
(ExecProtos.FragmentHandle handle) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.work.batch
Modifier and TypeMethodDescriptionControlMessageHandler.cancelFragment
(ExecProtos.FragmentHandle handle) ControlMessageHandler.resumeFragment
(ExecProtos.FragmentHandle handle) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.work.foreman
ModifierConstructorDescriptionFragmentData
(ExecProtos.FragmentHandle handle, CoordinationProtos.DrillbitEndpoint endpoint, boolean isLocal) -
Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.work.fragment
Modifier and TypeFieldDescriptionprotected final ExecProtos.FragmentHandle
AbstractFragmentManager.fragmentHandle
Modifier and TypeMethodDescriptionAbstractFragmentManager.getHandle()
FragmentManager.getHandle()
Modifier 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)