import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new ConnectorHandleResolver()
    {
        public Class<? extends ConnectorTableHandle> getTableHandleClass()
        {
            return RestTableHandle.class;
        }

        public Class<? extends ColumnHandle> getColumnHandleClass()
        {
            return RestColumnHandle.class;
        }

        public Class<? extends ConnectorSplit> getSplitClass()
        {
            return RestConnectorSplit.class;
        }

        public Class<? extends ConnectorTableLayoutHandle> getTableLayoutHandleClass()
        {
            return RestConnectorTableLayoutHandle.class;
        }

        @Override
        public Class<? extends ConnectorTransactionHandle> getTransactionHandleClass()
        {
            return RestTransactionHandle.class;
        }

        @Override
        public Class<? extends ConnectorInsertTableHandle> getInsertTableHandleClass()
        {
            return RestInsertTableHandle.class;
        }
    };
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
public void addConnectorName(String name, ConnectorHandleResolver resolver)
{
    requireNonNull(name, "name is null");
    requireNonNull(resolver, "resolver is null");
    ConnectorHandleResolver existingResolver = handleResolvers.putIfAbsent(name, resolver);
    checkState(existingResolver == null || existingResolver.equals(resolver),
            "Connector '%s' is already assigned to resolver: %s", name, existingResolver);
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
private <T> String getId(T handle, Function<ConnectorHandleResolver, Class<? extends T>> getter)
{
    for (Entry<String, ConnectorHandleResolver> entry : handleResolvers.entrySet()) {
        try {
            if (getter.apply(entry.getValue()).isInstance(handle)) {
                return entry.getKey();
            }
        }
        catch (UnsupportedOperationException ignored) {
        }
    }
    throw new IllegalArgumentException("No connector for handle: " + handle);
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Inject
public KafkaConnector(ConnectorMetadata metadata,
    ConnectorSplitManager splitManager,
    ConnectorRecordSetProvider recordSetProvider,
    ConnectorHandleResolver handleResolver)
{
    construct(metadata, splitManager, recordSetProvider, handleResolver);
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
private void construct(ConnectorMetadata metadata,
    ConnectorSplitManager splitManager,
    ConnectorRecordSetProvider recordSetProvider,
    ConnectorHandleResolver handleResolver)
{
      this.metadata = checkNotNull(metadata, "metadata is null");
      this.splitManager = checkNotNull(splitManager, "splitManager is null");
      this.recordSetProvider = checkNotNull(recordSetProvider,
              "recordSetProvider is null");
      this.handleResolver = checkNotNull(handleResolver,
              "handleResolver is null");
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public Connector create(final String connectorId, Map<String, String> requiredConfig) {
    checkNotNull(requiredConfig, "requiredConfig is null");
    checkNotNull(optionalConfig, "optionalConfig is null");

    try {
        // // A plugin is not required to use Guice; it is just very convenient
        // Bootstrap app = new Bootstrap(new JsonModule(), new ExampleModule(connectorId));
        //
        // Injector injector = app.strictConfig().doNotInitializeLogging()
        // .setRequiredConfigurationProperties(requiredConfig)
        // .setOptionalConfigurationProperties(optionalConfig).initialize();

        ClassToInstanceMap<Object> services = ImmutableClassToInstanceMap.builder()

        .put(ConnectorMetadata.class, new CloudataConnectorMetadata(connectorId, store))

        .put(ConnectorSplitManager.class, new CloudataSplitManager(nodeManager, connectorId))

        .put(ConnectorRecordSetProvider.class, new CloudataConnectorRecordSetProvider())

        .put(ConnectorHandleResolver.class, new CloudataConnectorHandleResolver()).build();

        CloudataConnector connector = new CloudataConnector(store, services);
        connectors.put(connectorId, connector);
        return connector;
    } catch (Exception e) {
        throw Throwables.propagate(e);
    }
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new HDFSHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver() {
    return new EthereumHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
public ConnectorHandleResolver getHandleResolver() {
  log.info("INFORMATION: AmpoolConnectorFactory getHandleResolver() called.");
  return new AmpoolHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new KuduHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new KafkaHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new ExampleHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new RaptorHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new RedisHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new BlackHoleHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new TpchIndexHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new JmxHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new JdbcHandleResolver();
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
@Override
public ConnectorHandleResolver getHandleResolver()
{
    return new LegacyTransactionHandleResolver(connectorFactory.getHandleResolver());
}
 

import com.facebook.presto.spi.ConnectorHandleResolver; //导入依赖的package包/类
public LegacyTransactionHandleResolver(ConnectorHandleResolver handleResolver)
{
    this.handleResolver = requireNonNull(handleResolver, "handleResolver is null");
}