Package co.decodable.sdk.pipeline.testing

Interface KeyedDecodableStream<K,V>

Type Parameters:

K - The key data type for a record in this stream

V - The value data type for a record in this stream

public interface KeyedDecodableStream<K,V>

Represents a keyed data stream on the Decodable platform.

Method Summary

Modifier and Type	Method	Description
void	add(KeyedStreamRecord<K,V> streamRecord)	Adds the given keyed stream record to this stream.
Future<List<KeyedStreamRecord<K,V>>>	take(int n)	Retrieves n keyed records from this stream.
Future<KeyedStreamRecord<K,V>>	takeOne()	Retrieves one keyed record from this stream.

Method Details

add

void add(KeyedStreamRecord<K,V> streamRecord)

Adds the given keyed stream record to this stream.

takeOne

Future<KeyedStreamRecord<K,V>> takeOne()

Retrieves one keyed record from this stream.

take

Future<List<KeyedStreamRecord<K,V>>> take(int n)

Retrieves n keyed records from this stream.