com.neocoretechs.rocksack.stream

Class TailSetKVStream

java.lang.Object

com.neocoretechs.rocksack.stream.SackStream

com.neocoretechs.rocksack.stream.TailSetKVStream

All Implemented Interfaces:

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

public class TailSetKVStream
extends SackStream

Java 8 stream extensions for RockSack delivery of ordered persistent datasets. greater or equal to 'from' 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
TailSetKVStream(java.lang.Comparable fkey, org.rocksdb.RocksDB kvMain)
TailSetKVStream(java.lang.Comparable fkey, org.rocksdb.RocksDB kvMain, org.rocksdb.ColumnFamilyHandle cfh)
TailSetKVStream(java.lang.Comparable fkey, org.rocksdb.Transaction kvMain)
TailSetKVStream(java.lang.Comparable fkey, org.rocksdb.Transaction kvMain, org.rocksdb.ColumnFamilyHandle cfh)
TailSetKVStream(TailSetKVIterator 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

TailSetKVStream

public TailSetKVStream(TailSetKVIterator esi)

TailSetKVStream

public TailSetKVStream(java.lang.Comparable fkey,
                       org.rocksdb.RocksDB kvMain)
                throws java.io.IOException

Throws:

java.io.IOException

TailSetKVStream

public TailSetKVStream(java.lang.Comparable fkey,
                       org.rocksdb.Transaction kvMain)
                throws java.io.IOException

Throws:

java.io.IOException

TailSetKVStream

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

Throws:

java.io.IOException

TailSetKVStream

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

Throws:

java.io.IOException