Uses of Class
org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint

Packages that use CoordinationProtos.DrillbitEndpoint

Package	Description
org.apache.drill.common.exceptions	Various exceptions used in logical, physical and execution contexts.
org.apache.drill.exec.coord	Cluster coordination system based on Apache Zookeeper and Curator.
org.apache.drill.exec.coord.local	A single-node "cluster coordinator" used when running Drill locally.
org.apache.drill.exec.coord.zk	Zookeeper/Curator integration code.
org.apache.drill.exec.ops
org.apache.drill.exec.physical
org.apache.drill.exec.physical.base
org.apache.drill.exec.physical.config
org.apache.drill.exec.planner
org.apache.drill.exec.planner.cost
org.apache.drill.exec.planner.fragment
org.apache.drill.exec.planner.fragment.contrib
org.apache.drill.exec.planner.sql
org.apache.drill.exec.proto
org.apache.drill.exec.rpc
org.apache.drill.exec.rpc.control
org.apache.drill.exec.rpc.data
org.apache.drill.exec.rpc.user
org.apache.drill.exec.server
org.apache.drill.exec.server.rest
org.apache.drill.exec.service
org.apache.drill.exec.store.dfs.easy
org.apache.drill.exec.store.direct
org.apache.drill.exec.store.druid
org.apache.drill.exec.store.enumerable
org.apache.drill.exec.store.hbase
org.apache.drill.exec.store.hive
org.apache.drill.exec.store.http
org.apache.drill.exec.store.iceberg
org.apache.drill.exec.store.ischema
org.apache.drill.exec.store.jdbc
org.apache.drill.exec.store.kafka	Kafka storage plugin.
org.apache.drill.exec.store.kudu
org.apache.drill.exec.store.mapr.db
org.apache.drill.exec.store.mock	Defines a mock data source which generates dummy test data for use in testing.
org.apache.drill.exec.store.mongo	MongoDB storage plugin.
org.apache.drill.exec.store.openTSDB
org.apache.drill.exec.store.parquet
org.apache.drill.exec.store.phoenix
org.apache.drill.exec.store.schedule
org.apache.drill.exec.store.splunk
org.apache.drill.exec.store.sys
org.apache.drill.exec.testing
org.apache.drill.exec.work
org.apache.drill.exec.work.filter
org.apache.drill.exec.work.foreman
org.apache.drill.exec.work.fragment
org.apache.drill.yarn.appMaster.http
org.apache.drill.yarn.zk	Interface between the Application Master and ZooKeeper.

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.common.exceptions

Methods in org.apache.drill.common.exceptions with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
UserException.Builder	UserException.Builder.addIdentity(CoordinationProtos.DrillbitEndpoint endpoint) add DrillbitEndpoint identity to the context.

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.coord

Fields in org.apache.drill.exec.coord with type parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Field and Description
static org.apache.curator.x.discovery.details.InstanceSerializer<CoordinationProtos.DrillbitEndpoint>	DrillServiceInstanceHelper.SERIALIZER

Methods in org.apache.drill.exec.coord that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	DrillbitEndpointSerDe.De.deserialize(com.fasterxml.jackson.core.JsonParser jp, com.fasterxml.jackson.databind.DeserializationContext ctxt)
CoordinationProtos.DrillbitEndpoint	ClusterCoordinator.RegistrationHandle.getEndPoint() Get the drillbit endpoint associated with the registration handle

Methods in org.apache.drill.exec.coord that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
abstract Collection<CoordinationProtos.DrillbitEndpoint>	ClusterCoordinator.getAvailableEndpoints() Get a collection of available Drillbit endpoints, Thread-safe.
abstract Collection<CoordinationProtos.DrillbitEndpoint>	ClusterCoordinator.getOnlineEndPoints() Get a collection of ONLINE drillbit endpoints by excluding the drillbits that are in QUIESCENT state (drillbits that are shutting down).

Methods in org.apache.drill.exec.coord with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
boolean	ClusterCoordinator.isDrillbitInState(CoordinationProtos.DrillbitEndpoint endpoint, CoordinationProtos.DrillbitEndpoint.State state)
abstract ClusterCoordinator.RegistrationHandle	ClusterCoordinator.register(CoordinationProtos.DrillbitEndpoint data)
void	DrillbitEndpointSerDe.Se.serialize(CoordinationProtos.DrillbitEndpoint value, com.fasterxml.jackson.core.JsonGenerator jgen, com.fasterxml.jackson.databind.SerializerProvider provider)
void	ClusterCoordinator.RegistrationHandle.setEndPoint(CoordinationProtos.DrillbitEndpoint endpoint)

Method parameters in org.apache.drill.exec.coord with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
protected void	ClusterCoordinator.drillbitRegistered(Set<CoordinationProtos.DrillbitEndpoint> registeredBits)
protected void	ClusterCoordinator.drillbitUnregistered(Set<CoordinationProtos.DrillbitEndpoint> unregisteredBits) Actions to take when there are a set of new de-active drillbits.

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.coord.local

Methods in org.apache.drill.exec.coord.local that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
Collection<CoordinationProtos.DrillbitEndpoint>	LocalClusterCoordinator.getAvailableEndpoints()
Collection<CoordinationProtos.DrillbitEndpoint>	LocalClusterCoordinator.getOnlineEndPoints() Get a collection of ONLINE Drillbit endpoints by excluding the drillbits that are in QUIESCENT state (drillbits shutting down).

