com.neocoretechs.rocksack.stream

Class KeySetStream

java.lang.Object

com.neocoretechs.rocksack.stream.SackStream

com.neocoretechs.rocksack.stream.KeySetStream

All Implemented Interfaces:

java.lang.AutoCloseable, java.util.stream.BaseStream, java.util.stream.Stream

public class KeySetStream
extends SackStream

Java 8 stream extensions for RockSack delivery of ordered persistent datasets.

Author:

Jonathan Groff Copyright (C) NeoCoreTechs 2021

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.stream.Stream

java.util.stream.Stream.Builder<T>

Constructor Summary

Constructors

Constructor and Description
KeySetStream(KeySetIterator esi)
KeySetStream(org.rocksdb.RocksDB kvMain)
KeySetStream(org.rocksdb.RocksDB kvMain, org.rocksdb.ColumnFamilyHandle cfh)
KeySetStream(org.rocksdb.Transaction kvMain)
KeySetStream(org.rocksdb.Transaction kvMain, org.rocksdb.ColumnFamilyHandle cfh)

Method Summary

Methods inherited from class com.neocoretechs.rocksack.stream.SackStream

allMatch, anyMatch, close, collect, collect, count, distinct, filter, findAny, findFirst, flatMap, flatMapToDouble, flatMapToInt, flatMapToLong, forEach, forEachOrdered, isParallel, iterator, limit, map, mapToDouble, mapToInt, mapToLong, max, min, noneMatch, of, onClose, parallel, peek, reduce, reduce, reduce, sequential, setParallel, skip, sorted, sorted, spliterator, toArray, toArray, unordered

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.stream.Stream

builder, concat, empty, generate, iterate, of, of

Constructor Detail

KeySetStream

public KeySetStream(KeySetIterator esi)

KeySetStream

public KeySetStream(org.rocksdb.RocksDB kvMain)
             throws java.io.IOException

Throws:

java.io.IOException

KeySetStream

public KeySetStream(org.rocksdb.Transaction kvMain)
             throws java.io.IOException

Throws:

java.io.IOException

KeySetStream

public KeySetStream(org.rocksdb.RocksDB kvMain,
                    org.rocksdb.ColumnFamilyHandle cfh)
             throws java.io.IOException

Throws:

java.io.IOException

KeySetStream

public KeySetStream(org.rocksdb.Transaction kvMain,
                    org.rocksdb.ColumnFamilyHandle cfh)
             throws java.io.IOException

Throws:

java.io.IOException