本文整理了Java中io.prestosql.spi.NodeManager.getCurrentNode()方法的一些代码示例，展示了NodeManager.getCurrentNode()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。NodeManager.getCurrentNode()方法的具体详情如下：
包路径：io.prestosql.spi.NodeManager
类名称：NodeManager
方法名：getCurrentNode

NodeManager.getCurrentNode介绍

暂无

代码示例

代码示例来源：origin: io.prestosql/presto-memory

@Inject
public MemoryPageSinkProvider(MemoryPagesStore pagesStore, NodeManager nodeManager)
{
  this(pagesStore, requireNonNull(nodeManager, "nodeManager is null").getCurrentNode().getHostAndPort());
}

代码示例来源：origin: prestosql/presto

@Inject
public JmxRecordSetProvider(MBeanServer mbeanServer, NodeManager nodeManager, JmxHistoricalData jmxHistoricalData)
{
  this.mbeanServer = requireNonNull(mbeanServer, "mbeanServer is null");
  this.nodeId = requireNonNull(nodeManager, "nodeManager is null").getCurrentNode().getNodeIdentifier();
  this.jmxHistoricalData = requireNonNull(jmxHistoricalData, "jmxHistoryHolder is null");
}

代码示例来源：origin: prestosql/presto

@Inject
public MemoryPageSinkProvider(MemoryPagesStore pagesStore, NodeManager nodeManager)
{
  this(pagesStore, requireNonNull(nodeManager, "nodeManager is null").getCurrentNode().getHostAndPort());
}

代码示例来源：origin: prestosql/presto

@Inject
public RaptorConnector(
    LifeCycleManager lifeCycleManager,
    NodeManager nodeManager,
    RaptorMetadataFactory metadataFactory,
    RaptorSplitManager splitManager,
    RaptorPageSourceProvider pageSourceProvider,
    RaptorPageSinkProvider pageSinkProvider,
    RaptorNodePartitioningProvider nodePartitioningProvider,
    RaptorSessionProperties sessionProperties,
    RaptorTableProperties tableProperties,
    Set<SystemTable> systemTables,
    ConnectorAccessControl accessControl,
    @ForMetadata IDBI dbi)
{
  this.lifeCycleManager = requireNonNull(lifeCycleManager, "lifeCycleManager is null");
  this.metadataFactory = requireNonNull(metadataFactory, "metadataFactory is null");
  this.splitManager = requireNonNull(splitManager, "splitManager is null");
  this.pageSourceProvider = requireNonNull(pageSourceProvider, "pageSourceProvider is null");
  this.pageSinkProvider = requireNonNull(pageSinkProvider, "pageSinkProvider is null");
  this.nodePartitioningProvider = requireNonNull(nodePartitioningProvider, "nodePartitioningProvider is null");
  this.sessionProperties = requireNonNull(sessionProperties, "sessionProperties is null").getSessionProperties();
  this.tableProperties = requireNonNull(tableProperties, "tableProperties is null").getTableProperties();
  this.systemTables = requireNonNull(systemTables, "systemTables is null");
  this.accessControl = requireNonNull(accessControl, "accessControl is null");
  this.dao = onDemandDao(dbi, MetadataDao.class);
  this.coordinator = nodeManager.getCurrentNode().isCoordinator();
}

代码示例来源：origin: prestosql/presto

private SimpleConsumer createConsumer(HostAddress host)
  {
    log.info("Creating new Consumer for %s", host);
    return new SimpleConsumer(host.getHostText(),
        host.getPort(),
        connectTimeoutMillis,
        bufferSizeBytes,
        format("presto-kafka-%s-%s", connectorId, nodeManager.getCurrentNode().getNodeIdentifier()));
  }
}

代码示例来源：origin: prestosql/presto

public ShardRecoveryManager(
    StorageService storageService,
    Optional<BackupStore> backupStore,
    NodeManager nodeManager,
    ShardManager shardManager,
    Duration missingShardDiscoveryInterval,
    int recoveryThreads)
{
  this.storageService = requireNonNull(storageService, "storageService is null");
  this.backupStore = requireNonNull(backupStore, "backupStore is null");
  this.nodeIdentifier = requireNonNull(nodeManager, "nodeManager is null").getCurrentNode().getNodeIdentifier();
  this.shardManager = requireNonNull(shardManager, "shardManager is null");
  this.missingShardDiscoveryInterval = requireNonNull(missingShardDiscoveryInterval, "missingShardDiscoveryInterval is null");
  this.shardQueue = new MissingShardsQueue(new PrioritizedFifoExecutor<>(executorService, recoveryThreads, new MissingShardComparator()));
  this.stats = new ShardRecoveryStats();
}