Methods in org.apache.drill.exec.coord.local with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
ClusterCoordinator.RegistrationHandle	LocalClusterCoordinator.register(CoordinationProtos.DrillbitEndpoint data)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.coord.zk

Fields in org.apache.drill.exec.coord.zk declared as CoordinationProtos.DrillbitEndpoint

Modifier and Type	Field and Description
CoordinationProtos.DrillbitEndpoint	ZKRegistrationHandle.endpoint

Methods in org.apache.drill.exec.coord.zk that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	ZKRegistrationHandle.getEndPoint()

Methods in org.apache.drill.exec.coord.zk that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
Collection<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinator.getAvailableEndpoints()
Collection<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinator.getOnlineEndPoints()
protected org.apache.curator.x.discovery.ServiceDiscovery<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinator.newDiscovery()
protected org.apache.curator.x.discovery.ServiceInstance<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinator.newServiceInstance(CoordinationProtos.DrillbitEndpoint endpoint)

Methods in org.apache.drill.exec.coord.zk with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
protected org.apache.curator.x.discovery.ServiceInstance<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinator.newServiceInstance(CoordinationProtos.DrillbitEndpoint endpoint)
ClusterCoordinator.RegistrationHandle	ZKClusterCoordinator.register(CoordinationProtos.DrillbitEndpoint data)
void	ZKRegistrationHandle.setEndPoint(CoordinationProtos.DrillbitEndpoint endpoint)

Constructors in org.apache.drill.exec.coord.zk with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
ZKRegistrationHandle(String id, CoordinationProtos.DrillbitEndpoint endpoint)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.ops

Methods in org.apache.drill.exec.ops that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	QueryContext.getCurrentEndpoint()
CoordinationProtos.DrillbitEndpoint	ExecutorFragmentContext.getEndpoint()
CoordinationProtos.DrillbitEndpoint	FragmentContextImpl.getEndpoint()
CoordinationProtos.DrillbitEndpoint	ExecutorFragmentContext.getForemanEndpoint()
CoordinationProtos.DrillbitEndpoint	FragmentContextImpl.getForemanEndpoint()

Methods in org.apache.drill.exec.ops that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
Collection<CoordinationProtos.DrillbitEndpoint>	QueryContext.getActiveEndpoints()
Collection<CoordinationProtos.DrillbitEndpoint>	ExecutorFragmentContext.getBits()
Collection<CoordinationProtos.DrillbitEndpoint>	FragmentContextImpl.getBits()
Collection<CoordinationProtos.DrillbitEndpoint>	QueryContext.getOnlineEndpoints()

Methods in org.apache.drill.exec.ops with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
AccountingDataTunnel	ExchangeFragmentContext.getDataTunnel(CoordinationProtos.DrillbitEndpoint endpoint)
AccountingDataTunnel	FragmentContextImpl.getDataTunnel(CoordinationProtos.DrillbitEndpoint endpoint)

Constructors in org.apache.drill.exec.ops with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
FragmentStats(BufferAllocator allocator, CoordinationProtos.DrillbitEndpoint endpoint)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.physical

Methods in org.apache.drill.exec.physical that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	EndpointAffinity.getEndpoint() Return the Drillbit endpoint in this instance.
CoordinationProtos.DrillbitEndpoint	MinorFragmentEndpoint.getEndpoint() Get the Drillbit endpoint where the fragment is assigned for execution.

Constructors in org.apache.drill.exec.physical with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
EndpointAffinity(CoordinationProtos.DrillbitEndpoint endpoint) Create EndpointAffinity instance for given Drillbit endpoint.
EndpointAffinity(CoordinationProtos.DrillbitEndpoint endpoint, double affinity) Create EndpointAffinity instance for given Drillbit endpoint and affinity initialized to given affinity value.
EndpointAffinity(CoordinationProtos.DrillbitEndpoint endpoint, double affinity, boolean mandatory, int maxWidth) Creates EndpointAffinity instance for given DrillbitEndpoint, affinity and mandatory assignment requirement flag.
MinorFragmentEndpoint(int id, CoordinationProtos.DrillbitEndpoint endpoint)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.physical.base

Fields in org.apache.drill.exec.physical.base with type parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Field and Description
protected List<CoordinationProtos.DrillbitEndpoint>	AbstractExchange.receiverLocations
protected List<CoordinationProtos.DrillbitEndpoint>	AbstractExchange.senderLocations

