Package com.hazelcast.pc

Interface Source

All Known Implementing Classes:
FileSource, ItemsSource, ItemStreamSource, JdbcSource, KafkaSource, MapJournalSource, MapSource
@Deprecated(since="5.7", forRemoval=true) public interface Source
Deprecated, for removal: This API element is subject to removal in a future version.

  • Method Summary

    Modifier and Type
    Method
    Description
    static <T> com.hazelcast.jet.pipeline.StreamStage<T>
    maybeApplyTimestamps(com.hazelcast.jet.pipeline.StreamSourceStage<T> stage, StageConfig stageConfig)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    <T> com.hazelcast.jet.pipeline.GeneralStage<T>
    source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig)
    Deprecated, for removal: This API element is subject to removal in a future version.
     

  • Method Details

    • source

      <T> com.hazelcast.jet.pipeline.GeneralStage<T> source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig)
      Deprecated, for removal: This API element is subject to removal in a future version.

    • maybeApplyTimestamps

      static <T> com.hazelcast.jet.pipeline.StreamStage<T> maybeApplyTimestamps(com.hazelcast.jet.pipeline.StreamSourceStage<T> stage, StageConfig stageConfig)
      Deprecated, for removal: This API element is subject to removal in a future version.