Package org.voltdb.stream.api.pipeline

Interface VoltOpenStreamBuilder<I>

public interface VoltOpenStreamBuilder<I>

Method Summary

Modifier and Type	Method	Description
default <O> VoltOpenStreamBuilder<O>	processWith(Function<I,O> function)
<O> VoltOpenStreamBuilder<O>	processWith(VoltFunctionConfigurator<I,O> builder)
<O> VoltOpenStreamBuilder<O>	processWith(VoltFunction<I,O> processor)
<O> void	terminateWithSink(VoltStreamSinkConfigurator<O> configurator)
<O> void	terminateWithSink(VoltStreamSink<O> sink)

Method Details

processWith

<O> VoltOpenStreamBuilder<O> processWith(VoltFunction<I,O> processor)

processWith

<O> VoltOpenStreamBuilder<O> processWith(VoltFunctionConfigurator<I,O> builder)

processWith

default <O> VoltOpenStreamBuilder<O> processWith(Function<I,O> function)

terminateWithSink

<O> void terminateWithSink(VoltStreamSink<O> sink)

terminateWithSink

<O> void terminateWithSink(VoltStreamSinkConfigurator<O> configurator)