Method parameters in org.apache.drill.exec.physical.base with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	SchemalessScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
void	Store.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints) Inform the Store node about the actual decided DrillbitEndpoint assignments desired for storage purposes.
void	GroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
protected static List<EndpointAffinity>	AbstractExchange.getDefaultAffinityMap(List<CoordinationProtos.DrillbitEndpoint> fragmentEndpoints) Get a default endpoint affinity map where affinity of a Drillbit is proportional to the number of its occurrences in given endpoint list.
static List<MinorFragmentEndpoint>	PhysicalOperatorUtil.getIndexOrderedEndpoints(List<CoordinationProtos.DrillbitEndpoint> endpoints) Helper method to create a list of MinorFragmentEndpoint instances from a given endpoint assignment list.
ParallelizationInfo	AbstractExchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints) Default receiver parallelization width range is [1, Integer.MAX_VALUE] and affinity to nodes where sender fragments are running.
ParallelizationInfo	Exchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints) Provide parallelization parameters for receiver side of the exchange.
ParallelizationInfo	AbstractExchange.getSenderParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> receiverFragmentEndpoints) Default sender parallelization width range is [1, Integer.MAX_VALUE] and no endpoint affinity
ParallelizationInfo	Exchange.getSenderParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> receiverFragmentEndpoints) Provide parallelization parameters for sender side of the exchange.
void	AbstractExchange.setupReceivers(int majorFragmentId, List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
void	Exchange.setupReceivers(int majorFragmentId, List<CoordinationProtos.DrillbitEndpoint> receiverLocations) Inform this Exchange node about its receiver locations.
protected void	AbstractExchange.setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
void	AbstractExchange.setupSenders(int majorFragmentId, List<CoordinationProtos.DrillbitEndpoint> senderLocations)
void	Exchange.setupSenders(int majorFragmentId, List<CoordinationProtos.DrillbitEndpoint> senderLocations) Inform this Exchange node about its sender locations.
protected void	AbstractExchange.setupSenders(List<CoordinationProtos.DrillbitEndpoint> senderLocations)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.physical.config

Methods in org.apache.drill.exec.physical.config that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	SingleSender.getDestination()
CoordinationProtos.DrillbitEndpoint	Screen.getEndpoint()

Method parameters in org.apache.drill.exec.physical.config with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	Screen.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
ParallelizationInfo	AbstractDeMuxExchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
ParallelizationInfo	AbstractMuxExchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
ParallelizationInfo	SingleMergeExchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
ParallelizationInfo	UnionExchange.getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
ParallelizationInfo	AbstractDeMuxExchange.getSenderParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> receiverFragmentEndpoints)
protected void	SingleMergeExchange.setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
protected void	UnionExchange.setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
void	UnionExchange.setupSenders(List<CoordinationProtos.DrillbitEndpoint> senderLocations)

Constructors in org.apache.drill.exec.physical.config with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
Screen(PhysicalOperator child, CoordinationProtos.DrillbitEndpoint endpoint)
SingleSender(int oppositeMajorFragmentId, int oppositeMinorFragmentId, PhysicalOperator child, CoordinationProtos.DrillbitEndpoint destination) Create a SingleSender which sends data to fragment identified by given MajorFragmentId and MinorFragmentId, and running at given endpoint
SingleSender(int oppositeMajorFragmentId, PhysicalOperator child, CoordinationProtos.DrillbitEndpoint destination) Create a SingleSender which sends data to fragment with MinorFragmentId as 0 in given opposite major fragment.

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.planner

Constructors in org.apache.drill.exec.planner with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
PhysicalPlanReader(DrillConfig config, ScanResult scanResult, LogicalPlanPersistence lpPersistance, CoordinationProtos.DrillbitEndpoint endpoint, StoragePluginRegistry pluginRegistry)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.planner.cost

Methods in org.apache.drill.exec.planner.cost that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
static Map<CoordinationProtos.DrillbitEndpoint,NodeResource>	NodeResource.merge(Map<CoordinationProtos.DrillbitEndpoint,NodeResource> to, Map<CoordinationProtos.DrillbitEndpoint,NodeResource> from)

Method parameters in org.apache.drill.exec.planner.cost with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
static Map<CoordinationProtos.DrillbitEndpoint,NodeResource>	NodeResource.merge(Map<CoordinationProtos.DrillbitEndpoint,NodeResource> to, Map<CoordinationProtos.DrillbitEndpoint,NodeResource> from)
static Map<CoordinationProtos.DrillbitEndpoint,NodeResource>	NodeResource.merge(Map<CoordinationProtos.DrillbitEndpoint,NodeResource> to, Map<CoordinationProtos.DrillbitEndpoint,NodeResource> from)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.planner.fragment

Methods in org.apache.drill.exec.planner.fragment that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	Wrapper.getAssignedEndpoint(int minorFragmentId)

Methods in org.apache.drill.exec.planner.fragment that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
List<CoordinationProtos.DrillbitEndpoint>	Wrapper.getAssignedEndpoints()
Map<CoordinationProtos.DrillbitEndpoint,EndpointAffinity>	ParallelizationInfo.getEndpointAffinityMap()
protected BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long>	DefaultQueryParallelizer.getMemory()
BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long>	QueueQueryParallelizer.getMemory()
protected abstract BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long>	SimpleParallelizer.getMemory()
Map<CoordinationProtos.DrillbitEndpoint,NodeResource>	Wrapper.getResourceMap()

Methods in org.apache.drill.exec.planner.fragment with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
QueryWorkUnit	QueryParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) This is the only function exposed to the consumer of this parallelizer (currently Foreman) to parallelize the plan.
QueryWorkUnit	SimpleParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) The starting function for the whole parallelization and memory computation logic.
protected QueryWorkUnit	SimpleParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Fragment rootNode, PlanningSet planningSet, UserSession session, BitControl.QueryContextInformation queryContextInfo)
List<org.apache.commons.lang3.tuple.Pair<PhysicalOperator,Long>>	MemoryCalculator.getBufferedOperators(CoordinationProtos.DrillbitEndpoint endpoint)
List<QueryWorkUnit>	SimpleParallelizer.getSplitFragments(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, PhysicalPlanReader reader, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) Create multiple physical plans from original query planning, it will allow execute them eventually independently

