Package org.apache.drill.exec.rpc.data

Class DataConnectionCreator

java.lang.Object

org.apache.drill.exec.rpc.data.DataConnectionCreator

All Implemented Interfaces:

AutoCloseable

public class DataConnectionCreator
extends Object
implements AutoCloseable

Manages a connection for each endpoint.

Constructor Summary

Constructors

Constructor	Description
DataConnectionCreator(BootStrapContext context, BufferAllocator allocator, WorkEventBus workBus, WorkManager.WorkerBee bee)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DataConnectionCreator

public DataConnectionCreator(BootStrapContext context,
 BufferAllocator allocator,
 WorkEventBus workBus,
 WorkManager.WorkerBee bee)
                      throws DrillbitStartupException

Throws:

DrillbitStartupException

Method Details

start

public CoordinationProtos.DrillbitEndpoint start(CoordinationProtos.DrillbitEndpoint partialEndpoint,
 boolean allowPortHunting)

getTunnel

public DataTunnel getTunnel(CoordinationProtos.DrillbitEndpoint endpoint)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception