Package org.apache.flink.autoscaler.jdbc.state

Class JdbcStateInteractor

  • public class JdbcStateInteractor
extends java.lang.Object
    Responsible for interacting with the database.

    • Constructor Summary

      Constructors 
      Constructor Description
      JdbcStateInteractor​(java.sql.Connection conn)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void createData​(java.lang.String jobKey, java.util.List<StateType> createdStateTypes, java.util.Map<StateType,​java.lang.String> data)  
      void deleteData​(java.lang.String jobKey, java.util.List<StateType> deletedStateTypes)  
      java.util.Map<StateType,​java.lang.String> queryData​(java.lang.String jobKey)  
      void updateData​(java.lang.String jobKey, java.util.List<StateType> updatedStateTypes, java.util.Map<StateType,​java.lang.String> data)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • JdbcStateInteractor

        public JdbcStateInteractor​(java.sql.Connection conn)

    • Method Detail

      • queryData

        public java.util.Map<StateType,​java.lang.String> queryData​(java.lang.String jobKey)
                                                          throws java.lang.Exception
        Throws:
        java.lang.Exception

      • deleteData

        public void deleteData​(java.lang.String jobKey,
                       java.util.List<StateType> deletedStateTypes)
                throws java.lang.Exception
        Throws:
        java.lang.Exception

      • createData

        public void createData​(java.lang.String jobKey,
                       java.util.List<StateType> createdStateTypes,
                       java.util.Map<StateType,​java.lang.String> data)
                throws java.lang.Exception
        Throws:
        java.lang.Exception

      • updateData

        public void updateData​(java.lang.String jobKey,
                       java.util.List<StateType> updatedStateTypes,
                       java.util.Map<StateType,​java.lang.String> data)
                throws java.lang.Exception
        Throws:
        java.lang.Exception