本文整理了Java中io.prestosql.spi.Node.getNodeIdentifier()
方法的一些代码示例,展示了Node.getNodeIdentifier()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Node.getNodeIdentifier()
方法的具体详情如下:
包路径:io.prestosql.spi.Node
类名称:Node
方法名:getNodeIdentifier
暂无
代码示例来源:origin: io.prestosql/presto-main
public int getQueuedSplitCountForStage(Node node)
{
return queuedSplitCountByNode.getOrDefault(node.getNodeIdentifier(), 0) + assignmentCount.getOrDefault(node, 0);
}
代码示例来源:origin: prestosql/presto
public int getQueuedSplitCountForStage(Node node)
{
return queuedSplitCountByNode.getOrDefault(node.getNodeIdentifier(), 0) + assignmentCount.getOrDefault(node, 0);
}
代码示例来源: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
@Override
public URI createTaskLocation(Node node, TaskId taskId)
{
return URI.create("http://fake.invalid/task/" + node.getNodeIdentifier() + "/" + taskId);
}
代码示例来源:origin: io.prestosql/presto-main
@Override
public URI createTaskLocation(Node node, TaskId taskId)
{
return URI.create("http://fake.invalid/task/" + node.getNodeIdentifier() + "/" + taskId);
}
代码示例来源:origin: io.prestosql/presto-main
@Override
public URI createMemoryInfoLocation(Node node)
{
return URI.create("http://fake.invalid/" + node.getNodeIdentifier() + "/memory");
}
}
代码示例来源:origin: prestosql/presto
@Override
public URI createMemoryInfoLocation(Node node)
{
return URI.create("http://fake.invalid/" + node.getNodeIdentifier() + "/memory");
}
}
代码示例来源:origin: io.prestosql/presto-main
public static ResettableRandomizedIterator<Node> randomizedNodes(NodeMap nodeMap, boolean includeCoordinator, Set<Node> excludedNodes)
{
ImmutableList<Node> nodes = nodeMap.getNodesByHostAndPort().values().stream()
.filter(node -> includeCoordinator || !nodeMap.getCoordinatorNodeIds().contains(node.getNodeIdentifier()))
.filter(node -> !excludedNodes.contains(node))
.collect(toImmutableList());
return new ResettableRandomizedIterator<>(nodes);
}
代码示例来源:origin: prestosql/presto
public static ResettableRandomizedIterator<Node> randomizedNodes(NodeMap nodeMap, boolean includeCoordinator, Set<Node> excludedNodes)
{
ImmutableList<Node> nodes = nodeMap.getNodesByHostAndPort().values().stream()
.filter(node -> includeCoordinator || !nodeMap.getCoordinatorNodeIds().contains(node.getNodeIdentifier()))
.filter(node -> !excludedNodes.contains(node))
.collect(toImmutableList());
return new ResettableRandomizedIterator<>(nodes);
}
代码示例来源:origin: io.prestosql/presto-main
private void addRows(Builder table, Set<Node> nodes, NodeState state)
{
for (Node node : nodes) {
table.addRow(node.getNodeIdentifier(), node.getHttpUri().toString(), getNodeVersion(node), isCoordinator(node), state.toString().toLowerCase(Locale.ENGLISH));
}
}
代码示例来源:origin: prestosql/presto
private void addRows(Builder table, Set<Node> nodes, NodeState state)
{
for (Node node : nodes) {
table.addRow(node.getNodeIdentifier(), node.getHttpUri().toString(), getNodeVersion(node), isCoordinator(node), state.toString().toLowerCase(Locale.ENGLISH));
}
}
代码示例来源:origin: io.prestosql/presto-main
private Response proxyJsonResponse(String nodeId, String workerPath)
{
Set<Node> nodes = nodeManager.getNodes(NodeState.ACTIVE);
Node node = nodes.stream()
.filter(n -> n.getNodeIdentifier().equals(nodeId))
.findFirst()
.orElseThrow(() -> new WebApplicationException(NOT_FOUND));
Request request = prepareGet()
.setUri(uriBuilderFrom(node.getHttpUri())
.appendPath(workerPath)
.build())
.build();
InputStream responseStream = httpClient.execute(request, new StreamingJsonResponseHandler());
return Response.ok(responseStream, APPLICATION_JSON_TYPE).build();
}
代码示例来源:origin: prestosql/presto
private Response proxyJsonResponse(String nodeId, String workerPath)
{
Set<Node> nodes = nodeManager.getNodes(NodeState.ACTIVE);
Node node = nodes.stream()
.filter(n -> n.getNodeIdentifier().equals(nodeId))
.findFirst()
.orElseThrow(() -> new WebApplicationException(NOT_FOUND));
Request request = prepareGet()
.setUri(uriBuilderFrom(node.getHttpUri())
.appendPath(workerPath)
.build())
.build();
InputStream responseStream = httpClient.execute(request, new StreamingJsonResponseHandler());
return Response.ok(responseStream, APPLICATION_JSON_TYPE).build();
}
代码示例来源: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
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
@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 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
@Test
public void testPredicatePushdown()
throws Exception
{
for (Node node : nodes) {
String nodeIdentifier = node.getNodeIdentifier();
TupleDomain<ColumnHandle> nodeTupleDomain = TupleDomain.fromFixedValues(ImmutableMap.of(columnHandle, NullableValue.of(createUnboundedVarcharType(), utf8Slice(nodeIdentifier))));
ConnectorTableLayoutHandle layout = new JmxTableLayoutHandle(tableHandle, nodeTupleDomain);
ConnectorSplitSource splitSource = splitManager.getSplits(JmxTransactionHandle.INSTANCE, SESSION, layout, UNGROUPED_SCHEDULING);
List<ConnectorSplit> allSplits = getAllSplits(splitSource);
assertEquals(allSplits.size(), 1);
assertEquals(allSplits.get(0).getAddresses().size(), 1);
assertEquals(allSplits.get(0).getAddresses().get(0).getHostText(), nodeIdentifier);
}
}
代码示例来源: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
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();
}
内容来源于网络,如有侵权,请联系作者删除!