Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 /*
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  *     http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.facebook.presto.metadata;
public class InMemoryNodeManager
        implements InternalNodeManager
    private final Node localNode;
    private final SetMultimap<StringNoderemoteNodes = Multimaps.synchronizedSetMultimap(HashMultimap.<StringNode>create());
    @Inject
    public InMemoryNodeManager()
    {
        this(URI.create("local://127.0.0.1"));
    }
    public InMemoryNodeManager(URI localUri)
    {
         = new PrestoNode("local"localUri.);
    }
    public void addCurrentNodeDatasource(String datasourceName)
    {
        addNode(datasourceName);
    }
    public void addNode(String datasourceNameNode... nodes)
    {
        addNode(datasourceName, ImmutableList.copyOf(nodes));
    }
    public void addNode(String datasourceNameIterable<Nodenodes)
    {
        .putAll(datasourceNamenodes);
    }
    @Override
    public Set<NodegetActiveNodes()
    {
        return getAllNodes().getActiveNodes();
    }
    @Override
    public Set<NodegetActiveDatasourceNodes(String datasourceName)
    {
        return ImmutableSet.copyOf(.get(datasourceName));
    }
    @Override
    public AllNodes getAllNodes()
    {
        return new AllNodes(ImmutableSet.<Node>builder().add().addAll(.values()).build(), ImmutableSet.<Node>of());
    }
    @Override
    public Node getCurrentNode()
    {
        return ;
    }
    @Override
    public Set<NodegetCoordinators()
    {
        // always use localNode as coordinator
        return ImmutableSet.of();
    }
    @Override
    public void refreshNodes()
    {
        // no-op
    }
New to GrepCode? Check out our FAQ X