com.neocoretechs.rocksack.stream

Class HeadSetKVStream

java.lang.Object

com.neocoretechs.rocksack.stream.SackStream

com.neocoretechs.rocksack.stream.HeadSetKVStream

All Implemented Interfaces:

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

public class HeadSetKVStream
extends SackStream

Java 8 stream extensions for RockSack delivery of ordered persistent datasets. for items of persistent collection strictly less than 'to' element

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
HeadSetKVStream(java.lang.Comparable tkey, org.rocksdb.RocksDB kvMain)
HeadSetKVStream(java.lang.Comparable tkey, org.rocksdb.RocksDB kvMain, org.rocksdb.ColumnFamilyHandle cfh)
HeadSetKVStream(java.lang.Comparable tkey, org.rocksdb.Transaction kvMain)
HeadSetKVStream(java.lang.Comparable tkey, org.rocksdb.Transaction kvMain, org.rocksdb.ColumnFamilyHandle cfh)
HeadSetKVStream(HeadSetKVIterator esi)

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

HeadSetKVStream

public HeadSetKVStream(HeadSetKVIterator esi)

HeadSetKVStream

public HeadSetKVStream(java.lang.Comparable tkey,
                       org.rocksdb.RocksDB kvMain)
                throws java.io.IOException

Throws:

java.io.IOException

HeadSetKVStream

public HeadSetKVStream(java.lang.Comparable tkey,
                       org.rocksdb.Transaction kvMain)
                throws java.io.IOException

Throws:

java.io.IOException

HeadSetKVStream

public HeadSetKVStream(java.lang.Comparable tkey,
                       org.rocksdb.RocksDB kvMain,
                       org.rocksdb.ColumnFamilyHandle cfh)
                throws java.io.IOException

Throws:

java.io.IOException

HeadSetKVStream

public HeadSetKVStream(java.lang.Comparable tkey,
                       org.rocksdb.Transaction kvMain,
                       org.rocksdb.ColumnFamilyHandle cfh)
                throws java.io.IOException

Throws:

java.io.IOException