Package com.hazelcast.pc

Interface Sink

All Known Implementing Classes:
JdbcSink, KafkaSink, LoggerSink, MapSink
public interface Sink

  • Method Summary

    Modifier and Type
    Method
    Description
    com.hazelcast.jet.pipeline.SinkStage
    sink(Object stage, StageConfig stageConfig)
     
    static <T> com.hazelcast.jet.pipeline.SinkStage
    write(Object stage, com.hazelcast.jet.pipeline.Sink<T> writer)
     

  • Method Details

    • sink

      com.hazelcast.jet.pipeline.SinkStage sink(Object stage, StageConfig stageConfig)

    • write

      static <T> com.hazelcast.jet.pipeline.SinkStage write(Object stage, com.hazelcast.jet.pipeline.Sink<T> writer)