Package com.dp.nebula.wormhole.common.interfaces

Examples of com.dp.nebula.wormhole.common.interfaces.ILine.addField()

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
326
327
328
329
330
331
332
333
334
335
336
      int begin = 0;
      int i = 0;
      if (!colListSet) {
        for (i = 0; i < s.length(); ++i) {
          if (s.charAt(i) == fieldSplit) {
            line.addField(replace(s.substring(begin, i)));
            begin = i + 1;
          }
        }
        // last field
        line.addField(replace(s.substring(begin, i)));
View Full Code Here
331
332
333
334
335
336
337
338
339
340
341
            line.addField(replace(s.substring(begin, i)));
            begin = i + 1;
          }
        }
        // last field
        line.addField(replace(s.substring(begin, i)));
      } else {
        int colIndex = 0;
        for (i = 0; i < s.length(); ++i) {
          if (s.charAt(i) == fieldSplit) {
            if (colList[colIndex] >= 0) {
View Full Code Here
337
338
339
340
341
342
343
344
345
346
347
      } else {
        int colIndex = 0;
        for (i = 0; i < s.length(); ++i) {
          if (s.charAt(i) == fieldSplit) {
            if (colList[colIndex] >= 0) {
              line.addField(replace(s.substring(begin, i)),
                  colList[colIndex]);
            }
            begin = i + 1;
            colIndex++;
          }
View Full Code Here
345
346
347
348
349
350
351
352
353
354
355
            begin = i + 1;
            colIndex++;
          }
        }
        if (colList[colIndex] >= 0) {
          line.addField(replace(s.substring(begin, i)),
              colList[colIndex]);
        }
        // add constant columns
        for (Integer k : constColMap.keySet()) {
          line.addField(constColMap.get(k), k);
View Full Code Here
350
351
352
353
354
355
356
357
358
359
360
          line.addField(replace(s.substring(begin, i)),
              colList[colIndex]);
        }
        // add constant columns
        for (Integer k : constColMap.keySet()) {
          line.addField(constColMap.get(k), k);
        }
      }
      boolean flag = sender.send(line);

      if (flag) {
View Full Code Here
14
15
16
17
18
19
20
21
22
23
24
  @Test
  public void queueTest(){
    SingleQueue dq = new SingleQueue(200,1024*200);
    ILine setLine,getLine = null;
    setLine = new DefaultLine();
    setLine.addField("1");
    setLine.addField("sunny");
    try {
      dq.push(setLine, 1, TimeUnit.MILLISECONDS);
      getLine = dq.pull(1, TimeUnit.MILLISECONDS);
    } catch (InterruptedException e) {
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.