Package com.dp.nebula.wormhole.common

Examples of com.dp.nebula.wormhole.common.DefaultLine.addField()

101
102
103
104
105
106
107
108
109
110
111
        while(iterator.hasNext()) {
          String lineData = iterator.nextLine();
          ILine line = new DefaultLine();
          for(String field:lineData.split(String.valueOf(DEP))){
            if(field.equals("\\N")){
              line.addField(null);
            } else {
              line.addField(pgStringNormalize(field));
            }
          }
          sender.send(line);
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
          ILine line = new DefaultLine();
          for(String field:lineData.split(String.valueOf(DEP))){
            if(field.equals("\\N")){
              line.addField(null);
            } else {
              line.addField(pgStringNormalize(field));
            }
          }
          sender.send(line);
          sucLineCounter ++;
        }
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
    }

    private List<ILine> generateDatas() {
      List<ILine> datas = new ArrayList<ILine>();
        ILine data = new DefaultLine();
        data.addField("Jim");
        data.addField("21");
        datas.add(data);
        data = new DefaultLine();
        data.addField("Tom");
        data.addField("22");
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
    private List<ILine> generateDatas() {
      List<ILine> datas = new ArrayList<ILine>();
        ILine data = new DefaultLine();
        data.addField("Jim");
        data.addField("21");
        datas.add(data);
        data = new DefaultLine();
        data.addField("Tom");
        data.addField("22");
        datas.add(data);
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
        ILine data = new DefaultLine();
        data.addField("Jim");
        data.addField("21");
        datas.add(data);
        data = new DefaultLine();
        data.addField("Tom");
        data.addField("22");
        datas.add(data);
        data = new DefaultLine();
        data.addField("Jack");
        data.addField("23");
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
        data.addField("Jim");
        data.addField("21");
        datas.add(data);
        data = new DefaultLine();
        data.addField("Tom");
        data.addField("22");
        datas.add(data);
        data = new DefaultLine();
        data.addField("Jack");
        data.addField("23");
        datas.add(data);
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
        data = new DefaultLine();
        data.addField("Tom");
        data.addField("22");
        datas.add(data);
        data = new DefaultLine();
        data.addField("Jack");
        data.addField("23");
        datas.add(data);
        return datas;
    }
   
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
        data.addField("Tom");
        data.addField("22");
        datas.add(data);
        data = new DefaultLine();
        data.addField("Jack");
        data.addField("23");
        datas.add(data);
        return datas;
    }
   
    @Test
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
    SingleQueue dq = new SingleQueue(200,1024*200);
    ILine[] setLines,getLines = null;
    setLines = new ILine[10];
    getLines = new ILine[10];
    ILine item1 = new DefaultLine();
    item1.addField("1");
    item1.addField("sunny");
    ILine item2 = new DefaultLine();
    item2.addField("2");
    item2.addField("jack");
    setLines[0]=item1;
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
    ILine[] setLines,getLines = null;
    setLines = new ILine[10];
    getLines = new ILine[10];
    ILine item1 = new DefaultLine();
    item1.addField("1");
    item1.addField("sunny");
    ILine item2 = new DefaultLine();
    item2.addField("2");
    item2.addField("jack");
    setLines[0]=item1;
    setLines[1]=item2;
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.