Blackhole

The blackhole sink discards all the data it consumes.

It is mainly used for testing or for scenarios where data output is not required.

JAVAYAML

BlackholeSink<String> sink = new BlackholeSink<>();

sink:
  blackhole: {}

Java dependency management

Add this declaration to your dependency management system to access the configuration DSL for this plugin in Java.

MavenGradle

<dependency>
    <groupId>org.voltdb</groupId>
    <artifactId>volt-stream-connectors-api</artifactId>
    <version>1.4.0</version>
</dependency>

implementation group: 'org.voltdb', name: 'volt-stream-connectors-api', version: '1.4.0'

Usage Examples

JAVA

stream
  .consumeFromSource(...)
  .terminateWithSink(new BlackholeSink<>());