Examples of ClusterCoordinator

Examples of org.apache.drill.exec.coord.ClusterCoordinator

32
33
34
35
36
37
38
39
40
41
42
  static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(ZkPStoreProvider.class);

  private final CuratorFramework curator;

  public ZkPStoreProvider(PStoreRegistry registry) throws DrillbitStartupException {
    ClusterCoordinator coord = registry.getClusterCoordinator();
    if (!(coord instanceof ZKClusterCoordinator)) {
      throw new DrillbitStartupException("A ZkPStoreProvider was created without a ZKClusterCoordinator.");
    }
    this.curator = ((ZKClusterCoordinator)registry.getClusterCoordinator()).getCurator();
  }
View Full Code Here

Examples of org.apache.drill.exec.coord.ClusterCoordinator

55
56
57
58
59
60
61
62
63
  @Path("/query.json")
  @Consumes(MediaType.APPLICATION_JSON)
  @Produces(MediaType.APPLICATION_JSON)
  public List<Map<String, Object>> submitQueryJSON(QueryWrapper query) throws Exception {
    final DrillConfig config = work.getContext().getConfig();
    final ClusterCoordinator coordinator = work.getContext().getClusterCoordinator();
    final BufferAllocator allocator = work.getContext().getAllocator();
    return query.run(config, coordinator, allocator);
  }
View Full Code Here

Examples of org.apache.drill.exec.coord.ClusterCoordinator

80
81
82
83
84
85
86
87
88
89
90
        this.hbaseConf.set(entry.getKey(), String.valueOf(entry.getValue()));
      }
    }
    this.storeTableName = registry.getConfig().getString(DrillHBaseConstants.SYS_STORE_PROVIDER_HBASE_TABLE);

    ClusterCoordinator coord = registry.getClusterCoordinator();
    if ((coord instanceof ZKClusterCoordinator)) {
      this.localEStoreProvider = null;
      this.zkEStoreProvider = new ZkEStoreProvider(((ZKClusterCoordinator)registry.getClusterCoordinator()).getCurator());
      this.zkAvailable = true;
    } else {
View Full Code Here

Examples of org.apache.drill.exec.coord.ClusterCoordinator

49
50
51
52
53
54
55
56
57
58
59
  private final Path blobRoot;

  private final ZkEStoreProvider zkEStoreProvider;

  public ZkPStoreProvider(PStoreRegistry registry) throws DrillbitStartupException {
    ClusterCoordinator coord = registry.getClusterCoordinator();
    if (!(coord instanceof ZKClusterCoordinator)) {
      throw new DrillbitStartupException("A ZkPStoreProvider was created without a ZKClusterCoordinator.");
    }
    this.curator = ((ZKClusterCoordinator)registry.getClusterCoordinator()).getCurator();
View Full Code Here

Examples of org.apache.drill.exec.coord.ClusterCoordinator

54
55
56
57
58
59
60
61
62
  @Path("/query.json")
  @Consumes(MediaType.APPLICATION_JSON)
  @Produces(MediaType.APPLICATION_JSON)
  public List<Map<String, Object>> submitQueryJSON(QueryWrapper query) throws Exception {
    final DrillConfig config = work.getContext().getConfig();
    final ClusterCoordinator coordinator = work.getContext().getClusterCoordinator();
    final BufferAllocator allocator = work.getContext().getAllocator();
    return query.run(config, coordinator, allocator);
  }
View Full Code Here

Examples of org.olat.commons.coordinate.cluster.ClusterCoordinator

105
106
107
108
109
110
111
112
113
114
115
116
   * @param ureq
   * @param wControl
   */
  public ClusterAdminControllerCluster(UserRequest ureq, WindowControl wControl) {
    super(ureq, wControl);
    ClusterCoordinator clustercoord = (ClusterCoordinator) CoreSpringFactory.getCoreBean(Coordinator.class);
    clusBus = clustercoord.getClusterEventBus();

    mainVc = createVelocityContainer("cluster");
   
   
    // information about the cluster nodes
View Full Code Here

Examples of org.olat.commons.coordinate.cluster.ClusterCoordinator

115
116
117
118
119
120
121
122
123
124
125
126
    }
  }
 
  private ClusterEventBus getClusterEventBus() {
    if (clusterEventBus_==null) {
      ClusterCoordinator clustercoord = (ClusterCoordinator) CoreSpringFactory.getCoreBean(Coordinator.class);
      if (clustercoord!=null) {
        clusterEventBus_ = clustercoord.getClusterEventBus();
      }
    }
    return clusterEventBus_;
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.