Examples of single()

Examples of com.alibaba.otter.node.etl.load.loader.weight.WeightBarrier.single()

43
44
45
46
47
48
49
50
51
52
53
            executor.submit(new Callable() {

                public Object call() throws Exception {
                    Thread.sleep(1000);
                    barrier.single(11);
                    count.countDown();
                    return null;
                }
            });
View Full Code Here

Examples of com.alibaba.otter.node.etl.load.loader.weight.WeightBarrier.single()

78
79
80
81
82
83
84
85
86
87
88
                    }
                });
            }
            Thread.sleep(1000);
            for (int i = 0; i < 10; i++) {
                barrier.single(i);
            }
            count.await();
            executor.shutdown();
        } catch (InterruptedException e) {
            want.fail();
View Full Code Here

Examples of com.alibaba.otter.shared.arbitrate.impl.setl.monitor.MainstemMonitor.single()

88
89
90
91
92
93
94
95
96
97
98
    /**
     * 更新mainStem的同步状态数据
     */
    public void single(MainStemEventData data) {
        MainstemMonitor mainstemMonitor = ArbitrateFactory.getInstance(data.getPipelineId(), MainstemMonitor.class);
        mainstemMonitor.single(data);
    }

    /**
     * 释放mainStem的节点，重新选择工作节点
     */
 
View Full Code Here

Examples of org.intellij.grammar.generator.RuleGraphHelper.Cardinality.single()

479
480
481
482
483
484
485
486
487
488
489
      Map<PsiElement, Cardinality> map = psiMap();
      boolean leftMarker = m.containsKey(LEFT_MARKER);
      for (PsiElement t : m.keySet()) {
        Cardinality joinedCard = fromNodeType(type).and(m.get(t));
        if (leftMarker) {
          joinedCard = joinedCard.single();
        }
        map.put(t, joinedCard);
      }
      return map;
    }
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.