Method parameters in org.apache.drill.exec.planner.fragment with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	DefaultQueryParallelizer.adjustMemory(PlanningSet planningSet, Set<Wrapper> roots, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
void	QueueQueryParallelizer.adjustMemory(PlanningSet planningSet, Set<Wrapper> roots, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints) Function called by the SimpleParallelizer to adjust the memory post parallelization.
abstract void	SimpleParallelizer.adjustMemory(PlanningSet planningSet, Set<Wrapper> roots, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
void	Wrapper.assignEndpoints(List<CoordinationProtos.DrillbitEndpoint> assignedEndpoints)
void	SimpleParallelizer.collectStatsAndParallelizeFragments(PlanningSet planningSet, Set<Wrapper> roots, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints) Traverse all the major fragments and parallelize each major fragment based on collected stats.
QueryWorkUnit	QueryParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) This is the only function exposed to the consumer of this parallelizer (currently Foreman) to parallelize the plan.
QueryWorkUnit	SimpleParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) The starting function for the whole parallelization and memory computation logic.
List<QueryWorkUnit>	SimpleParallelizer.getSplitFragments(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, PhysicalPlanReader reader, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) Create multiple physical plans from original query planning, it will allow execute them eventually independently
void	FragmentParallelizer.parallelizeFragment(Wrapper fragment, ParallelizationParameters parameters, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints) Parallelize the given fragment.
void	HardAffinityFragmentParallelizer.parallelizeFragment(Wrapper fragmentWrapper, ParallelizationParameters parameters, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)
void	SoftAffinityFragmentParallelizer.parallelizeFragment(Wrapper fragmentWrapper, ParallelizationParameters parameters, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints)

Constructor parameters in org.apache.drill.exec.planner.fragment with type arguments of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
IndexedFragmentNode(int minorFragmentId, Wrapper info, BiFunction<Wrapper,Integer,CoordinationProtos.DrillbitEndpoint> wrapperToEndpoint, BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long> memoryReqs)
IndexedFragmentNode(int minorFragmentId, Wrapper info, BiFunction<Wrapper,Integer,CoordinationProtos.DrillbitEndpoint> wrapperToEndpoint, BiFunction<CoordinationProtos.DrillbitEndpoint,PhysicalOperator,Long> memoryReqs)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.planner.fragment.contrib

Methods in org.apache.drill.exec.planner.fragment.contrib with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type

Method and Description

List<QueryWorkUnit>

SplittingParallelizer.getSplitFragments(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, PhysicalPlanReader reader, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) Create multiple physical plans from original query planning, it will allow execute them eventually independently

Method parameters in org.apache.drill.exec.planner.fragment.contrib with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type

Method and Description

List<QueryWorkUnit>

SplittingParallelizer.getSplitFragments(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, PhysicalPlanReader reader, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) Create multiple physical plans from original query planning, it will allow execute them eventually independently

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.planner.sql

Methods in org.apache.drill.exec.planner.sql with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
static <T> PhysicalPlan	DirectPlan.createDirectPlan(CoordinationProtos.DrillbitEndpoint endpoint, List<T> records, Class<T> clazz)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.proto

Fields in org.apache.drill.exec.proto with type parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Field and Description
static com.google.protobuf.Parser<CoordinationProtos.DrillbitEndpoint>	CoordinationProtos.DrillbitEndpoint.PARSER Deprecated.

