Shirly Radco has uploaded a new change for review.

Change subject: history: update buffered cached memory to bigint
......................................................................

history: update buffered cached memory to bigint

Change-Id: If7198285fe6b6102eb38333159b7d76a494b5a92
Bug-Url: https://bugzilla.redhat.com/1231691
Signed-off-by: Shirly Radco <sra...@redhat.com>
---
M etl_export/src/ovirt_engine_dwh/aggregationtodaily_3_6/AggregationToDaily.java
M 
etl_export/src/ovirt_engine_dwh/aggregationtohourly_3_6/AggregationToHourly.java
M etl_export/src/ovirt_engine_dwh/statisticssync_3_6/StatisticsSync.java
A 
packaging/dbscripts/upgrade/03_06_0050_update_buffered_cached_memory_to_bigint.sql
M tos_project/process/AggregationToDaily_3.6.item
M tos_project/process/AggregationToDaily_3.6.properties
M tos_project/process/AggregationToHourly_3.6.item
M tos_project/process/AggregationToHourly_3.6.properties
M tos_project/process/StatisticsSync_3.6.item
M tos_project/process/StatisticsSync_3.6.properties
10 files changed, 602 insertions(+), 309 deletions(-)


  git pull ssh://gerrit.ovirt.org:29418/ovirt-dwh refs/changes/36/42436/1

diff --git 
a/etl_export/src/ovirt_engine_dwh/aggregationtodaily_3_6/AggregationToDaily.java
 
b/etl_export/src/ovirt_engine_dwh/aggregationtodaily_3_6/AggregationToDaily.java
index e56e9c1..364389c 100644
--- 
a/etl_export/src/ovirt_engine_dwh/aggregationtodaily_3_6/AggregationToDaily.java
+++ 
b/etl_export/src/ovirt_engine_dwh/aggregationtodaily_3_6/AggregationToDaily.java
@@ -8789,27 +8789,27 @@
                        return this.current_host_configuration_version;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer max_memory_buffered_kb;
+               public Long max_memory_buffered_kb;
 
