Uses of Class
org.apache.drill.exec.proto.ExecProtos.FragmentHandle

Packages that use ExecProtos.FragmentHandle

Package	Description
org.apache.drill.exec.ops
org.apache.drill.exec.physical.impl
org.apache.drill.exec.physical.impl.partitionsender
org.apache.drill.exec.physical.impl.spill	Collection of classes shared by operators that implement spill-to-disk.
org.apache.drill.exec.proto
org.apache.drill.exec.proto.helper
org.apache.drill.exec.rpc.control
org.apache.drill.exec.rpc.data
org.apache.drill.exec.work
org.apache.drill.exec.work.batch
org.apache.drill.exec.work.foreman
org.apache.drill.exec.work.fragment
org.apache.drill.test	Provides a variety of test framework tools to simplify Drill unit tests and ad-hoc tests created while developing features.

Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.ops

Methods in org.apache.drill.exec.ops that return ExecProtos.FragmentHandle

Modifier and Type	Method and Description
ExecProtos.FragmentHandle	FragmentContextImpl.getHandle() The FragmentHandle for this Fragment
ExecProtos.FragmentHandle	FragmentContext.getHandle()

Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.physical.impl

Methods in org.apache.drill.exec.physical.impl with parameters of type ExecProtos.FragmentHandle

Modifier and Type	Method and Description
void	SimpleRootExec.receivingFragmentFinished(ExecProtos.FragmentHandle handle) Deprecated.
void	BaseRootExec.receivingFragmentFinished(ExecProtos.FragmentHandle handle)
void	SingleSenderCreator.SingleSenderRootExec.receivingFragmentFinished(ExecProtos.FragmentHandle handle)
void	RootExec.receivingFragmentFinished(ExecProtos.FragmentHandle handle) Inform sender that receiving fragment is finished and doesn't need any more data.

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.FragmentHandle

Modifier and Type	Method and Description
void	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.FragmentHandle

