Package org.voltdb.stream.api

Class Sources

java.lang.Object

org.voltdb.stream.api.Sources

public final class Sources
extends Object

Constructor Summary

Constructors

Constructor	Description
Sources()

Method Summary

Modifier and Type	Method	Description
static <T> VoltStreamSource<T>	collection(T... given)
static <I> VoltStreamSource<I>	generate(Supplier<I> supplier)
static <I> RateLimitedSourceConfigurator<I>	generateAtRate(double tps, Supplier<I> supplier)
static KafkaStreamSourceConfigurator<ByteBuffer,ByteBuffer>	kafka()

Methods inherited from class java.lang.Object

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

Constructor Details

Sources

public Sources()

Method Details

kafka

public static KafkaStreamSourceConfigurator<ByteBuffer,ByteBuffer> kafka()

generate

public static <I> VoltStreamSource<I> generate(Supplier<I> supplier)

generateAtRate

public static <I> RateLimitedSourceConfigurator<I> generateAtRate(double tps,
 Supplier<I> supplier)

collection

@SafeVarargs
public static <T> VoltStreamSource<T> collection(T... given)