Examples of LoadBanlanceAlgorithm

Examples of com.alibaba.otter.shared.common.model.config.pipeline.PipelineParameter.LoadBanlanceAlgorithm

30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
*/
public class LoadBalanceFactory {

    public static Node getNextExtractNode(Long pipelineId) throws InterruptedException {
        Pipeline pipeline = ArbitrateConfigUtils.getPipeline(pipelineId);
        LoadBanlanceAlgorithm loadBanlanceAlgorithm = pipeline.getParameters().getLbAlgorithm();
        LoadBalance loadbalance = null;
        if (loadBanlanceAlgorithm.isRandom()) {
            loadbalance = ArbitrateFactory.getInstance(pipelineId, ExtractRandomLoadBanlance.class);
        } else if (loadBanlanceAlgorithm.isRoundRbin()) {
            loadbalance = ArbitrateFactory.getInstance(pipelineId, ExtractRoundRobinLoadBalance.class);
        } else {
            loadbalance = ArbitrateFactory.getInstance(pipelineId, ExtractStickLoadBalance.class);
        }
        Node node = loadbalance.next();// 获取下一个处理节点信息
View Full Code Here

Examples of com.alibaba.otter.shared.common.model.config.pipeline.PipelineParameter.LoadBanlanceAlgorithm

45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
        return node;
    }

    public static Node getNextTransformNode(Long pipelineId) throws InterruptedException {
        Pipeline pipeline = ArbitrateConfigUtils.getPipeline(pipelineId);
        LoadBanlanceAlgorithm loadBanlanceAlgorithm = pipeline.getParameters().getLbAlgorithm();
        LoadBalance loadbalance = null;
        if (loadBanlanceAlgorithm.isRandom()) {
            loadbalance = ArbitrateFactory.getInstance(pipelineId, TransformRandomLoadBanlance.class);
        } else if (loadBanlanceAlgorithm.isRoundRbin()) {
            loadbalance = ArbitrateFactory.getInstance(pipelineId, TransformRoundRobinLoadBalance.class);
        } else {
            loadbalance = ArbitrateFactory.getInstance(pipelineId, TransformStickLoadBalance.class);
        }
        Node node = loadbalance.next();// 获取下一个处理节点信息
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.