Class DefaultIncrementalHandler

    • Field Detail

      • logger

        private final org.slf4j.Logger logger
    • Constructor Detail

      • DefaultIncrementalHandler

        public DefaultIncrementalHandler()
    • Method Detail

      • getLogger

        protected org.slf4j.Logger getLogger()
      • loadRemoteIncrementalUpdates

        public java.util.List<java.lang.String> loadRemoteIncrementalUpdates​(IndexUpdateRequest request,
                                                                             java.util.Properties localProperties,
                                                                             java.util.Properties remoteProperties)
                                                                      throws java.io.IOException
        Specified by:
        loadRemoteIncrementalUpdates in interface IncrementalHandler
        Throws:
        java.io.IOException
      • validateProperties

        private boolean validateProperties​(java.util.Properties properties)
      • getIndexChunk

        private java.util.List<java.lang.Integer> getIndexChunk​(IndexPackingRequest request,
                                                                java.util.Date timestamp)
                                                         throws java.io.IOException
        Throws:
        java.io.IOException
      • updateProperties

        private void updateProperties​(java.util.Properties properties,
                                      IndexPackingRequest request)
                               throws java.io.IOException
        Throws:
        java.io.IOException
      • cleanUpIncrementalChunks

        private void cleanUpIncrementalChunks​(IndexPackingRequest request,
                                              java.util.Properties properties)
                                       throws java.io.IOException
        Throws:
        java.io.IOException
      • parse

        private java.util.Date parse​(java.lang.String s)
      • canRetrieveAllChunks

        private boolean canRetrieveAllChunks​(java.util.Properties localProps,
                                             java.util.Properties remoteProps)