本文整理了Java中io.prestosql.spi.Node.isCoordinator()
方法的一些代码示例,展示了Node.isCoordinator()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Node.isCoordinator()
方法的具体详情如下:
包路径:io.prestosql.spi.Node
类名称: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()),
内容来源于网络,如有侵权,请联系作者删除!