Constructor and Description
SpillSet(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.FragmentHandle

Modifier and Type	Field and Description
static com.google.protobuf.Parser<ExecProtos.FragmentHandle>	ExecProtos.FragmentHandle.PARSER Deprecated.

Methods in org.apache.drill.exec.proto that return ExecProtos.FragmentHandle

Modifier and Type	Method and Description
ExecProtos.FragmentHandle	ExecProtos.FragmentHandle.Builder.build()
ExecProtos.FragmentHandle	ExecProtos.FragmentHandle.Builder.buildPartial()
static ExecProtos.FragmentHandle	ExecProtos.FragmentHandle.getDefaultInstance()
ExecProtos.FragmentHandle	ExecProtos.FragmentHandle.getDefaultInstanceForType()
ExecProtos.FragmentHandle	ExecProtos.FragmentHandle.Builder.getDefaultInstanceForType()
ExecProtos.FragmentHandle	BitControl.FragmentStatusOrBuilder.getHandle() optional .exec.bit.FragmentHandle handle = 2;
ExecProtos.FragmentHandle	BitControl.FragmentStatus.getHandle() optional .exec.bit.FragmentHandle handle = 2;
ExecProtos.FragmentHandle	BitControl.FragmentStatus.Builder.getHandle() optional .exec.bit.FragmentHandle handle = 2;
ExecProtos.FragmentHandle	BitControl.PlanFragmentOrBuilder.getHandle() optional .exec.bit.FragmentHandle handle = 1;
ExecProtos.FragmentHandle	BitControl.PlanFragment.getHandle() optional .exec.bit.FragmentHandle handle = 1;
ExecProtos.FragmentHandle	BitControl.PlanFragment.Builder.getHandle() optional .exec.bit.FragmentHandle handle = 1;
ExecProtos.FragmentHandle	BitControl.FinishedReceiverOrBuilder.getReceiver() optional .exec.bit.FragmentHandle receiver = 1;
ExecProtos.FragmentHandle	BitControl.FinishedReceiver.getReceiver() optional .exec.bit.FragmentHandle receiver = 1;
ExecProtos.FragmentHandle	BitControl.FinishedReceiver.Builder.getReceiver() optional .exec.bit.FragmentHandle receiver = 1;
ExecProtos.FragmentHandle	BitControl.FinishedReceiverOrBuilder.getSender() optional .exec.bit.FragmentHandle sender = 2;
ExecProtos.FragmentHandle	BitControl.FinishedReceiver.getSender() optional .exec.bit.FragmentHandle sender = 2;
ExecProtos.FragmentHandle	BitControl.FinishedReceiver.Builder.getSender() optional .exec.bit.FragmentHandle sender = 2;
ExecProtos.FragmentHandle	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(ByteBuffer data)
static ExecProtos.FragmentHandle	ExecProtos.FragmentHandle.parseFrom(ByteBuffer 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)

Methods in org.apache.drill.exec.proto that return types with arguments of type ExecProtos.FragmentHandle

Modifier and Type	Method and Description
com.google.protobuf.Parser<ExecProtos.FragmentHandle>	ExecProtos.FragmentHandle.getParserForType()
static com.google.protobuf.Parser<ExecProtos.FragmentHandle>	ExecProtos.FragmentHandle.parser()
Class<ExecProtos.FragmentHandle>	SchemaExecProtos.FragmentHandle.MessageSchema.typeClass()

Methods in org.apache.drill.exec.proto with parameters of type ExecProtos.FragmentHandle

Modifier and Type	Method and Description
boolean	SchemaExecProtos.FragmentHandle.MessageSchema.isInitialized(ExecProtos.FragmentHandle message)
ExecProtos.FragmentHandle.Builder	ExecProtos.FragmentHandle.Builder.mergeFrom(ExecProtos.FragmentHandle other)
void	SchemaExecProtos.FragmentHandle.MessageSchema.mergeFrom(io.protostuff.Input input, ExecProtos.FragmentHandle message)
BitControl.FragmentStatus.Builder	BitControl.FragmentStatus.Builder.mergeHandle(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle handle = 2;
BitControl.PlanFragment.Builder	BitControl.PlanFragment.Builder.mergeHandle(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle handle = 1;
BitControl.FinishedReceiver.Builder	BitControl.FinishedReceiver.Builder.mergeReceiver(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle receiver = 1;
BitControl.FinishedReceiver.Builder	BitControl.FinishedReceiver.Builder.mergeSender(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle sender = 2;
static ExecProtos.FragmentHandle.Builder	ExecProtos.FragmentHandle.newBuilder(ExecProtos.FragmentHandle prototype)
BitControl.FragmentStatus.Builder	BitControl.FragmentStatus.Builder.setHandle(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle handle = 2;
BitControl.PlanFragment.Builder	BitControl.PlanFragment.Builder.setHandle(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle handle = 1;
BitControl.FinishedReceiver.Builder	BitControl.FinishedReceiver.Builder.setReceiver(ExecProtos.FragmentHandle value) optional .exec.bit.FragmentHandle receiver = 1;
BitControl.FinishedReceiver.Builder	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.FragmentHandle

Modifier and Type	Method and Description
static 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.FragmentHandle

Modifier and Type	Method and Description
ExecProtos.FragmentHandle	ControlTunnel.SignalFragment.getMessage()

Methods in org.apache.drill.exec.rpc.control with parameters of type ExecProtos.FragmentHandle

Modifier and Type	Method and Description
void	ControlTunnel.cancelFragment(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle)
FragmentManager	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.FragmentHandle

Constructor and Description
SignalFragment(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, ExecProtos.FragmentHandle handle, BitControl.RpcType type)

Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.rpc.data

Methods in org.apache.drill.exec.rpc.data that return ExecProtos.FragmentHandle

Modifier and Type	Method and Description
ExecProtos.FragmentHandle	TestBitRpc.MockFragmentManager.getHandle()
ExecProtos.FragmentHandle	TestBitRpc.MockFragmentManagerWithDynamicCredit.getHandle()
ExecProtos.FragmentHandle	TestBitBitKerberos.MockFragmentManager.getHandle()

Methods in org.apache.drill.exec.rpc.data with parameters of type ExecProtos.FragmentHandle

Modifier and Type	Method and Description
void	TestBitRpc.MockFragmentManager.receivingFragmentFinished(ExecProtos.FragmentHandle handle)
void	TestBitRpc.MockFragmentManagerWithDynamicCredit.receivingFragmentFinished(ExecProtos.FragmentHandle handle)
void	TestBitBitKerberos.MockFragmentManager.receivingFragmentFinished(ExecProtos.FragmentHandle handle)

Uses of ExecProtos.FragmentHandle in org.apache.drill.exec.work

Methods in org.apache.drill.exec.work with parameters of type ExecProtos.FragmentHandle

Modifier and Type	Method and Description
FragmentExecutor	WorkManager.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.FragmentHandle

Modifier and Type	Method and Description
GeneralRPCProtos.Ack	ControlMessageHandler.cancelFragment(ExecProtos.FragmentHandle handle)
GeneralRPCProtos.Ack	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.FragmentHandle

Modifier and Type	Method and Description
ExecProtos.FragmentHandle	FragmentData.getHandle()

Constructors in org.apache.drill.exec.work.foreman with parameters of type ExecProtos.FragmentHandle

Constructor and Description
FragmentData(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.FragmentHandle

Modifier and Type	Field and Description
protected ExecProtos.FragmentHandle	AbstractFragmentManager.fragmentHandle

Methods in org.apache.drill.exec.work.fragment that return ExecProtos.FragmentHandle

Modifier and Type	Method and Description
ExecProtos.FragmentHandle	FragmentManager.getHandle()
ExecProtos.FragmentHandle	AbstractFragmentManager.getHandle()

Methods in org.apache.drill.exec.work.fragment with parameters of type ExecProtos.FragmentHandle

Modifier and Type	Method and Description
void	FragmentManager.receivingFragmentFinished(ExecProtos.FragmentHandle handle)
void	RootFragmentManager.receivingFragmentFinished(ExecProtos.FragmentHandle handle)
void	NonRootFragmentManager.receivingFragmentFinished(ExecProtos.FragmentHandle handle)
void	FragmentExecutor.receivingFragmentFinished(ExecProtos.FragmentHandle handle) Inform this fragment that one of its downstream partners no longer needs additional records.
abstract void	AbstractFragmentManager.receivingFragmentFinished(ExecProtos.FragmentHandle handle)

Uses of ExecProtos.FragmentHandle in org.apache.drill.test

Methods in org.apache.drill.test that return ExecProtos.FragmentHandle

Modifier and Type	Method and Description
ExecProtos.FragmentHandle	OperatorFixture.MockFragmentContext.getHandle()