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

Node.isCoordinator介绍

暂无

代码示例

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

@Inject
public TaskCountEstimator(NodeSchedulerConfig nodeSchedulerConfig, InternalNodeManager nodeManager)
{
  requireNonNull(nodeSchedulerConfig, "nodeSchedulerConfig is null");
  requireNonNull(nodeManager, "nodeManager is null");
  this.numberOfNodes = () -> {
    Set<Node> activeNodes = nodeManager.getAllNodes().getActiveNodes();
    if (nodeSchedulerConfig.isIncludeCoordinator()) {
      return activeNodes.size();
    }
    return toIntExact(activeNodes.stream()
        .filter(node -> !node.isCoordinator())
        .count());
  };
}

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

@Inject
public TaskCountEstimator(NodeSchedulerConfig nodeSchedulerConfig, InternalNodeManager nodeManager)
{
  requireNonNull(nodeSchedulerConfig, "nodeSchedulerConfig is null");
  requireNonNull(nodeManager, "nodeManager is null");
  this.numberOfNodes = () -> {
    Set<Node> activeNodes = nodeManager.getAllNodes().getActiveNodes();
    if (nodeSchedulerConfig.isIncludeCoordinator()) {
      return activeNodes.size();
    }
    return toIntExact(activeNodes.stream()
        .filter(node -> !node.isCoordinator())
        .count());
  };
}

代码示例来源：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

@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

private synchronized void announceNodes(Set<Node> activeNodes, Set<Node> inactiveNodes)
{
  ImmutableList.Builder<ServiceDescriptor> descriptors = ImmutableList.builder();
  for (Node node : Iterables.concat(activeNodes, inactiveNodes)) {
    descriptors.add(serviceDescriptor("presto")
        .setNodeId(node.getNodeIdentifier())
        .addProperty("http", node.getHttpUri().toString())
        .addProperty("node_version", ((PrestoNode) node).getNodeVersion().toString())
        .addProperty("coordinator", String.valueOf(node.isCoordinator()))
        .build());
  }
  this.descriptors = descriptors.build();
}

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

private synchronized void announceNodes(Set<Node> activeNodes, Set<Node> inactiveNodes)
{
  ImmutableList.Builder<ServiceDescriptor> descriptors = ImmutableList.builder();
  for (Node node : Iterables.concat(activeNodes, inactiveNodes)) {
    descriptors.add(serviceDescriptor("presto")
        .setNodeId(node.getNodeIdentifier())
        .addProperty("http", node.getHttpUri().toString())
        .addProperty("node_version", ((PrestoNode) node).getNodeVersion().toString())
        .addProperty("coordinator", String.valueOf(node.isCoordinator()))
        .build());
  }
  this.descriptors = descriptors.build();
}

代码示例来源：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: io.prestosql/presto-main

SystemTablesProvider systemTablesProvider;
if (nodeManager.getCurrentNode().isCoordinator()) {
  systemTablesProvider = new DelegatingSystemTablesProvider(
      new StaticSystemTablesProvider(connector.getSystemTables()),

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

SystemTablesProvider systemTablesProvider;
if (nodeManager.getCurrentNode().isCoordinator()) {
  systemTablesProvider = new DelegatingSystemTablesProvider(
      new StaticSystemTablesProvider(connector.getSystemTables()),