Package org.voltdb.stream.api

Class Sinks

java.lang.Object

org.voltdb.stream.api.Sinks

public final class Sinks
extends Object

Constructor Summary

Constructors

Constructor	Description
Sinks()

Method Summary

Modifier and Type	Method	Description
static <T> IterableSink<T>	collection()
static <T> VoltStreamSink<T>	consume(Consumer<T> consumer)
static <T> FileSink<T>	directory(String directoryPath)
static KafkaSinks	kafka()
static StdoutSink<Object>	stdout()
static VoltSinks	volt()

Methods inherited from class java.lang.Object

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

Constructor Details

Sinks

public Sinks()

Method Details

kafka

public static KafkaSinks kafka()

volt

public static VoltSinks volt()

directory

public static <T> FileSink<T> directory(String directoryPath)

stdout

public static StdoutSink<Object> stdout()

consume

public static <T> VoltStreamSink<T> consume(Consumer<T> consumer)

collection

public static <T> IterableSink<T> collection()