hollow/src/main/java/com/netflix/hollow/core/index/HollowHashIndexResult.java
public IntStream stream() {
        Spliterator.OfInt si = new Spliterator.OfInt() {
            final long endBucket = selectTableStartPointer + selectTableBuckets;
            long currentBucket = selectTableStartPointer;

            @Override
            public OfInt trySplit() {
                // @@@ Supporting splitting and therefore enable parallelism
                return null;
            }

            @Override
            public boolean tryAdvance(IntConsumer action) {
                while (currentBucket < endBucket) {
                    int selectOrdinal = (int) hashIndexState.getSelectHashArray().getElementValue(
                            (currentBucket++) * hashIndexState.getBitsPerSelectHashEntry(),
                            hashIndexState.getBitsPerSelectHashEntry()) - 1;
                    if (selectOrdinal != -1) {
                        action.accept(selectOrdinal);
                        return true;
                    }
                }
                return false;
            }

            @Override
            public long estimateSize() {
                // @@@
                return 0;
            }

            @Override
            public int characteristics() {
                // @@@ ordinals are distinct?
                return 0;
            }
        };
        return StreamSupport.intStream(si, false);
    }
public IntStream stream() {
        Spliterator.OfInt si = new Spliterator.OfInt() {
            final long endBucket = selectTableStartPointer + selectTableBuckets;
            long currentBucket = selectTableStartPointer;

            @Override
            public OfInt trySplit() {
                // @@@ Supporting splitting and therefore enable parallelism
                return null;
            }

            @Override
            public boolean tryAdvance(IntConsumer action) {
                while (currentBucket < endBucket) {
                    int selectOrdinal = (int) hashIndexState.getSelectHashArray().getElementValue(
                            (currentBucket++) * hashIndexState.getBitsPerSelectHashEntry(),
                            hashIndexState.getBitsPerSelectHashEntry()) - 1;
                    if (selectOrdinal != -1) {
                        action.accept(selectOrdinal);
                        return true;
                    }
                }
                return false;
            }

            @Override
            public long estimateSize() {
                // @@@
                return 0;
            }

            @Override
            public int characteristics() {
                // @@@ ordinals are distinct?
                return 0;
            }
        };
        return StreamSupport.intStream(si, false);
    }
public IntStream stream ( ) { Spliterator . OfInt si = new Spliterator . OfInt ( ) { final long endBucket = selectTableStartPointer + selectTableBuckets ; long currentBucket = selectTableStartPointer ; @ Override public OfInt trySplit ( ) { // @@@ Supporting splitting and therefore enable parallelism return null ; } @ Override public boolean tryAdvance ( IntConsumer action ) { while ( currentBucket < endBucket ) { int selectOrdinal = ( int ) hashIndexState . getSelectHashArray ( ) . getElementValue ( ( currentBucket ++ ) * hashIndexState . getBitsPerSelectHashEntry ( ) , hashIndexState . getBitsPerSelectHashEntry ( ) ) - 1 ; if ( selectOrdinal != - 1 ) { action . accept ( selectOrdinal ) ; return true ; } } return false ; } @ Override public long estimateSize ( ) { // @@@ return 0 ; } @ Override public int characteristics ( ) { // @@@ ordinals are distinct? return 0 ; } } ; return StreamSupport . intStream ( si , false ) ; }
Returns a stream of matching ordinals.
<p>
The ordinals may be used with a generated API or the Generic Object API to inspect
the matched records.

@return an {@code IntStream} of matching ordinals
Returns a stream of matching ordinals . <p > The ordinals may be used with a generated API or the Generic Object API to inspect the matched records .