Methods in org.apache.drill.exec.proto that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.Builder.build()
CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.Builder.buildPartial()
CoordinationProtos.DrillbitEndpoint	BitControl.PlanFragmentOrBuilder.getAssignment() optional .exec.DrillbitEndpoint assignment = 10;
CoordinationProtos.DrillbitEndpoint	BitControl.PlanFragment.getAssignment() optional .exec.DrillbitEndpoint assignment = 10;
CoordinationProtos.DrillbitEndpoint	BitControl.PlanFragment.Builder.getAssignment() optional .exec.DrillbitEndpoint assignment = 10;
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.getDefaultInstance()
CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.getDefaultInstanceForType()
CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.Builder.getDefaultInstanceForType()
CoordinationProtos.DrillbitEndpoint	BitControl.BitControlHandshakeOrBuilder.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 3;
CoordinationProtos.DrillbitEndpoint	BitControl.BitControlHandshake.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 3;
CoordinationProtos.DrillbitEndpoint	BitControl.BitControlHandshake.Builder.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 3;
CoordinationProtos.DrillbitEndpoint	BitControl.WorkQueueStatusOrBuilder.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 1;
CoordinationProtos.DrillbitEndpoint	BitControl.WorkQueueStatus.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 1;
CoordinationProtos.DrillbitEndpoint	BitControl.WorkQueueStatus.Builder.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 1;
CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillServiceInstanceOrBuilder.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 3;
CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillServiceInstance.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 3;
CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillServiceInstance.Builder.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 3;
CoordinationProtos.DrillbitEndpoint	UserBitShared.DrillPBErrorOrBuilder.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 2;
CoordinationProtos.DrillbitEndpoint	UserBitShared.DrillPBError.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 2;
CoordinationProtos.DrillbitEndpoint	UserBitShared.DrillPBError.Builder.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 2;
CoordinationProtos.DrillbitEndpoint	UserBitShared.MinorFragmentProfileOrBuilder.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 9;
CoordinationProtos.DrillbitEndpoint	UserBitShared.MinorFragmentProfile.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 9;
CoordinationProtos.DrillbitEndpoint	UserBitShared.MinorFragmentProfile.Builder.getEndpoint() optional .exec.DrillbitEndpoint endpoint = 9;
CoordinationProtos.DrillbitEndpoint	BitControl.PlanFragmentOrBuilder.getForeman() optional .exec.DrillbitEndpoint foreman = 11;
CoordinationProtos.DrillbitEndpoint	BitControl.PlanFragment.getForeman() optional .exec.DrillbitEndpoint foreman = 11;
CoordinationProtos.DrillbitEndpoint	BitControl.PlanFragment.Builder.getForeman() optional .exec.DrillbitEndpoint foreman = 11;
CoordinationProtos.DrillbitEndpoint	UserBitShared.QueryInfoOrBuilder.getForeman() optional .exec.DrillbitEndpoint foreman = 5;
CoordinationProtos.DrillbitEndpoint	UserBitShared.QueryInfo.getForeman() optional .exec.DrillbitEndpoint foreman = 5;
CoordinationProtos.DrillbitEndpoint	UserBitShared.QueryInfo.Builder.getForeman() optional .exec.DrillbitEndpoint foreman = 5;
CoordinationProtos.DrillbitEndpoint	UserBitShared.QueryProfileOrBuilder.getForeman() optional .exec.DrillbitEndpoint foreman = 7;
CoordinationProtos.DrillbitEndpoint	UserBitShared.QueryProfile.getForeman() optional .exec.DrillbitEndpoint foreman = 7;
CoordinationProtos.DrillbitEndpoint	UserBitShared.QueryProfile.Builder.getForeman() optional .exec.DrillbitEndpoint foreman = 7;
CoordinationProtos.DrillbitEndpoint	SchemaCoordinationProtos.DrillbitEndpoint.MessageSchema.newMessage()
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseDelimitedFrom(InputStream input)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseFrom(byte[] data)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseFrom(ByteBuffer data)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseFrom(com.google.protobuf.ByteString data)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseFrom(com.google.protobuf.CodedInputStream input)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseFrom(InputStream input)
static CoordinationProtos.DrillbitEndpoint	CoordinationProtos.DrillbitEndpoint.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in org.apache.drill.exec.proto that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
com.google.protobuf.Parser<CoordinationProtos.DrillbitEndpoint>	CoordinationProtos.DrillbitEndpoint.getParserForType()
static com.google.protobuf.Parser<CoordinationProtos.DrillbitEndpoint>	CoordinationProtos.DrillbitEndpoint.parser()
Class<CoordinationProtos.DrillbitEndpoint>	SchemaCoordinationProtos.DrillbitEndpoint.MessageSchema.typeClass()

