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 TypeMethodDescriptionvoidBaseRootExec.receivingFragmentFinished(ExecProtos.FragmentHandle handle) voidRootExec.receivingFragmentFinished(ExecProtos.FragmentHandle handle) Inform sender that receiving fragment is finished and doesn't need any more data.voidSingleSenderCreator.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 TypeMethodDescriptionvoidPartitionSenderRootExec.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.PARSERDeprecated.Methods in org.apache.drill.exec.proto that return ExecProtos.FragmentHandleModifier and TypeMethodDescriptionExecProtos.FragmentHandle.Builder.build()ExecProtos.FragmentHandle.Builder.buildPartial()static ExecProtos.FragmentHandleExecProtos.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.FragmentHandleExecProtos.FragmentHandle.parseDelimitedFrom(InputStream input) static ExecProtos.FragmentHandleExecProtos.FragmentHandle.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static ExecProtos.FragmentHandleExecProtos.FragmentHandle.parseFrom(byte[] data) static ExecProtos.FragmentHandleExecProtos.FragmentHandle.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static ExecProtos.FragmentHandleExecProtos.FragmentHandle.parseFrom(com.google.protobuf.ByteString data) static ExecProtos.FragmentHandleExecProtos.FragmentHandle.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static ExecProtos.FragmentHandleExecProtos.FragmentHandle.parseFrom(com.google.protobuf.CodedInputStream input) static ExecProtos.FragmentHandleExecProtos.FragmentHandle.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static ExecProtos.FragmentHandleExecProtos.FragmentHandle.parseFrom(InputStream input) static ExecProtos.FragmentHandleExecProtos.FragmentHandle.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static ExecProtos.FragmentHandleExecProtos.FragmentHandle.parseFrom(ByteBuffer data) static ExecProtos.FragmentHandleExecProtos.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 TypeMethodDescriptionbooleanSchemaExecProtos.FragmentHandle.MessageSchema.isInitialized(ExecProtos.FragmentHandle message) ExecProtos.FragmentHandle.Builder.mergeFrom(ExecProtos.FragmentHandle other) voidSchemaExecProtos.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;voidSchemaExecProtos.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 StringQueryIdHelper.getExecutorThreadName(ExecProtos.FragmentHandle fragmentHandle) static StringQueryIdHelper.getFragmentId(ExecProtos.FragmentHandle fragmentHandle) static StringQueryIdHelper.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 TypeMethodDescriptionvoidControlTunnel.cancelFragment(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle) WorkEventBus.getFragmentManager(ExecProtos.FragmentHandle handle) booleanWorkEventBus.removeFragmentManager(ExecProtos.FragmentHandle handle, boolean cancel) Optionally cancels and removes fragment manager (for the corresponding the handle) from the work event bus.voidControlTunnel.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.FragmentHandleAbstractFragmentManager.fragmentHandleMethods 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 voidAbstractFragmentManager.receivingFragmentFinished(ExecProtos.FragmentHandle handle) voidFragmentExecutor.receivingFragmentFinished(ExecProtos.FragmentHandle handle) Inform this fragment that one of its downstream partners no longer needs additional records.voidFragmentManager.receivingFragmentFinished(ExecProtos.FragmentHandle handle) voidNonRootFragmentManager.receivingFragmentFinished(ExecProtos.FragmentHandle handle) voidRootFragmentManager.receivingFragmentFinished(ExecProtos.FragmentHandle handle)