timestamp = (Date) ConfigUtils.getObject(session, new Date(), "maven.startTime");

        /*
         * NOTE: This should be considered a quirk to support interop with Maven's legacy ArtifactDeployer which
         * processes one artifact at a time and hence cannot associate the artifacts from the same project to use the
         * same version index. Allowing the caller to pass in metadata from a previous deployment allows to re-establish

import org.opensearch.index.query.QueryBuilders;

import jakarta.servlet.http.HttpServletRequest;

/**
 * Entity class that handles geographic information for search queries.
 * This class processes geographic query parameters from HTTP requests and converts them
 * into OpenSearch geo-distance queries for location-based search functionality.
 *
 */
public class GeoInfo {

        assertEquals(1, ingester.processCalled);
        assertEquals("processed", result.get("status"));
    }

    @Test
    public void test_ingest_withException() {
        // Setup ingester that throws exception
        TestIngester failingIngester = new TestIngester() {
            @Override
            public Map<String, Object> process(Map<String, Object> target, DataStoreParams paramMap) {

    // PUT /api/admin/elevateword/upload
    /**
     * Uploads and imports elevate words from a CSV file.
     * Processes the file asynchronously and updates the suggest helper.
     *
     * @param body upload form containing the CSV file
     * @return JSON response with upload status
     */
    @Execute
    public JsonResponse<ApiResult> put$upload(final UploadForm body) {
        validateApi(body, messages -> {});

     * @param dataMap the document data to be indexed as key-value pairs
     */
    void store(DataStoreParams paramMap, Map<String, Object> dataMap);

    /**
     * Returns the total number of documents processed by this callback.
     *
     * @return the document count
     */
    long getDocumentSize();

    /**
     * Returns the total execution time for index update operations.
     *

     * Performs the specified bean configuration.
     *
     * @param request The configuration request that specifies the bean and the configuration to process, must not be
     *            {@code null}.
     * @throws BeanConfigurationException If the bean configuration could not be successfully processed.
     */
    void configureBean(BeanConfigurationRequest request) throws BeanConfigurationException;

```

### Monitoring

```java
// Monitor crawling progress
while (crawler.crawlerContext.getStatus() == CrawlerStatus.RUNNING) {
    int processed = dataService.getCount(sessionId);
    System.out.println("Processed: " + processed + " URLs");
    Thread.sleep(5000);
}
```

## Contributing

We welcome contributions to Fess Crawler! Please follow these guidelines:

        }

        snapshots = new LinkedHashMap<>();

        /*
         * NOTE: This should be considered a quirk to support interop with Maven's legacy ArtifactDeployer which
         * processes one artifact at a time and hence cannot associate the artifacts from the same project to use the
         * same timestamp+buildno for the snapshot versions. Allowing the caller to pass in metadata from a previous

      }
      readControlFrame()
    }
  }

  /**
   * Reads a message body into across one or more frames. Control frames that occur between
   * fragments will be processed. If the message payload is masked this will unmask as it's being
   * processed.
   */
  @Throws(IOException::class)
  private fun readMessage() {
    while (true) {
      if (receivedCloseFrame) throw IOException("closed")

        QueryBuilder builder = queryCommand.convertTermRangeQuery(context, query, 1.0f);
        assertNotNull(builder);
        assertTrue(builder instanceof RangeQueryBuilder);

        // Query was processed successfully
        RangeQueryBuilder rqb = (RangeQueryBuilder) builder;
        assertEquals("title", rqb.fieldName());
    }