Examples of CloseableIterator

mil.nga.giat.geowave.store.CloseableIterator
This interface wraps both the Iterator interface and the Closeable interface. It is best to close an iterator of this interface when it is no longer needed. @param < E> A generic for the type of data for iteration
org.infinispan.commons.util.CloseableIterator
Interface that provides semantics of a {@link Iterator} and {@link AutoCloseable} interfaces. This isuseful when you have data that must be iterated on and may hold resources in the underlying implementation that must be closed.
Some implementations may close resources automatically when the iterator is finished being iterated on however this is an implementation detail and all callers should call {@link AutoCloseable#close()} method to besure all resources are freed properly.
@author wburns @since 7.0

Examples of mil.nga.giat.geowave.store.CloseableIterator

        visWriterBBB).get(
        0);


    final SpatialQuery query = new SpatialQuery(
        testGeoFilter);
    CloseableIterator it1 = mockDataStore.query(
        adapter,
        index,
        query,
        -1,
        "aaa",
        "bbb");
    int count = 0;
    while (it1.hasNext()) {
      it1.next();
      count++;
    }
    assertEquals(
        3,
        count);


    CountDataStatistics countStats = (CountDataStatistics) this.statsStore.getDataStatistics(
        adapter.getAdapterId(),
        CountDataStatistics.STATS_ID,
        "aaa",
        "bbb");
    assertEquals(
        3,
        countStats.getCount());


    countStats = (CountDataStatistics) this.statsStore.getDataStatistics(
        adapter.getAdapterId(),
        CountDataStatistics.STATS_ID,
        "aaa");
    assertEquals(
        2,
        countStats.getCount());


    countStats = (CountDataStatistics) this.statsStore.getDataStatistics(
        adapter.getAdapterId(),
        CountDataStatistics.STATS_ID,
        "bbb");
    assertEquals(
        1,
        countStats.getCount());


    assertFalse(mockDataStore.deleteEntry(
        index,
        new ByteArrayId("test_pt_2".getBytes()),
        adapter.getAdapterId(),
        "aaa"));


    it1 = mockDataStore.query(adapter,
        index,
        query,
        -1,
        "aaa",
        "bbb");
    count = 0;
    while (it1.hasNext()) {
      it1.next();
      count++;
    }
    assertEquals(
        3,
        count);
    
    assertTrue(mockDataStore.deleteEntry(
        index,
        new ByteArrayId("test_pt".getBytes()),
        adapter.getAdapterId(),
        "aaa"));


    it1 = mockDataStore.query(adapter,
        index,
        query,
        -1,
        "aaa",
        "bbb");
    count = 0;
    while (it1.hasNext()) {
      it1.next();
      count++;
    }
    assertEquals(
        2,
        count);


    countStats = (CountDataStatistics) this.statsStore.getDataStatistics(
        adapter.getAdapterId(),
        CountDataStatistics.STATS_ID,
        "aaa");
    assertEquals(
        1,
        countStats.getCount());


    countStats = (CountDataStatistics) this.statsStore.getDataStatistics(
        adapter.getAdapterId(),
        CountDataStatistics.STATS_ID,
        "bbb");
    assertEquals(
        1,
        countStats.getCount());


    mockDataStore.deleteEntries(
        adapter,
        index,
        "aaa",
        "bbb");
    it1 = mockDataStore.query(adapter,
        index,
        query,
        -1,
        "aaa",
        "bbb");
    count = 0;
    while (it1.hasNext()) {
      it1.next();
      count++;
    }
    assertEquals(
        0,
        count);

View Full Code Here

Examples of org.infinispan.commons.util.CloseableIterator

         initialValues.add(new ImmortalCacheEntry(key, value));
      }


      final CyclicBarrier barrier = new CyclicBarrier(2);


      final CloseableIterator closeable = mock(CloseableIterator.class, withSettings().defaultAnswer(
            AdditionalAnswers.delegatesTo(initialValues.iterator())));


      // Now we block the close from occurring, which happens after iteration before completing the iteration
      doAnswer(new Answer<Void>() {
         @Override

View Full Code Here

Examples of org.infinispan.commons.util.CloseableIterator

         initialValues.add(new ImmortalCacheEntry(key, value));
      }


      final CyclicBarrier barrier = new CyclicBarrier(2);


      final CloseableIterator closeable = mock(CloseableIterator.class, withSettings().defaultAnswer(
            AdditionalAnswers.delegatesTo(initialValues.iterator())));


      // Now we block the close from occurring, which happens after iteration before completing the iteration
      doAnswer(new Answer<Void>() {
         @Override

View Full Code Here

Examples of org.infinispan.commons.util.CloseableIterator

      EntryRetriever mockRetriever = mock(EntryRetriever.class, withSettings().defaultAnswer(forwardedAnswer));


      doAnswer(new Answer() {
         @Override
         public Object answer(InvocationOnMock invocation) throws Throwable {
            CloseableIterator realIter = (CloseableIterator)forwardedAnswer.answer(invocation);


            final Answer<Object> forwardedIterAnswer = AdditionalAnswers.delegatesTo(realIter);


            CloseableIterator iter = mock(CloseableIterator.class, withSettings().defaultAnswer(forwardedIterAnswer));


            doAnswer(new Answer() {


               @Override
               public Object answer(InvocationOnMock invocationOnMock) throws Throwable {

View Full Code Here

Examples of org.infinispan.commons.util.CloseableIterator

      EntryRetriever mockRetriever = mock(EntryRetriever.class, withSettings().defaultAnswer(forwardedAnswer));


      doAnswer(new Answer() {
         @Override
         public Object answer(InvocationOnMock invocation) throws Throwable {
            CloseableIterator realIter = (CloseableIterator)forwardedAnswer.answer(invocation);


            final Answer<Object> forwardedIterAnswer = AdditionalAnswers.delegatesTo(realIter);


            CloseableIterator iter = mock(CloseableIterator.class, withSettings().defaultAnswer(forwardedIterAnswer));


            doAnswer(new Answer() {


               @Override
               public Object answer(InvocationOnMock invocationOnMock) throws Throwable {

View Full Code Here

Examples of org.infinispan.commons.util.CloseableIterator

         initialValues.add(new ImmortalCacheEntry(key, value));
      }


      final CyclicBarrier barrier = new CyclicBarrier(2);


      final CloseableIterator closeable = mock(CloseableIterator.class, withSettings().defaultAnswer(
            AdditionalAnswers.delegatesTo(initialValues.iterator())));


      // Now we block the close from occurring, which happens after iteration before completing the iteration
      doAnswer(new Answer<Void>() {
         @Override

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.