Methods in org.apache.drill.exec.proto with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
boolean	SchemaCoordinationProtos.DrillbitEndpoint.MessageSchema.isInitialized(CoordinationProtos.DrillbitEndpoint message)
BitControl.PlanFragment.Builder	BitControl.PlanFragment.Builder.mergeAssignment(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint assignment = 10;
BitControl.BitControlHandshake.Builder	BitControl.BitControlHandshake.Builder.mergeEndpoint(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint endpoint = 3;
BitControl.WorkQueueStatus.Builder	BitControl.WorkQueueStatus.Builder.mergeEndpoint(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint endpoint = 1;
CoordinationProtos.DrillServiceInstance.Builder	CoordinationProtos.DrillServiceInstance.Builder.mergeEndpoint(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint endpoint = 3;
UserBitShared.DrillPBError.Builder	UserBitShared.DrillPBError.Builder.mergeEndpoint(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint endpoint = 2;
UserBitShared.MinorFragmentProfile.Builder	UserBitShared.MinorFragmentProfile.Builder.mergeEndpoint(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint endpoint = 9;
BitControl.PlanFragment.Builder	BitControl.PlanFragment.Builder.mergeForeman(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint foreman = 11;
UserBitShared.QueryInfo.Builder	UserBitShared.QueryInfo.Builder.mergeForeman(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint foreman = 5;
UserBitShared.QueryProfile.Builder	UserBitShared.QueryProfile.Builder.mergeForeman(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint foreman = 7;
CoordinationProtos.DrillbitEndpoint.Builder	CoordinationProtos.DrillbitEndpoint.Builder.mergeFrom(CoordinationProtos.DrillbitEndpoint other)
void	SchemaCoordinationProtos.DrillbitEndpoint.MessageSchema.mergeFrom(io.protostuff.Input input, CoordinationProtos.DrillbitEndpoint message)
static CoordinationProtos.DrillbitEndpoint.Builder	CoordinationProtos.DrillbitEndpoint.newBuilder(CoordinationProtos.DrillbitEndpoint prototype)
BitControl.PlanFragment.Builder	BitControl.PlanFragment.Builder.setAssignment(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint assignment = 10;
BitControl.BitControlHandshake.Builder	BitControl.BitControlHandshake.Builder.setEndpoint(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint endpoint = 3;
BitControl.WorkQueueStatus.Builder	BitControl.WorkQueueStatus.Builder.setEndpoint(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint endpoint = 1;
CoordinationProtos.DrillServiceInstance.Builder	CoordinationProtos.DrillServiceInstance.Builder.setEndpoint(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint endpoint = 3;
UserBitShared.DrillPBError.Builder	UserBitShared.DrillPBError.Builder.setEndpoint(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint endpoint = 2;
UserBitShared.MinorFragmentProfile.Builder	UserBitShared.MinorFragmentProfile.Builder.setEndpoint(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint endpoint = 9;
BitControl.PlanFragment.Builder	BitControl.PlanFragment.Builder.setForeman(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint foreman = 11;
UserBitShared.QueryInfo.Builder	UserBitShared.QueryInfo.Builder.setForeman(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint foreman = 5;
UserBitShared.QueryProfile.Builder	UserBitShared.QueryProfile.Builder.setForeman(CoordinationProtos.DrillbitEndpoint value) optional .exec.DrillbitEndpoint foreman = 7;
void	SchemaCoordinationProtos.DrillbitEndpoint.MessageSchema.writeTo(io.protostuff.Output output, CoordinationProtos.DrillbitEndpoint message)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.rpc

Methods in org.apache.drill.exec.rpc that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	UserRpcException.getEndpoint()

Methods in org.apache.drill.exec.rpc with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
Map<String,?>	BitConnectionConfig.getSaslClientProperties(CoordinationProtos.DrillbitEndpoint remoteEndpoint, Map<String,String> overrides)
static boolean	BitRpcUtility.isLocalControlServer(CoordinationProtos.DrillbitEndpoint local, CoordinationProtos.DrillbitEndpoint remote) Verifies if local and remote Drillbit Endpoint has same control server by using address and control port information.
static <T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite> void	BitRpcUtility.prepareSaslHandshake(RpcConnectionHandler<CC> connectionHandler, List<String> serverAuthMechanisms, CC connection, BitConnectionConfig config, CoordinationProtos.DrillbitEndpoint endpoint, BasicClient<T,CC,HS,HR> client, T saslRpcType) Creates various instances needed to start the SASL handshake.

Constructors in org.apache.drill.exec.rpc with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
UserRpcException(CoordinationProtos.DrillbitEndpoint endpoint, String message, Throwable t)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.rpc.control

Methods in org.apache.drill.exec.rpc.control that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	ControllerImpl.start(CoordinationProtos.DrillbitEndpoint partialEndpoint, boolean allowPortHunting)
CoordinationProtos.DrillbitEndpoint	Controller.start(CoordinationProtos.DrillbitEndpoint partialEndpoint, boolean allowPortHunting)

Methods in org.apache.drill.exec.rpc.control with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
ControlConnectionManager	ConnectionManagerRegistry.getConnectionManager(CoordinationProtos.DrillbitEndpoint remoteEndpoint)
ControlTunnel	ControllerImpl.getTunnel(CoordinationProtos.DrillbitEndpoint endpoint)
ControlTunnel	Controller.getTunnel(CoordinationProtos.DrillbitEndpoint node) Get a Bit to Bit communication tunnel.
void	CustomHandlerRegistry.setEndpoint(CoordinationProtos.DrillbitEndpoint endpoint)
CoordinationProtos.DrillbitEndpoint	ControllerImpl.start(CoordinationProtos.DrillbitEndpoint partialEndpoint, boolean allowPortHunting)
CoordinationProtos.DrillbitEndpoint	Controller.start(CoordinationProtos.DrillbitEndpoint partialEndpoint, boolean allowPortHunting)

Constructors in org.apache.drill.exec.rpc.control with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
ControlClient(ControlConnectionConfig config, CoordinationProtos.DrillbitEndpoint remoteEndpoint, ReconnectingConnection.CloseHandlerCreator closeHandlerFactory)
ControlConnectionManager(CoordinationProtos.DrillbitEndpoint localEndpoint, CoordinationProtos.DrillbitEndpoint remoteEndpoint)
LocalControlConnectionManager(ControlConnectionConfig config, CoordinationProtos.DrillbitEndpoint localEndpoint)
RemoteControlConnectionManager(ControlConnectionConfig config, CoordinationProtos.DrillbitEndpoint localEndpoint, CoordinationProtos.DrillbitEndpoint remoteEndpoint)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.rpc.data

Methods in org.apache.drill.exec.rpc.data that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	DataConnectionCreator.start(CoordinationProtos.DrillbitEndpoint partialEndpoint, boolean allowPortHunting)

Methods in org.apache.drill.exec.rpc.data with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
DataTunnel	DataConnectionCreator.getTunnel(CoordinationProtos.DrillbitEndpoint endpoint)
CoordinationProtos.DrillbitEndpoint	DataConnectionCreator.start(CoordinationProtos.DrillbitEndpoint partialEndpoint, boolean allowPortHunting)

Constructors in org.apache.drill.exec.rpc.data with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
DataClient(CoordinationProtos.DrillbitEndpoint remoteEndpoint, org.apache.drill.exec.rpc.data.DataConnectionConfig config, ReconnectingConnection.CloseHandlerCreator closeHandlerFactory)
DataConnectionManager(CoordinationProtos.DrillbitEndpoint remoteEndpoint, org.apache.drill.exec.rpc.data.DataConnectionConfig config)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.rpc.user

Methods in org.apache.drill.exec.rpc.user with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	UserClient.connect(CoordinationProtos.DrillbitEndpoint endpoint, DrillProperties properties, UserBitShared.UserCredentials credentials) Connects, and if required, authenticates.

Constructors in org.apache.drill.exec.rpc.user with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
UserClient(String clientName, DrillConfig config, Properties properties, boolean supportComplexTypes, BufferAllocator allocator, io.netty.channel.EventLoopGroup eventLoopGroup, Executor eventExecutor, CoordinationProtos.DrillbitEndpoint endpoint)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.server

Methods in org.apache.drill.exec.server that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	DrillbitContext.getEndpoint()

Methods in org.apache.drill.exec.server that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
Collection<CoordinationProtos.DrillbitEndpoint>	DrillbitContext.getAvailableBits()
Collection<CoordinationProtos.DrillbitEndpoint>	DrillbitContext.getBits()

Methods in org.apache.drill.exec.server with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
boolean	DrillbitContext.isForeman(CoordinationProtos.DrillbitEndpoint endpoint)
boolean	DrillbitContext.isOnline(CoordinationProtos.DrillbitEndpoint endpoint)

Constructors in org.apache.drill.exec.server with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
DrillbitContext(CoordinationProtos.DrillbitEndpoint endpoint, BootStrapContext context, ClusterCoordinator coord, Controller controller, DataConnectionCreator connectionsPool, WorkEventBus workBus, PersistentStoreProvider provider)
DrillbitContext(CoordinationProtos.DrillbitEndpoint endpoint, BootStrapContext context, ClusterCoordinator coord, Controller controller, DataConnectionCreator connectionsPool, WorkEventBus workBus, PersistentStoreProvider provider, PersistentStoreProvider profileStoreProvider)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.server.rest

Constructors in org.apache.drill.exec.server.rest with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
DrillbitInfo(CoordinationProtos.DrillbitEndpoint drillbit, boolean current, boolean versionMatch)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.service

Methods in org.apache.drill.exec.service that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	ServiceEngine.start()

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.dfs.easy

Method parameters in org.apache.drill.exec.store.dfs.easy with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	EasyGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.direct

Method parameters in org.apache.drill.exec.store.direct with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	DirectGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.druid

Method parameters in org.apache.drill.exec.store.druid with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	DruidGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.enumerable

Method parameters in org.apache.drill.exec.store.enumerable with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	EnumerableGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.hbase

Method parameters in org.apache.drill.exec.store.hbase with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	HBaseGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.hive

Methods in org.apache.drill.exec.store.hive that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
protected Collection<CoordinationProtos.DrillbitEndpoint>	HiveDrillNativeParquetScan.getDrillbits()

Method parameters in org.apache.drill.exec.store.hive with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	HiveScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.http

Method parameters in org.apache.drill.exec.store.http with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	HttpGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.iceberg

Method parameters in org.apache.drill.exec.store.iceberg with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	IcebergGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Constructor parameters in org.apache.drill.exec.store.iceberg with type arguments of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
IcebergBlockMapBuilder(org.apache.hadoop.fs.FileSystem fs, Collection<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.ischema

Method parameters in org.apache.drill.exec.store.ischema with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	InfoSchemaGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.jdbc

Method parameters in org.apache.drill.exec.store.jdbc with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	JdbcGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.kafka

Method parameters in org.apache.drill.exec.store.kafka with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	KafkaGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.kudu

Method parameters in org.apache.drill.exec.store.kudu with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	KuduGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.mapr.db

Method parameters in org.apache.drill.exec.store.mapr.db with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	MapRDBGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.mock

Method parameters in org.apache.drill.exec.store.mock with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	MockGroupScanPOP.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)
void	MockStorePOP.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.mongo

Method parameters in org.apache.drill.exec.store.mongo with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	MongoGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.openTSDB

Method parameters in org.apache.drill.exec.store.openTSDB with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	OpenTSDBGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.parquet

Methods in org.apache.drill.exec.store.parquet that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
protected abstract Collection<CoordinationProtos.DrillbitEndpoint>	AbstractParquetGroupScan.getDrillbits()
protected Collection<CoordinationProtos.DrillbitEndpoint>	ParquetGroupScan.getDrillbits()

Method parameters in org.apache.drill.exec.store.parquet with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	AbstractParquetGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.phoenix

Method parameters in org.apache.drill.exec.store.phoenix with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	PhoenixGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.schedule

Methods in org.apache.drill.exec.store.schedule that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
Iterator<com.carrotsearch.hppc.cursors.ObjectLongCursor<CoordinationProtos.DrillbitEndpoint>>	EndpointByteMapImpl.iterator()

Methods in org.apache.drill.exec.store.schedule with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	EndpointByteMapImpl.add(CoordinationProtos.DrillbitEndpoint endpoint, long bytes)
void	EndpointByteMap.add(CoordinationProtos.DrillbitEndpoint endpoint, long bytes)
long	EndpointByteMapImpl.get(CoordinationProtos.DrillbitEndpoint endpoint)
long	EndpointByteMap.get(CoordinationProtos.DrillbitEndpoint endpoint)
boolean	EndpointByteMapImpl.isSet(CoordinationProtos.DrillbitEndpoint endpoint)
boolean	EndpointByteMap.isSet(CoordinationProtos.DrillbitEndpoint endpoint)

Method parameters in org.apache.drill.exec.store.schedule with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
static <T extends CompleteWork> org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap<Integer,T>	AssignmentCreator.getMappings(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints, List<T> units) Assign each unit of work to a minor fragment, given that a list of DrillbitEndpoints, whose index in the list correspond to the minor fragment id for each fragment.

Constructor parameters in org.apache.drill.exec.store.schedule with type arguments of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
BlockMapBuilder(org.apache.hadoop.fs.FileSystem fs, Collection<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.splunk

Method parameters in org.apache.drill.exec.store.splunk with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	SplunkGroupScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.store.sys

Methods in org.apache.drill.exec.store.sys with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
boolean	DrillbitIterator.isCurrent(CoordinationProtos.DrillbitEndpoint ep)

Method parameters in org.apache.drill.exec.store.sys with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	SystemTableScan.applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.testing

Methods in org.apache.drill.exec.testing with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
boolean	Injection.isValidForBit(CoordinationProtos.DrillbitEndpoint endpoint)

Constructors in org.apache.drill.exec.testing with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
ExecutionControls(OptionManager options, CoordinationProtos.DrillbitEndpoint endpoint)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.work

Fields in org.apache.drill.exec.work declared as CoordinationProtos.DrillbitEndpoint

Modifier and Type	Field and Description
protected CoordinationProtos.DrillbitEndpoint	EndpointListener.endpoint

Methods in org.apache.drill.exec.work that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
protected CoordinationProtos.DrillbitEndpoint	EndpointListener.getEndpoint()

Methods in org.apache.drill.exec.work with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	WorkManager.start(CoordinationProtos.DrillbitEndpoint endpoint, Controller controller, DataConnectionCreator data, ClusterCoordinator coord, PersistentStoreProvider provider, PersistentStoreProvider profilesProvider)

Constructors in org.apache.drill.exec.work with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
EndpointListener(CoordinationProtos.DrillbitEndpoint endpoint, V value)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.work.filter

Method parameters in org.apache.drill.exec.work.filter with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	RuntimeFilterSink.setJoinMjId2probeScanEps(Map<Integer,List<CoordinationProtos.DrillbitEndpoint>> joinMjId2probeScanEps)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.work.foreman

Methods in org.apache.drill.exec.work.foreman that return CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
CoordinationProtos.DrillbitEndpoint	FragmentData.getEndpoint()

Method parameters in org.apache.drill.exec.work.foreman with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	DrillbitStatusListener.drillbitRegistered(Set<CoordinationProtos.DrillbitEndpoint> registeredDrillbits) The action to taken when a set of new drillbits are registered to the cluster.
void	DrillbitStatusListener.drillbitUnregistered(Set<CoordinationProtos.DrillbitEndpoint> unregisteredDrillbits) The action to taken when a set of drillbits are unregistered from the cluster.

Constructors in org.apache.drill.exec.work.foreman with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
FragmentData(ExecProtos.FragmentHandle handle, CoordinationProtos.DrillbitEndpoint endpoint, boolean isLocal)

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.exec.work.fragment

Fields in org.apache.drill.exec.work.fragment with type parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Field and Description
protected AtomicReference<CoordinationProtos.DrillbitEndpoint>	FragmentStatusReporter.foremanDrillbit

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.yarn.appMaster.http

Fields in org.apache.drill.yarn.appMaster.http declared as CoordinationProtos.DrillbitEndpoint

Modifier and Type	Field and Description
protected CoordinationProtos.DrillbitEndpoint	AbstractTasksModel.TaskModel.endpoint

Uses of CoordinationProtos.DrillbitEndpoint in org.apache.drill.yarn.zk

Fields in org.apache.drill.yarn.zk declared as CoordinationProtos.DrillbitEndpoint

Modifier and Type	Field and Description
protected CoordinationProtos.DrillbitEndpoint	ZKRegistry.DrillbitTracker.endpoint For Drillbits discovered through ZK, the Drill endpoint for the Drillbit.

Methods in org.apache.drill.yarn.zk that return types with arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
Collection<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinator.getAvailableEndpoints()
List<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinatorDriver.getInitialEndpoints() Returns the set of Drillbits registered at the time of the ZKClusterCoordinatorDriver.build() call.
Collection<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinator.getOnlineEndPoints()
protected org.apache.curator.x.discovery.ServiceDiscovery<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinator.newDiscovery()
protected org.apache.curator.x.discovery.ServiceInstance<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinator.newServiceInstance(CoordinationProtos.DrillbitEndpoint endpoint)

Methods in org.apache.drill.yarn.zk with parameters of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
static String	ZKClusterCoordinatorDriver.asString(CoordinationProtos.DrillbitEndpoint bit) Convenience method to convert a Drillbit to a string.
protected org.apache.curator.x.discovery.ServiceInstance<CoordinationProtos.DrillbitEndpoint>	ZKClusterCoordinator.newServiceInstance(CoordinationProtos.DrillbitEndpoint endpoint)
ClusterCoordinator.RegistrationHandle	ZKClusterCoordinator.register(CoordinationProtos.DrillbitEndpoint data)

Method parameters in org.apache.drill.yarn.zk with type arguments of type CoordinationProtos.DrillbitEndpoint

Modifier and Type	Method and Description
void	ZKRegistry.drillbitRegistered(Set<CoordinationProtos.DrillbitEndpoint> registeredDrillbits) Callback from ZK to indicate that one or more drillbits have become registered.
void	ZKRegistry.drillbitUnregistered(Set<CoordinationProtos.DrillbitEndpoint> unregisteredDrillbits) Callback from ZK to indicate that one or more drillbits have become deregistered from ZK.

Constructors in org.apache.drill.yarn.zk with parameters of type CoordinationProtos.DrillbitEndpoint

Constructor and Description
AckEvent(Task task, CoordinationProtos.DrillbitEndpoint endpoint)
DrillbitTracker(String key, CoordinationProtos.DrillbitEndpoint endpoint)