| Class | Description |
|---|---|
| SinkFunctionSpec<T> |
An
EgressSpec that can run any Apache Flink SinkFunction. |
| SourceFunctionSpec<T> |
An
IngressSpec that can run any Apache Flink SourceFunction. |
| SourceSinkModule |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.