代码示例来源：origin: prestosql/presto

@Inject
public ShardOrganizationManager(
    @ForMetadata IDBI dbi,
    NodeManager nodeManager,
    ShardManager shardManager,
    ShardOrganizer organizer,
    TemporalFunction temporalFunction,
    StorageManagerConfig config)
{
  this(dbi,
      nodeManager.getCurrentNode().getNodeIdentifier(),
      shardManager,
      organizer,
      temporalFunction,
      config.isOrganizationEnabled(),
      config.getOrganizationInterval(),
      config.getOrganizationDiscoveryInterval());
}

代码示例来源：origin: prestosql/presto

@Inject
public BucketBalancer(
    NodeManager nodeManager,
    NodeSupplier nodeSupplier,
    ShardManager shardManager,
    BucketBalancerConfig config,
    BackupService backupService,
    RaptorConnectorId connectorId)
{
  this(nodeSupplier,
      shardManager,
      config.isBalancerEnabled(),
      config.getBalancerInterval(),
      backupService.isBackupAvailable(),
      nodeManager.getCurrentNode().isCoordinator(),
      connectorId.toString());
}

代码示例来源：origin: prestosql/presto

@Inject
public ShardCompactionManager(@ForMetadata IDBI dbi,
    NodeManager nodeManager,
    ShardManager shardManager,
    ShardOrganizer organizer,
    TemporalFunction temporalFunction,
    StorageManagerConfig config)
{
  this(dbi,
      nodeManager.getCurrentNode().getNodeIdentifier(),
      shardManager,
      organizer,
      temporalFunction,
      config.getCompactionInterval(),
      config.getMaxShardSize(),
      config.getMaxShardRows(),
      config.isCompactionEnabled());
}

代码示例来源：origin: prestosql/presto

@Inject
public ShardCleaner(
    DaoSupplier<ShardDao> shardDaoSupplier,
    Ticker ticker,
    NodeManager nodeManager,
    StorageService storageService,
    Optional<BackupStore> backupStore,
    ShardCleanerConfig config)
{
  this(
      shardDaoSupplier,
      nodeManager.getCurrentNode().getNodeIdentifier(),
      nodeManager.getCurrentNode().isCoordinator(),
      ticker,
      storageService,
      backupStore,
      config.getMaxTransactionAge(),
      config.getTransactionCleanerInterval(),
      config.getLocalCleanerInterval(),
      config.getLocalCleanTime(),
      config.getBackupCleanerInterval(),
      config.getBackupCleanTime(),
      config.getBackupDeletionThreads(),
      config.getMaxCompletedTransactionAge());
}

代码示例来源：origin: prestosql/presto

outputStorageFormat.getOutputFormat(),
writerImplementation,
nodeManager.getCurrentNode().getVersion(),
nodeManager.getCurrentNode().getHttpUri().getHost(),
session.getIdentity().getPrincipal().map(Principal::getName).orElse(null),
nodeManager.getEnvironment(),

代码示例来源：origin: prestosql/presto

MBeanServer platformMBeanServer = ManagementFactory.getPlatformMBeanServer();
binder.bind(MBeanServer.class).toInstance(new RebindSafeMBeanServer(platformMBeanServer));
binder.bind(NodeVersion.class).toInstance(new NodeVersion(context.getNodeManager().getCurrentNode().getVersion()));
binder.bind(NodeManager.class).toInstance(context.getNodeManager());
binder.bind(TypeManager.class).toInstance(context.getTypeManager());

代码示例来源：origin: prestosql/presto

TypeManager typeManager)
this(nodeManager.getCurrentNode().getNodeIdentifier(),
    storageService,
    backupStore,

代码示例来源：origin: prestosql/presto

RaptorConnectorId connectorId)
this(nodeManager.getCurrentNode().getNodeIdentifier(),
    nodeSupplier,
    shardManager,

代码示例来源：origin: prestosql/presto

nodeManager.getCurrentNode().getNodeIdentifier(),
nodeManager::getWorkerNodes,
shardManager,