fix:GAL-317 离线报告服务支持指定结果储存TTL

1 files changed, 7 insertions, 0 deletions

diff --git a/src/main/java/com/mesa/reportservice/service/impl/HbaseServiceImpl.java b/src/main/java/com/mesa/reportservice/service/impl/HbaseServiceImpl.java
index 8f3ae5a..cb0528f 100644
--- a/src/main/java/com/mesa/reportservice/service/impl/HbaseServiceImpl.java
+++ b/src/main/java/com/mesa/reportservice/service/impl/HbaseServiceImpl.java
@@ -11,6 +11,7 @@ import org.apache.hadoop.hbase.client.Put;
 import org.apache.hadoop.hbase.client.Table;
 import org.apache.hadoop.hbase.util.Bytes;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import java.io.IOException;
@@ -23,6 +24,9 @@ import java.io.IOException;
 @Service
 public class HbaseServiceImpl implements HbaseService {
 
+    @Value("${hbase.cell_ttl}")
+    private Long cellTTL;
+
     @Autowired
     private Connection hbaseConnection;
 
@@ -64,6 +68,9 @@ public class HbaseServiceImpl implements HbaseService {
             if (jobEntity.getMemory_usage() != null) {
                 put.addColumn(Bytes.toBytes("detail"), Bytes.toBytes("memory_usage"), Bytes.toBytes(jobEntity.getMemory_usage()));
             }
+            if (cellTTL != null) {
+                put.setTTL(cellTTL);
+            }
             table.put(put);
             status = true;
         } catch (IOException e) {