-               public Integer getMax_memory_buffered_kb() {
+               public Long getMax_memory_buffered_kb() {
                        return this.max_memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
-               public Integer max_memory_cached_kb;
+               public Long max_memory_cached_kb;
 
-               public Integer getMax_memory_cached_kb() {
+               public Long getMax_memory_cached_kb() {
                        return this.max_memory_cached_kb;
                }
 
@@ -8976,13 +8976,33 @@
 
                                        this.current_host_configuration_version 
= readInteger(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.max_memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.max_memory_buffered_kb = 
null;
+                                       } else {
+                                               this.max_memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
-                                       this.max_memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.max_memory_cached_kb = 
null;
+                                       } else {
+                                               this.max_memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -9107,21 +9127,41 @@
 
                                
writeInteger(this.current_host_configuration_version, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.max_memory_buffered_kb, dos);
+                               if (this.max_memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       
dos.writeLong(this.max_memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.max_memory_cached_kb, dos);
+                               if (this.max_memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       
dos.writeLong(this.max_memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -9312,27 +9352,27 @@
                        return this.current_host_configuration_version;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer max_memory_buffered_kb;
+               public Long max_memory_buffered_kb;
 
-               public Integer getMax_memory_buffered_kb() {
+               public Long getMax_memory_buffered_kb() {
                        return this.max_memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
-               public Integer max_memory_cached_kb;
+               public Long max_memory_cached_kb;
 
-               public Integer getMax_memory_cached_kb() {
+               public Long getMax_memory_cached_kb() {
                        return this.max_memory_cached_kb;
                }
 
@@ -9499,13 +9539,33 @@
 
                                        this.current_host_configuration_version 
= readInteger(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.max_memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.max_memory_buffered_kb = 
null;
+                                       } else {
+                                               this.max_memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
-                                       this.max_memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.max_memory_cached_kb = 
null;
+                                       } else {
+                                               this.max_memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -9630,21 +9690,41 @@
 
                                
writeInteger(this.current_host_configuration_version, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.max_memory_buffered_kb, dos);
+                               if (this.max_memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       
dos.writeLong(this.max_memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.max_memory_cached_kb, dos);
+                               if (this.max_memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       
dos.writeLong(this.max_memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -9811,15 +9891,15 @@
                        return this.current_host_configuration_version;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
@@ -9958,9 +10038,19 @@
 
                                        this.current_host_configuration_version 
= readInteger(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -10049,13 +10139,23 @@
 
                                
writeInteger(this.current_host_configuration_version, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -10218,15 +10318,15 @@
                        return this.current_host_configuration_version;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
@@ -10367,9 +10467,19 @@
 
                                        this.current_host_configuration_version 
= readInteger(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -10462,13 +10572,23 @@
 
                                
writeInteger(this.current_host_configuration_version, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -10818,14 +10938,14 @@
                                        Object currently_running_on_host_last;
                                        Integer vm_configuration_version_last;
                                        Integer 
current_host_configuration_version_last;
-                                       Double memory_buffered_kb_sum;
+                                       BigDecimal memory_buffered_kb_sum;
                                        int memory_buffered_kb_count = 0;
 
-                                       Integer max_memory_buffered_kb_max;
-                                       Double memory_cached_kb_sum;
+                                       Long max_memory_buffered_kb_max;
+                                       BigDecimal memory_cached_kb_sum;
                                        int memory_cached_kb_count = 0;
 
-                                       Integer max_memory_cached_kb_max;
+                                       Long max_memory_cached_kb_max;
 
                                        @Override
                                        public int hashCode() {
@@ -11128,7 +11248,7 @@
 
                                                        if 
(rs_tJDBCInput_4.getObject(15) != null) {
                                                                
row4.memory_buffered_kb = rs_tJDBCInput_4
-                                                                               
.getInt(15);
+                                                                               
.getLong(15);
                                                        } else {
                                                                
row4.memory_buffered_kb = null;
                                                        }
@@ -11139,7 +11259,7 @@
 
                                                        if 
(rs_tJDBCInput_4.getObject(16) != null) {
                                                                
row4.memory_cached_kb = rs_tJDBCInput_4
-                                                                               
.getInt(16);
+                                                                               
.getLong(16);
                                                        } else {
                                                                
row4.memory_cached_kb = null;
                                                        }
@@ -11392,11 +11512,13 @@
                                                                
operation_result_tAggregateRow_4.memory_buffered_kb_count++;
 
                                                                if 
(operation_result_tAggregateRow_4.memory_buffered_kb_sum == null) {
-                                                                       
operation_result_tAggregateRow_4.memory_buffered_kb_sum = (double) 0;
+                                                                       
operation_result_tAggregateRow_4.memory_buffered_kb_sum = new BigDecimal(
+                                                                               
        0);
                                                                }
+                                                               
operation_result_tAggregateRow_4.memory_buffered_kb_sum = 
operation_result_tAggregateRow_4.memory_buffered_kb_sum
+                                                                               
.add(new BigDecimal(
+                                                                               
                String.valueOf(vm_aggregate_history.memory_buffered_kb)));
 
-                                                               if 
(vm_aggregate_history.memory_buffered_kb != null)
-                                                                       
operation_result_tAggregateRow_4.memory_buffered_kb_sum += 
vm_aggregate_history.memory_buffered_kb;
                                                        } // G_OutMain_AggR_546
 
                                                        if 
(vm_aggregate_history.memory_buffered_kb != null) { // G_OutMain_AggR_546
@@ -11415,11 +11537,13 @@
                                                                
operation_result_tAggregateRow_4.memory_cached_kb_count++;
 
                                                                if 
(operation_result_tAggregateRow_4.memory_cached_kb_sum == null) {
-                                                                       
operation_result_tAggregateRow_4.memory_cached_kb_sum = (double) 0;
+                                                                       
operation_result_tAggregateRow_4.memory_cached_kb_sum = new BigDecimal(
+                                                                               
        0);
                                                                }
+                                                               
operation_result_tAggregateRow_4.memory_cached_kb_sum = 
operation_result_tAggregateRow_4.memory_cached_kb_sum
+                                                                               
.add(new BigDecimal(
+                                                                               
                String.valueOf(vm_aggregate_history.memory_cached_kb)));
 
-                                                               if 
(vm_aggregate_history.memory_cached_kb != null)
-                                                                       
operation_result_tAggregateRow_4.memory_cached_kb_sum += 
vm_aggregate_history.memory_cached_kb;
                                                        } // G_OutMain_AggR_546
 
                                                        if 
(vm_aggregate_history.memory_cached_kb != null) { // G_OutMain_AggR_546
@@ -11655,31 +11779,38 @@
                                        row9.current_host_configuration_version 
= aggregated_row_tAggregateRow_4.current_host_configuration_version_last;
                                        if 
(aggregated_row_tAggregateRow_4.memory_buffered_kb_count > 0) {
 
-                                               double 
row9_memory_buffered_kb_temp = (double) 
aggregated_row_tAggregateRow_4.memory_buffered_kb_sum
-                                                               / (double) 
aggregated_row_tAggregateRow_4.memory_buffered_kb_count;
+                                               row9.memory_buffered_kb = 
aggregated_row_tAggregateRow_4.memory_buffered_kb_sum
+                                                               .divide(new 
BigDecimal(
+                                                                               
String.valueOf(aggregated_row_tAggregateRow_4.memory_buffered_kb_count)),
+                                                                               
10, BigDecimal.ROUND_HALF_UP)
 
-                                               row9.memory_buffered_kb = (int) 
row9_memory_buffered_kb_temp;
+                                                               .longValue()
+
+                                               ;
 
                                        } else {
                                                String count = "0";
 
                                                row9.memory_buffered_kb = 
ParserUtils
-                                                               
.parseTo_Integer(count);
+                                                               
.parseTo_Long(count);
 
                                        }
                                        row9.max_memory_buffered_kb = 
aggregated_row_tAggregateRow_4.max_memory_buffered_kb_max;
                                        if 
(aggregated_row_tAggregateRow_4.memory_cached_kb_count > 0) {
 
-                                               double 
row9_memory_cached_kb_temp = (double) 
aggregated_row_tAggregateRow_4.memory_cached_kb_sum
-                                                               / (double) 
aggregated_row_tAggregateRow_4.memory_cached_kb_count;
+                                               row9.memory_cached_kb = 
aggregated_row_tAggregateRow_4.memory_cached_kb_sum
+                                                               .divide(new 
BigDecimal(
+                                                                               
String.valueOf(aggregated_row_tAggregateRow_4.memory_cached_kb_count)),
+                                                                               
10, BigDecimal.ROUND_HALF_UP)
 
-                                               row9.memory_cached_kb = (int) 
row9_memory_cached_kb_temp;
+                                                               .longValue()
+
+                                               ;
 
                                        } else {
                                                String count = "0";
 
-                                               row9.memory_cached_kb = 
ParserUtils
-                                                               
.parseTo_Integer(count);
+                                               row9.memory_cached_kb = 
ParserUtils.parseTo_Long(count);
 
                                        }
                                        row9.max_memory_cached_kb = 
aggregated_row_tAggregateRow_4.max_memory_cached_kb_max;
@@ -11805,26 +11936,27 @@
                                        if (row9.memory_buffered_kb == null) {
                                                pstmt_tJDBCOutput_4.setNull(18, 
java.sql.Types.INTEGER);
                                        } else {
-                                               pstmt_tJDBCOutput_4.setInt(18, 
row9.memory_buffered_kb);
+                                               pstmt_tJDBCOutput_4
+                                                               .setLong(18, 
row9.memory_buffered_kb);
                                        }
 
                                        if (row9.max_memory_buffered_kb == 
null) {
                                                pstmt_tJDBCOutput_4.setNull(19, 
java.sql.Types.INTEGER);
                                        } else {
-                                               pstmt_tJDBCOutput_4.setInt(19,
+                                               pstmt_tJDBCOutput_4.setLong(19,
                                                                
row9.max_memory_buffered_kb);
                                        }
 
                                        if (row9.memory_cached_kb == null) {
                                                pstmt_tJDBCOutput_4.setNull(20, 
java.sql.Types.INTEGER);
                                        } else {
-                                               pstmt_tJDBCOutput_4.setInt(20, 
row9.memory_cached_kb);
+                                               pstmt_tJDBCOutput_4.setLong(20, 
row9.memory_cached_kb);
                                        }
 
                                        if (row9.max_memory_cached_kb == null) {
                                                pstmt_tJDBCOutput_4.setNull(21, 
java.sql.Types.INTEGER);
                                        } else {
-                                               pstmt_tJDBCOutput_4.setInt(21,
+                                               pstmt_tJDBCOutput_4.setLong(21,
                                                                
row9.max_memory_cached_kb);
                                        }
 
@@ -26850,6 +26982,6 @@
        ResumeUtil resumeUtil = null;
 }
 
/************************************************************************************************
- * 767379 characters generated by Talend Open Studio for Data Integration on 
the
- * June 10, 2015 1:47:19 PM IDT
+ * 771525 characters generated by Talend Open Studio for Data Integration on 
the
+ * June 16, 2015 3:03:31 PM IDT
  
************************************************************************************************/
diff --git 
a/etl_export/src/ovirt_engine_dwh/aggregationtohourly_3_6/AggregationToHourly.java
 
b/etl_export/src/ovirt_engine_dwh/aggregationtohourly_3_6/AggregationToHourly.java
index 5f713f3..589841f 100644
--- 
a/etl_export/src/ovirt_engine_dwh/aggregationtohourly_3_6/AggregationToHourly.java
+++ 
b/etl_export/src/ovirt_engine_dwh/aggregationtohourly_3_6/AggregationToHourly.java
@@ -8822,27 +8822,27 @@
                        return this.current_host_configuration_version;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer max_memory_buffered_kb;
+               public Long max_memory_buffered_kb;
 
-               public Integer getMax_memory_buffered_kb() {
+               public Long getMax_memory_buffered_kb() {
                        return this.max_memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
-               public Integer max_memory_cached_kb;
+               public Long max_memory_cached_kb;
 
-               public Integer getMax_memory_cached_kb() {
+               public Long getMax_memory_cached_kb() {
                        return this.max_memory_cached_kb;
                }
 
@@ -9009,13 +9009,33 @@
 
                                        this.current_host_configuration_version 
= readInteger(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.max_memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.max_memory_buffered_kb = 
null;
+                                       } else {
+                                               this.max_memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
-                                       this.max_memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.max_memory_cached_kb = 
null;
+                                       } else {
+                                               this.max_memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -9140,21 +9160,41 @@
 
                                
writeInteger(this.current_host_configuration_version, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.max_memory_buffered_kb, dos);
+                               if (this.max_memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       
dos.writeLong(this.max_memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.max_memory_cached_kb, dos);
+                               if (this.max_memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       
dos.writeLong(this.max_memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -9345,27 +9385,27 @@
                        return this.current_host_configuration_version;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer max_memory_buffered_kb;
+               public Long max_memory_buffered_kb;
 
-               public Integer getMax_memory_buffered_kb() {
+               public Long getMax_memory_buffered_kb() {
                        return this.max_memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
-               public Integer max_memory_cached_kb;
+               public Long max_memory_cached_kb;
 
-               public Integer getMax_memory_cached_kb() {
+               public Long getMax_memory_cached_kb() {
                        return this.max_memory_cached_kb;
                }
 
@@ -9532,13 +9572,33 @@
 
                                        this.current_host_configuration_version 
= readInteger(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.max_memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.max_memory_buffered_kb = 
null;
+                                       } else {
+                                               this.max_memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
-                                       this.max_memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.max_memory_cached_kb = 
null;
+                                       } else {
+                                               this.max_memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -9663,21 +9723,41 @@
 
                                
writeInteger(this.current_host_configuration_version, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.max_memory_buffered_kb, dos);
+                               if (this.max_memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       
dos.writeLong(this.max_memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.max_memory_cached_kb, dos);
+                               if (this.max_memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       
dos.writeLong(this.max_memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -9844,15 +9924,15 @@
                        return this.current_host_configuration_version;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
@@ -9991,9 +10071,19 @@
 
                                        this.current_host_configuration_version 
= readInteger(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -10082,13 +10172,23 @@
 
                                
writeInteger(this.current_host_configuration_version, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -10257,15 +10357,15 @@
                        return this.current_host_configuration_version;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
@@ -10413,9 +10513,19 @@
 
                                        this.current_host_configuration_version 
= readInteger(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -10517,13 +10627,23 @@
 
                                
writeInteger(this.current_host_configuration_version, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -10875,14 +10995,14 @@
                                        Object currently_running_on_host_last;
                                        Integer vm_configuration_version_last;
                                        Integer 
current_host_configuration_version_last;
-                                       Double memory_buffered_kb_sum;
+                                       BigDecimal memory_buffered_kb_sum;
                                        int memory_buffered_kb_count = 0;
 
-                                       Integer max_memory_buffered_kb_max;
-                                       Double memory_cached_kb_sum;
+                                       Long max_memory_buffered_kb_max;
+                                       BigDecimal memory_cached_kb_sum;
                                        int memory_cached_kb_count = 0;
 
-                                       Integer max_memory_cached_kb_max;
+                                       Long max_memory_cached_kb_max;
 
                                        @Override
                                        public int hashCode() {
@@ -11196,7 +11316,7 @@
 
                                                        if 
(rs_tJDBCInput_4.getObject(16) != null) {
                                                                
row4.memory_buffered_kb = rs_tJDBCInput_4
-                                                                               
.getInt(16);
+                                                                               
.getLong(16);
                                                        } else {
                                                                
row4.memory_buffered_kb = null;
                                                        }
@@ -11207,7 +11327,7 @@
 
                                                        if 
(rs_tJDBCInput_4.getObject(17) != null) {
                                                                
row4.memory_cached_kb = rs_tJDBCInput_4
-                                                                               
.getInt(17);
+                                                                               
.getLong(17);
                                                        } else {
                                                                
row4.memory_cached_kb = null;
                                                        }
@@ -11460,11 +11580,13 @@
                                                                
operation_result_tAggregateRow_4.memory_buffered_kb_count++;
 
                                                                if 
(operation_result_tAggregateRow_4.memory_buffered_kb_sum == null) {
-                                                                       
operation_result_tAggregateRow_4.memory_buffered_kb_sum = (double) 0;
+                                                                       
operation_result_tAggregateRow_4.memory_buffered_kb_sum = new BigDecimal(
+                                                                               
        0);
                                                                }
+                                                               
operation_result_tAggregateRow_4.memory_buffered_kb_sum = 
operation_result_tAggregateRow_4.memory_buffered_kb_sum
+                                                                               
.add(new BigDecimal(
+                                                                               
                String.valueOf(vm_aggregate_history.memory_buffered_kb)));
 
-                                                               if 
(vm_aggregate_history.memory_buffered_kb != null)
-                                                                       
operation_result_tAggregateRow_4.memory_buffered_kb_sum += 
vm_aggregate_history.memory_buffered_kb;
                                                        } // G_OutMain_AggR_546
 
                                                        if 
(vm_aggregate_history.memory_buffered_kb != null) { // G_OutMain_AggR_546
@@ -11483,11 +11605,13 @@
                                                                
operation_result_tAggregateRow_4.memory_cached_kb_count++;
 
                                                                if 
(operation_result_tAggregateRow_4.memory_cached_kb_sum == null) {
-                                                                       
operation_result_tAggregateRow_4.memory_cached_kb_sum = (double) 0;
+                                                                       
operation_result_tAggregateRow_4.memory_cached_kb_sum = new BigDecimal(
+                                                                               
        0);
                                                                }
+                                                               
operation_result_tAggregateRow_4.memory_cached_kb_sum = 
operation_result_tAggregateRow_4.memory_cached_kb_sum
+                                                                               
.add(new BigDecimal(
+                                                                               
                String.valueOf(vm_aggregate_history.memory_cached_kb)));
 
-                                                               if 
(vm_aggregate_history.memory_cached_kb != null)
-                                                                       
operation_result_tAggregateRow_4.memory_cached_kb_sum += 
vm_aggregate_history.memory_cached_kb;
                                                        } // G_OutMain_AggR_546
 
                                                        if 
(vm_aggregate_history.memory_cached_kb != null) { // G_OutMain_AggR_546
@@ -11723,31 +11847,38 @@
                                        row9.current_host_configuration_version 
= aggregated_row_tAggregateRow_4.current_host_configuration_version_last;
                                        if 
(aggregated_row_tAggregateRow_4.memory_buffered_kb_count > 0) {
 
-                                               double 
row9_memory_buffered_kb_temp = (double) 
aggregated_row_tAggregateRow_4.memory_buffered_kb_sum
-                                                               / (double) 
aggregated_row_tAggregateRow_4.memory_buffered_kb_count;
+                                               row9.memory_buffered_kb = 
aggregated_row_tAggregateRow_4.memory_buffered_kb_sum
+                                                               .divide(new 
BigDecimal(
+                                                                               
String.valueOf(aggregated_row_tAggregateRow_4.memory_buffered_kb_count)),
+                                                                               
10, BigDecimal.ROUND_HALF_UP)
 
-                                               row9.memory_buffered_kb = (int) 
row9_memory_buffered_kb_temp;
+                                                               .longValue()
+
+                                               ;
 
                                        } else {
                                                String count = "0";
 
                                                row9.memory_buffered_kb = 
ParserUtils
-                                                               
.parseTo_Integer(count);
+                                                               
.parseTo_Long(count);
 
                                        }
                                        row9.max_memory_buffered_kb = 
aggregated_row_tAggregateRow_4.max_memory_buffered_kb_max;
                                        if 
(aggregated_row_tAggregateRow_4.memory_cached_kb_count > 0) {
 
-                                               double 
row9_memory_cached_kb_temp = (double) 
aggregated_row_tAggregateRow_4.memory_cached_kb_sum
-                                                               / (double) 
aggregated_row_tAggregateRow_4.memory_cached_kb_count;
+                                               row9.memory_cached_kb = 
aggregated_row_tAggregateRow_4.memory_cached_kb_sum
+                                                               .divide(new 
BigDecimal(
+                                                                               
String.valueOf(aggregated_row_tAggregateRow_4.memory_cached_kb_count)),
+                                                                               
10, BigDecimal.ROUND_HALF_UP)
 
-                                               row9.memory_cached_kb = (int) 
row9_memory_cached_kb_temp;
+                                                               .longValue()
+
+                                               ;
 
                                        } else {
                                                String count = "0";
 
-                                               row9.memory_cached_kb = 
ParserUtils
-                                                               
.parseTo_Integer(count);
+                                               row9.memory_cached_kb = 
ParserUtils.parseTo_Long(count);
 
                                        }
                                        row9.max_memory_cached_kb = 
aggregated_row_tAggregateRow_4.max_memory_cached_kb_max;
@@ -11873,26 +12004,27 @@
                                        if (row9.memory_buffered_kb == null) {
                                                pstmt_tJDBCOutput_4.setNull(18, 
java.sql.Types.INTEGER);
                                        } else {
-                                               pstmt_tJDBCOutput_4.setInt(18, 
row9.memory_buffered_kb);
+                                               pstmt_tJDBCOutput_4
+                                                               .setLong(18, 
row9.memory_buffered_kb);
                                        }
 
                                        if (row9.max_memory_buffered_kb == 
null) {
                                                pstmt_tJDBCOutput_4.setNull(19, 
java.sql.Types.INTEGER);
                                        } else {
-                                               pstmt_tJDBCOutput_4.setInt(19,
+                                               pstmt_tJDBCOutput_4.setLong(19,
                                                                
row9.max_memory_buffered_kb);
                                        }
 
                                        if (row9.memory_cached_kb == null) {
                                                pstmt_tJDBCOutput_4.setNull(20, 
java.sql.Types.INTEGER);
                                        } else {
-                                               pstmt_tJDBCOutput_4.setInt(20, 
row9.memory_cached_kb);
+                                               pstmt_tJDBCOutput_4.setLong(20, 
row9.memory_cached_kb);
                                        }
 
                                        if (row9.max_memory_cached_kb == null) {
                                                pstmt_tJDBCOutput_4.setNull(21, 
java.sql.Types.INTEGER);
                                        } else {
-                                               pstmt_tJDBCOutput_4.setInt(21,
+                                               pstmt_tJDBCOutput_4.setLong(21,
                                                                
row9.max_memory_cached_kb);
                                        }
 
@@ -27387,6 +27519,6 @@
        ResumeUtil resumeUtil = null;
 }
 
/************************************************************************************************
- * 782290 characters generated by Talend Open Studio for Data Integration on 
the
- * June 10, 2015 1:47:17 PM IDT
+ * 786436 characters generated by Talend Open Studio for Data Integration on 
the
+ * June 16, 2015 3:03:29 PM IDT
  
************************************************************************************************/
diff --git 
a/etl_export/src/ovirt_engine_dwh/statisticssync_3_6/StatisticsSync.java 
b/etl_export/src/ovirt_engine_dwh/statisticssync_3_6/StatisticsSync.java
index 7a97030..4bc6a54 100644
--- a/etl_export/src/ovirt_engine_dwh/statisticssync_3_6/StatisticsSync.java
+++ b/etl_export/src/ovirt_engine_dwh/statisticssync_3_6/StatisticsSync.java
@@ -8604,15 +8604,15 @@
                        return this.current_host_configuration_version;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
@@ -8759,9 +8759,19 @@
 
                                        this.current_host_configuration_version 
= readInteger(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -8863,13 +8873,23 @@
 
                                
writeInteger(this.current_host_configuration_version, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -9210,15 +9230,15 @@
                        return this.running_on_host_join_id;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
@@ -9254,28 +9274,6 @@
                                byte[] byteArray = str.getBytes(utf8Charset);
                                dos.writeInt(byteArray.length);
                                dos.write(byteArray);
-                       }
-               }
-
-               private Integer readInteger(ObjectInputStream dis) throws 
IOException {
-                       Integer intReturn;
-                       int length = 0;
-                       length = dis.readByte();
-                       if (length == -1) {
-                               intReturn = null;
-                       } else {
-                               intReturn = dis.readInt();
-                       }
-                       return intReturn;
-               }
-
-               private void writeInteger(Integer intNum, ObjectOutputStream 
dos)
-                               throws IOException {
-                       if (intNum == null) {
-                               dos.writeByte(-1);
-                       } else {
-                               dos.writeByte(0);
-                               dos.writeInt(intNum);
                        }
                }
 
@@ -9345,9 +9343,19 @@
 
                                        this.running_on_host_join_id = 
readString(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -9450,13 +9458,23 @@
 
                                writeString(this.running_on_host_join_id, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -9619,15 +9637,15 @@
                        return this.running_on_host_join_id;
                }
 
-               public Integer memory_buffered_kb;
+               public Long memory_buffered_kb;
 
-               public Integer getMemory_buffered_kb() {
+               public Long getMemory_buffered_kb() {
                        return this.memory_buffered_kb;
                }
 
-               public Integer memory_cached_kb;
+               public Long memory_cached_kb;
 
-               public Integer getMemory_cached_kb() {
+               public Long getMemory_cached_kb() {
                        return this.memory_cached_kb;
                }
 
@@ -9663,28 +9681,6 @@
                                byte[] byteArray = str.getBytes(utf8Charset);
                                dos.writeInt(byteArray.length);
                                dos.write(byteArray);
-                       }
-               }
-
-               private Integer readInteger(ObjectInputStream dis) throws 
IOException {
-                       Integer intReturn;
-                       int length = 0;
-                       length = dis.readByte();
-                       if (length == -1) {
-                               intReturn = null;
-                       } else {
-                               intReturn = dis.readInt();
-                       }
-                       return intReturn;
-               }
-
-               private void writeInteger(Integer intNum, ObjectOutputStream 
dos)
-                               throws IOException {
-                       if (intNum == null) {
-                               dos.writeByte(-1);
-                       } else {
-                               dos.writeByte(0);
-                               dos.writeInt(intNum);
                        }
                }
 
@@ -9754,9 +9750,19 @@
 
                                        this.running_on_host_join_id = 
readString(dis);
 
-                                       this.memory_buffered_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_buffered_kb = null;
+                                       } else {
+                                               this.memory_buffered_kb = 
dis.readLong();
+                                       }
 
-                                       this.memory_cached_kb = 
readInteger(dis);
+                                       length = dis.readByte();
+                                       if (length == -1) {
+                                               this.memory_cached_kb = null;
+                                       } else {
+                                               this.memory_cached_kb = 
dis.readLong();
+                                       }
 
                                } catch (IOException e) {
                                        throw new RuntimeException(e);
@@ -9859,13 +9865,23 @@
 
                                writeString(this.running_on_host_join_id, dos);
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_buffered_kb, dos);
+                               if (this.memory_buffered_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_buffered_kb);
+                               }
 
-                               // Integer
+                               // Long
 
-                               writeInteger(this.memory_cached_kb, dos);
+                               if (this.memory_cached_kb == null) {
+                                       dos.writeByte(-1);
+                               } else {
+                                       dos.writeByte(0);
+                                       dos.writeLong(this.memory_cached_kb);
+                               }
 
                        } catch (IOException e) {
                                throw new RuntimeException(e);
@@ -10293,7 +10309,7 @@
 
                                                        if 
(rs_tJDBCInput_10.getObject(15) != null) {
                                                                
row12.memory_buffered_kb = rs_tJDBCInput_10
-                                                                               
.getInt(15);
+                                                                               
.getLong(15);
                                                        } else {
                                                                
row12.memory_buffered_kb = null;
                                                        }
@@ -10304,7 +10320,7 @@
 
                                                        if 
(rs_tJDBCInput_10.getObject(16) != null) {
                                                                
row12.memory_cached_kb = rs_tJDBCInput_10
-                                                                               
.getInt(16);
+                                                                               
.getLong(16);
                                                        } else {
                                                                
row12.memory_cached_kb = null;
                                                        }
@@ -10645,7 +10661,7 @@
                                                                        
pstmt_tJDBCOutput_5.setNull(16,
                                                                                
        java.sql.Types.INTEGER);
                                                                } else {
-                                                                       
pstmt_tJDBCOutput_5.setInt(16,
+                                                                       
pstmt_tJDBCOutput_5.setLong(16,
                                                                                
        vm_history.memory_buffered_kb);
                                                                }
 
@@ -10653,7 +10669,7 @@
                                                                        
pstmt_tJDBCOutput_5.setNull(17,
                                                                                
        java.sql.Types.INTEGER);
                                                                } else {
-                                                                       
pstmt_tJDBCOutput_5.setInt(17,
+                                                                       
pstmt_tJDBCOutput_5.setLong(17,
                                                                                
        vm_history.memory_cached_kb);
                                                                }
 
@@ -18077,6 +18093,6 @@
        ResumeUtil resumeUtil = null;
 }
 
/************************************************************************************************
- * 496252 characters generated by Talend Open Studio for Data Integration on 
the
- * June 10, 2015 1:47:12 PM IDT
+ * 497270 characters generated by Talend Open Studio for Data Integration on 
the
+ * June 16, 2015 3:03:23 PM IDT
  
************************************************************************************************/
diff --git 
a/packaging/dbscripts/upgrade/03_06_0050_update_buffered_cached_memory_to_bigint.sql
 
b/packaging/dbscripts/upgrade/03_06_0050_update_buffered_cached_memory_to_bigint.sql
new file mode 100644
index 0000000..1f15ea1
--- /dev/null
+++ 
b/packaging/dbscripts/upgrade/03_06_0050_update_buffered_cached_memory_to_bigint.sql
@@ -0,0 +1,13 @@
+-- Update vm buffered and cached memory to bigint
+
+SELECT fn_db_change_column_type('vm_samples_history', 'memory_buffered_kb', 
'integer', 'bigint');
+SELECT fn_db_change_column_type('vm_samples_history', 'memory_cached_kb', 
'integer', 'bigint');
+SELECT fn_db_change_column_type('vm_hourly_history', 'memory_buffered_kb', 
'integer', 'bigint');
+SELECT fn_db_change_column_type('vm_hourly_history', 'memory_cached_kb', 
'integer', 'bigint');
+SELECT fn_db_change_column_type('vm_daily_history', 'memory_buffered_kb', 
'integer', 'bigint');
+SELECT fn_db_change_column_type('vm_daily_history', 'memory_cached_kb', 
'integer', 'bigint');
+
+SELECT fn_db_change_column_type('vm_hourly_history', 'max_memory_buffered_kb', 
'integer', 'bigint');
+SELECT fn_db_change_column_type('vm_hourly_history', 'max_memory_cached_kb', 
'integer', 'bigint');
+SELECT fn_db_change_column_type('vm_daily_history', 'max_memory_buffered_kb', 
'integer', 'bigint');
+SELECT fn_db_change_column_type('vm_daily_history', 'max_memory_cached_kb', 
'integer', 'bigint');
diff --git a/tos_project/process/AggregationToDaily_3.6.item 
b/tos_project/process/AggregationToDaily_3.6.item
index b9ff040..23d8ff3 100644
--- a/tos_project/process/AggregationToDaily_3.6.item
+++ b/tos_project/process/AggregationToDaily_3.6.item
@@ -1165,8 +1165,8 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
   </node>
   <node componentName="tMap" componentVersion="2.1" offsetLabelX="0" 
offsetLabelY="0" posX="864" posY="320">
@@ -1195,8 +1195,8 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
     <nodeData xsi:type="MapperData">
       <uiProperties shellMaximized="true"/>
@@ -1215,8 +1215,8 @@
         <mapperTableEntries name="currently_running_on_host" 
expression="row4.currently_running_on_host" type="id_Object" nullable="true"/>
         <mapperTableEntries name="vm_configuration_version" 
expression="row4.vm_configuration_version" type="id_Integer" nullable="true"/>
         <mapperTableEntries name="current_host_configuration_version" 
expression="row4.current_host_configuration_version" type="id_Integer" 
nullable="true"/>
-        <mapperTableEntries name="memory_buffered_kb" 
expression="row4.memory_buffered_kb " type="id_Integer" nullable="true"/>
-        <mapperTableEntries name="memory_cached_kb" 
expression="row4.memory_cached_kb " type="id_Integer" nullable="true"/>
+        <mapperTableEntries name="memory_buffered_kb" 
expression="row4.memory_buffered_kb " type="id_Long" nullable="true"/>
+        <mapperTableEntries name="memory_cached_kb" 
expression="row4.memory_cached_kb " type="id_Long" nullable="true"/>
       </outputTables>
       <inputTables sizeState="INTERMEDIATE" name="row4" 
matchingMode="UNIQUE_MATCH" lookupMode="LOAD_ONCE">
         <mapperTableEntries name="history_id" type="id_Long"/>
@@ -1233,8 +1233,8 @@
         <mapperTableEntries name="currently_running_on_host" type="id_Object" 
nullable="true"/>
         <mapperTableEntries name="vm_configuration_version" type="id_Integer" 
nullable="true"/>
         <mapperTableEntries name="current_host_configuration_version" 
type="id_Integer" nullable="true"/>
-        <mapperTableEntries name="memory_buffered_kb" type="id_Integer" 
nullable="true"/>
-        <mapperTableEntries name="memory_cached_kb" type="id_Integer" 
nullable="true"/>
+        <mapperTableEntries name="memory_buffered_kb" type="id_Long" 
nullable="true"/>
+        <mapperTableEntries name="memory_cached_kb" type="id_Long" 
nullable="true"/>
       </inputTables>
     </nodeData>
   </node>
@@ -1346,10 +1346,10 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
   </node>
   <node componentName="tJDBCOutput" componentVersion="0.102" offsetLabelX="0" 
offsetLabelY="0" posX="864" posY="512">
@@ -1503,10 +1503,10 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
     <metadata connector="REJECT" label="vm_daily_history" name="REJECT">
       <column comment="" key="false" length="8" name="history_datetime" 
nullable="false" pattern="&quot;yyyy-MM-dd HH:mm:ss.SSSSSS&quot;" precision="6" 
sourceType="TIMESTAMP" type="id_Date" usefulColumn="true"/>
@@ -1526,10 +1526,10 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
       <column defaultValue="" key="false" length="255" name="errorCode" 
nullable="true" precision="0" sourceType="" type="id_String" 
usefulColumn="true"/>
       <column defaultValue="" key="false" length="255" name="errorMessage" 
nullable="true" precision="0" sourceType="" type="id_String" 
usefulColumn="true"/>
     </metadata>
diff --git a/tos_project/process/AggregationToDaily_3.6.properties 
b/tos_project/process/AggregationToDaily_3.6.properties
index 0b4a7a4..f396319 100644
--- a/tos_project/process/AggregationToDaily_3.6.properties
+++ b/tos_project/process/AggregationToDaily_3.6.properties
@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <xmi:XMI xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI"; 
xmlns:TalendProperties="http://www.talend.org/properties";>
-  <TalendProperties:Property xmi:id="_6qukwEi2EeCv8PaoeAjHHg" 
id="_s0iQoFShEeCW44CWrpjEnA" label="AggregationToDaily" 
creationDate="2011-07-06T14:17:29.833+0300" 
modificationDate="2015-06-04T16:46:52.502+0300" version="3.6" statusCode="" 
item="_6qukwki2EeCv8PaoeAjHHg" displayName="AggregationToDaily">
+  <TalendProperties:Property xmi:id="_6qukwEi2EeCv8PaoeAjHHg" 
id="_s0iQoFShEeCW44CWrpjEnA" label="AggregationToDaily" 
creationDate="2011-07-06T14:17:29.833+0300" 
modificationDate="2015-06-16T14:58:56.061+0300" version="3.6" statusCode="" 
item="_6qukwki2EeCv8PaoeAjHHg" displayName="AggregationToDaily">
     <author href="../talend.project#_SapC4EJlEeCWRqOtaF5m-w"/>
   </TalendProperties:Property>
   <TalendProperties:ItemState xmi:id="_s1bogFShEeCW44CWrpjEnA" path=""/>
diff --git a/tos_project/process/AggregationToHourly_3.6.item 
b/tos_project/process/AggregationToHourly_3.6.item
index 83f7bec..e0ccb69 100644
--- a/tos_project/process/AggregationToHourly_3.6.item
+++ b/tos_project/process/AggregationToHourly_3.6.item
@@ -1170,8 +1170,8 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
   </node>
   <node componentName="tMap" componentVersion="2.1" offsetLabelX="0" 
offsetLabelY="0" posX="864" posY="288">
@@ -1200,8 +1200,8 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
     <nodeData xsi:type="MapperData">
       <uiProperties shellMaximized="true"/>
@@ -1220,8 +1220,8 @@
         <mapperTableEntries name="currently_running_on_host" 
expression="row4.currently_running_on_host" type="id_Object" nullable="true"/>
         <mapperTableEntries name="vm_configuration_version" 
expression="row4.vm_configuration_version" type="id_Integer" nullable="true"/>
         <mapperTableEntries name="current_host_configuration_version" 
expression="row4.current_host_configuration_version" type="id_Integer" 
nullable="true"/>
-        <mapperTableEntries name="memory_buffered_kb" 
expression="row4.memory_buffered_kb " type="id_Integer" nullable="true"/>
-        <mapperTableEntries name="memory_cached_kb" 
expression="row4.memory_cached_kb " type="id_Integer" nullable="true"/>
+        <mapperTableEntries name="memory_buffered_kb" 
expression="row4.memory_buffered_kb " type="id_Long" nullable="true"/>
+        <mapperTableEntries name="memory_cached_kb" 
expression="row4.memory_cached_kb " type="id_Long" nullable="true"/>
       </outputTables>
       <inputTables sizeState="INTERMEDIATE" name="row4" 
matchingMode="UNIQUE_MATCH" lookupMode="LOAD_ONCE">
         <mapperTableEntries name="history_id" type="id_Long"/>
@@ -1239,8 +1239,8 @@
         <mapperTableEntries name="currently_running_on_host" type="id_Object" 
nullable="true"/>
         <mapperTableEntries name="vm_configuration_version" type="id_Integer" 
nullable="true"/>
         <mapperTableEntries name="current_host_configuration_version" 
type="id_Integer" nullable="true"/>
-        <mapperTableEntries name="memory_buffered_kb" type="id_Integer" 
nullable="true"/>
-        <mapperTableEntries name="memory_cached_kb" type="id_Integer" 
nullable="true"/>
+        <mapperTableEntries name="memory_buffered_kb" type="id_Long" 
nullable="true"/>
+        <mapperTableEntries name="memory_cached_kb" type="id_Long" 
nullable="true"/>
       </inputTables>
     </nodeData>
   </node>
@@ -1352,10 +1352,10 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
   </node>
   <node componentName="tJDBCOutput" componentVersion="0.102" offsetLabelX="0" 
offsetLabelY="0" posX="864" posY="480">
@@ -1509,10 +1509,10 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
     <metadata connector="REJECT" label="vm_hourly_history" name="REJECT">
       <column comment="" key="false" length="8" name="history_datetime" 
nullable="false" pattern="&quot;yyyy-MM-dd HH:mm:ss.SSSSSS&quot;" precision="6" 
sourceType="TIMESTAMP" type="id_Date" usefulColumn="true"/>
@@ -1532,10 +1532,10 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_buffered_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="max_memory_cached_kb" 
nullable="true" pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
       <column defaultValue="" key="false" length="255" name="errorCode" 
nullable="true" precision="0" sourceType="" type="id_String" 
usefulColumn="true"/>
       <column defaultValue="" key="false" length="255" name="errorMessage" 
nullable="true" precision="0" sourceType="" type="id_String" 
usefulColumn="true"/>
     </metadata>
diff --git a/tos_project/process/AggregationToHourly_3.6.properties 
b/tos_project/process/AggregationToHourly_3.6.properties
index 317b47c..8e18dce 100644
--- a/tos_project/process/AggregationToHourly_3.6.properties
+++ b/tos_project/process/AggregationToHourly_3.6.properties
@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <xmi:XMI xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI"; 
xmlns:TalendProperties="http://www.talend.org/properties";>
-  <TalendProperties:Property xmi:id="_6qukwEi2EeCv8PaoeAjHHg" 
id="_6qsvkEi2EeCv8PaoeAjHHg" label="AggregationToHourly" 
creationDate="2011-07-06T14:17:18.376+0300" 
modificationDate="2015-06-04T16:42:59.067+0300" version="3.6" statusCode="" 
item="_6qukwki2EeCv8PaoeAjHHg" displayName="AggregationToHourly">
+  <TalendProperties:Property xmi:id="_6qukwEi2EeCv8PaoeAjHHg" 
id="_6qsvkEi2EeCv8PaoeAjHHg" label="AggregationToHourly" 
creationDate="2011-07-06T14:17:18.376+0300" 
modificationDate="2015-06-16T14:54:02.553+0300" version="3.6" statusCode="" 
item="_6qukwki2EeCv8PaoeAjHHg" displayName="AggregationToHourly">
     <author href="../talend.project#_SapC4EJlEeCWRqOtaF5m-w"/>
   </TalendProperties:Property>
   <TalendProperties:ItemState xmi:id="_6qukwUi2EeCv8PaoeAjHHg" path=""/>
diff --git a/tos_project/process/StatisticsSync_3.6.item 
b/tos_project/process/StatisticsSync_3.6.item
index 3c6f613..312cc34 100644
--- a/tos_project/process/StatisticsSync_3.6.item
+++ b/tos_project/process/StatisticsSync_3.6.item
@@ -1144,8 +1144,8 @@
       <column comment="" key="false" name="user_logged_in_to_guest" 
nullable="true" pattern="" sourceType="" type="id_Boolean" usefulColumn="true"/>
       <column comment="" key="false" length="2147483647" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="UUID" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" name="running_on_host_join_id" 
nullable="true" pattern="" sourceType="" type="id_String" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
   </node>
   <node componentName="tMap" componentVersion="2.1" offsetLabelX="0" 
offsetLabelY="0" posX="160" posY="384">
@@ -1176,8 +1176,8 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
     <metadata connector="FLOW" label="vm_disks_usage_samples_history" 
name="disk_usage_history">
       <column comment="" key="false" length="35" name="history_datetime" 
nullable="false" pattern="&quot;dd-MM-yyyy&quot;" precision="6" 
sourceType="TIMESTAMPTZ" type="id_Date" usefulColumn="true"/>
@@ -1203,8 +1203,8 @@
         <mapperTableEntries name="currently_running_on_host" 
expression="row12.currently_running_on_host" type="id_Object" nullable="true"/>
         <mapperTableEntries name="vm_configuration_version" 
expression="row47.history_id " type="id_Integer" nullable="true"/>
         <mapperTableEntries name="current_host_configuration_version" 
expression="row48.history_id " type="id_Integer" nullable="true"/>
-        <mapperTableEntries name="memory_buffered_kb" 
expression="row12.memory_buffered_kb " type="id_Integer" nullable="true"/>
-        <mapperTableEntries name="memory_cached_kb" 
expression="row12.memory_cached_kb " type="id_Integer" nullable="true"/>
+        <mapperTableEntries name="memory_buffered_kb" 
expression="row12.memory_buffered_kb " type="id_Long" nullable="true"/>
+        <mapperTableEntries name="memory_cached_kb" 
expression="row12.memory_cached_kb " type="id_Long" nullable="true"/>
       </outputTables>
       <outputTables sizeState="INTERMEDIATE" name="disk_usage_history">
         <mapperTableEntries name="history_datetime" 
expression="context.runTime" type="id_Date"/>
@@ -1226,8 +1226,8 @@
         <mapperTableEntries name="user_logged_in_to_guest" type="id_Boolean" 
nullable="true"/>
         <mapperTableEntries name="currently_running_on_host" type="id_Object" 
nullable="true"/>
         <mapperTableEntries name="running_on_host_join_id" type="id_String" 
nullable="true"/>
-        <mapperTableEntries name="memory_buffered_kb" type="id_Integer" 
nullable="true"/>
-        <mapperTableEntries name="memory_cached_kb" type="id_Integer" 
nullable="true"/>
+        <mapperTableEntries name="memory_buffered_kb" type="id_Long" 
nullable="true"/>
+        <mapperTableEntries name="memory_cached_kb" type="id_Long" 
nullable="true"/>
       </inputTables>
       <inputTables sizeState="INTERMEDIATE" name="row47" 
activateCondensedTool="true" matchingMode="UNIQUE_MATCH" lookupMode="LOAD_ONCE" 
innerJoin="true">
         <mapperTableEntries name="history_id" expression="" type="id_Integer" 
nullable="true"/>
@@ -1447,8 +1447,8 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
     </metadata>
     <metadata connector="REJECT" label="vm_samples_history" name="REJECT">
       <column comment="" key="false" length="8" name="history_datetime" 
nullable="false" pattern="&quot;yyyy-MM-dd HH:mm:ss.SSSSSS&quot;" precision="6" 
sourceType="TIMESTAMP" type="id_Date" usefulColumn="true"/>
@@ -1466,8 +1466,8 @@
       <column comment="" key="false" length="16" 
name="currently_running_on_host" nullable="true" pattern="" precision="0" 
sourceType="POINT" type="id_Object" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="vm_configuration_version" nullable="true" pattern="" precision="0" 
sourceType="INT4" type="id_Integer" usefulColumn="true"/>
       <column comment="" key="false" length="4" 
name="current_host_configuration_version" nullable="true" pattern="" 
precision="0" sourceType="INT4" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
-      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Integer" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_buffered_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
+      <column comment="" key="false" name="memory_cached_kb" nullable="true" 
pattern="" sourceType="" type="id_Long" usefulColumn="true"/>
       <column defaultValue="" key="false" length="255" name="errorCode" 
nullable="true" precision="0" sourceType="" type="id_String" 
usefulColumn="true"/>
       <column defaultValue="" key="false" length="255" name="errorMessage" 
nullable="true" precision="0" sourceType="" type="id_String" 
usefulColumn="true"/>
     </metadata>
diff --git a/tos_project/process/StatisticsSync_3.6.properties 
b/tos_project/process/StatisticsSync_3.6.properties
index 97fcb24..5140f0d 100644
--- a/tos_project/process/StatisticsSync_3.6.properties
+++ b/tos_project/process/StatisticsSync_3.6.properties
@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <xmi:XMI xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI"; 
xmlns:TalendProperties="http://www.talend.org/properties";>
-  <TalendProperties:Property xmi:id="_oWT9MVRyEeCEMvYqeevraA" 
id="_oWT9MFRyEeCEMvYqeevraA" label="StatisticsSync" 
creationDate="2011-07-06T14:16:52.840+0300" 
modificationDate="2015-06-04T16:26:28.566+0300" version="3.6" statusCode="" 
item="_oWT9M1RyEeCEMvYqeevraA" displayName="StatisticsSync">
+  <TalendProperties:Property xmi:id="_oWT9MVRyEeCEMvYqeevraA" 
id="_oWT9MFRyEeCEMvYqeevraA" label="StatisticsSync" 
creationDate="2011-07-06T14:16:52.840+0300" 
modificationDate="2015-06-16T14:51:18.650+0300" version="3.6" statusCode="" 
item="_oWT9M1RyEeCEMvYqeevraA" displayName="StatisticsSync">
     <author href="../talend.project#_SapC4EJlEeCWRqOtaF5m-w"/>
   </TalendProperties:Property>
   <TalendProperties:ItemState xmi:id="_oWT9MlRyEeCEMvYqeevraA" path=""/>


-- 
To view, visit https://gerrit.ovirt.org/42436
To unsubscribe, visit https://gerrit.ovirt.org/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: If7198285fe6b6102eb38333159b7d76a494b5a92
Gerrit-PatchSet: 1
Gerrit-Project: ovirt-dwh
Gerrit-Branch: master
Gerrit-Owner: Shirly Radco <sra...@redhat.com>
_______________________________________________
Engine-patches mailing list
Engine-patches@ovirt.org
http://lists.ovirt.org/mailman/listinfo/engine-patches

Reply via email to