Examples of addColumnValue()

Examples of com.manning.hip.common.PaddedTable.addColumnValue()

107
108
109
110
111
112
113
114
115
116
117
      minVal = minVal == null ? v : Math.min(minVal, v);
      maxVal = maxVal == null ? v : Math.max(maxVal, v);
      totalVals += v;

      table.newRow();
      table.addColumnValue(m.getType())
          .addColumnValue(m.getTaskId())
          .addColumnValue(m.getStatus())
          .addColumnValue(m.getHost())
          .addColumnValue(JobHistoryHelper.formatTime(
              m.getOverallTimeMillis()));
View Full Code Here

Examples of com.manning.hip.common.PaddedTable.addColumnValue()

115
116
117
118
119
120
121
122
123
124
125
          .addColumnValue(m.getHost())
          .addColumnValue(JobHistoryHelper.formatTime(
              m.getOverallTimeMillis()));

      if(isReduce) {
        table.addColumnValue(JobHistoryHelper.formatTime(
            m.getShuffleTimeMillis()))
            .addColumnValue(JobHistoryHelper.formatTime(
                m.getSortTimeMillis()));
      }
View Full Code Here

Examples of com.manning.hip.common.PaddedTable.addColumnValue()

121
122
123
124
125
126
127
128
129
130
131
            m.getShuffleTimeMillis()))
            .addColumnValue(JobHistoryHelper.formatTime(
                m.getSortTimeMillis()));
      }

          table.addColumnValue(m.getInputBytes())
          .addColumnValue(m.getOutputBytes())
          .addColumnValue(m.getInputRecords())
          .addColumnValue(m.getOutputRecords())
          .addColumnValue(m.getOverallThroughputBytesPerSecond());
View Full Code Here

Examples of com.manning.hip.common.PaddedTable.addColumnValue()

128
129
130
131
132
133
134
135
136
137
138
          .addColumnValue(m.getInputRecords())
          .addColumnValue(m.getOutputRecords())
          .addColumnValue(m.getOverallThroughputBytesPerSecond());

      if(isReduce) {
        table.addColumnValue(m.getShuffleThroughputBytesPerSecond())
            .addColumnValue(m.getSortThroughputBytesPerSecond())
            .addColumnValue(m.getReduceThroughputBytesPerSecond());
      }
    }
View Full Code Here

Examples of com.manning.hip.common.PaddedTable.addColumnValue()

100
101
102
103
104
105
106
107
108
109
110
      minVal = minVal == null ? v : Math.min(minVal, v);
      maxVal = maxVal == null ? v : Math.max(maxVal, v);
      totalVals += v;

      table.newRow();
      table.addColumnValue(m.getType())
          .addColumnValue(m.getTaskId())
          .addColumnValue(m.getStatus())
          .addColumnValue(m.getHost())
          .addColumnValue(JobHistoryHelper.formatTime(
              m.getOverallTimeMillis()))
View Full Code Here

Examples of liquibase.statement.core.InsertOrUpdateStatement.addColumnValue()

15
16
17
18
19
20
21
22
23
24
25
    @Test
    public void ContainsInsertStatement(){
        OracleDatabase database = new OracleDatabase();
        InsertOrUpdateGeneratorOracle generator = new InsertOrUpdateGeneratorOracle();
        InsertOrUpdateStatement statement = new InsertOrUpdateStatement("mycatalog", "myschema","mytable","pk_col1");
        statement.addColumnValue("pk_col1","value1");
        statement.addColumnValue("col2","value2");
        Sql[] sql = generator.generateSql( statement, database,  null);
        String theSql = sql[0].toSql();
        assertTrue(theSql.contains("INSERT INTO mycatalog.mytable (pk_col1, col2) VALUES ('value1', 'value2');"));
        assertTrue(theSql.contains("UPDATE mycatalog.mytable"));
View Full Code Here

Examples of liquibase.statement.core.InsertOrUpdateStatement.addColumnValue()

16
17
18
19
20
21
22
23
24
25
26
    public void ContainsInsertStatement(){
        OracleDatabase database = new OracleDatabase();
        InsertOrUpdateGeneratorOracle generator = new InsertOrUpdateGeneratorOracle();
        InsertOrUpdateStatement statement = new InsertOrUpdateStatement("mycatalog", "myschema","mytable","pk_col1");
        statement.addColumnValue("pk_col1","value1");
        statement.addColumnValue("col2","value2");
        Sql[] sql = generator.generateSql( statement, database,  null);
        String theSql = sql[0].toSql();
        assertTrue(theSql.contains("INSERT INTO mycatalog.mytable (pk_col1, col2) VALUES ('value1', 'value2');"));
        assertTrue(theSql.contains("UPDATE mycatalog.mytable"));
        String[] sqlLines = theSql.split("\n");
View Full Code Here

Examples of liquibase.statement.core.InsertOrUpdateStatement.addColumnValue()

77
78
79
80
81
82
83
84
85
86
87
    @Test
    public void testOnlyUpdateFlag(){
        OracleDatabase database = new OracleDatabase();
        InsertOrUpdateGeneratorOracle generator = new InsertOrUpdateGeneratorOracle();
        InsertOrUpdateStatement statement = new InsertOrUpdateStatement("mycatalog", "myschema","mytable","pk_col1", true);
        statement.addColumnValue("pk_col1","value1");
        statement.addColumnValue("col2","value2");
        Sql[] sql = generator.generateSql( statement, database,  null);
        String theSql = sql[0].toSql();
        assertFalse("should not have had insert statement",theSql.contains("INSERT INTO mycatalog.mytable (pk_col1, col2) VALUES ('value1', 'value2');"));
        assertTrue("missing update statement", theSql.contains("UPDATE mycatalog.mytable"));
View Full Code Here

Examples of liquibase.statement.core.InsertOrUpdateStatement.addColumnValue()

78
79
80
81
82
83
84
85
86
87
88
    public void testOnlyUpdateFlag(){
        OracleDatabase database = new OracleDatabase();
        InsertOrUpdateGeneratorOracle generator = new InsertOrUpdateGeneratorOracle();
        InsertOrUpdateStatement statement = new InsertOrUpdateStatement("mycatalog", "myschema","mytable","pk_col1", true);
        statement.addColumnValue("pk_col1","value1");
        statement.addColumnValue("col2","value2");
        Sql[] sql = generator.generateSql( statement, database,  null);
        String theSql = sql[0].toSql();
        assertFalse("should not have had insert statement",theSql.contains("INSERT INTO mycatalog.mytable (pk_col1, col2) VALUES ('value1', 'value2');"));
        assertTrue("missing update statement", theSql.contains("UPDATE mycatalog.mytable"));
        String[] sqlLines = theSql.split("\n");
View Full Code Here

Examples of liquibase.statement.core.InsertOrUpdateStatement.addColumnValue()

19
20
21
22
23
24
25
26
27
28
29
    public void getRecordCheck(){
        InsertOrUpdateGeneratorMSSQL generator = new InsertOrUpdateGeneratorMSSQL();
        MSSQLDatabase database = new MSSQLDatabase();

        InsertOrUpdateStatement statement = new InsertOrUpdateStatement("mycatalog", "myschema","mytable","pk_col1");
        statement.addColumnValue("pk_col1","value1");
        statement.addColumnValue("col2","value2");

        String where = "1 = 1";

        String recordCheck = (String)invokePrivateMethod(generator,"getRecordCheck", new Object[] {statement,database,where});
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.