Class OptimizedTableEngine

  • All Implemented Interfaces:
    DataHandler

    public class OptimizedTableEngine
    extends java.lang.Object
    implements DataHandler
    • Constructor Detail

    • Method Detail

      • getLogger

        protected LoggerEx getLogger()
      • getWindowSize

        protected long getWindowSize()
      • getConnection

        public SRConnection getConnection()
                                   throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • getDSQuoteChar

        protected java.lang.String getDSQuoteChar()
      • isAccepting

        public boolean isAccepting()
        We only accept new data when we're up to date.
      • startup

        public void startup()
      • shutdown

        public void shutdown()
      • asyncStart

        protected void asyncStart()
      • catchup

        protected void catchup()
                        throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getMaxTimestamp

        protected long getMaxTimestamp​(java.lang.String partitionName)
                                throws java.lang.Exception
        Throws:
        java.lang.Exception
      • putValue

        public void putValue​(RawTagValue inValue)
                      throws java.lang.Exception
        Description copied from interface: DataHandler
        Insert a value into the handler.
        Specified by:
        putValue in interface DataHandler
        Throws:
        java.lang.Exception
      • flush

        public void flush()
                   throws java.lang.Exception
        Description copied from interface: DataHandler
        Indicate that the handler won't get any more data, at least for a while.
        Specified by:
        flush in interface DataHandler
        Throws:
        java.lang.Exception