Uses of Class
com.hazelcast.pc.config.StageConfig
Packages that use StageConfig
Package
Description
-
Uses of StageConfig in com.hazelcast.pc
Methods in com.hazelcast.pc with parameters of type StageConfigModifier and TypeMethodDescriptionstatic <T> com.hazelcast.jet.pipeline.StreamStage<T>Source.maybeApplyTimestamps(com.hazelcast.jet.pipeline.StreamSourceStage<T> stage, StageConfig stageConfig) Deprecated, for removal: This API element is subject to removal in a future version.com.hazelcast.jet.pipeline.SinkStageSink.sink(Object 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.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) Deprecated, for removal: This API element is subject to removal in a future version.com.hazelcast.jet.pipeline.GeneralStage<R>Transform.transform(com.hazelcast.jet.pipeline.GeneralStage<T> stage, StageConfig stageConfig) Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of StageConfig in com.hazelcast.pc.config
Methods in com.hazelcast.pc.config that return StageConfigModifier and TypeMethodDescriptionstatic StageConfigDeprecated, for removal: This API element is subject to removal in a future version. -
Uses of StageConfig in com.hazelcast.pc.sinks
Methods in com.hazelcast.pc.sinks with parameters of type StageConfigModifier and TypeMethodDescriptioncom.hazelcast.jet.pipeline.SinkStageJdbcSink.sink(Object stage, StageConfig stageConfig) com.hazelcast.jet.pipeline.SinkStageKafkaSink.sink(Object stage, StageConfig stageConfig) com.hazelcast.jet.pipeline.SinkStageLoggerSink.sink(Object stage, StageConfig stageConfig) com.hazelcast.jet.pipeline.SinkStageMapSink.sink(Object stage, StageConfig stageConfig) -
Uses of StageConfig in com.hazelcast.pc.sources
Methods in com.hazelcast.pc.sources with parameters of type StageConfigModifier and TypeMethodDescriptioncom.hazelcast.jet.pipeline.GeneralStageFileSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageItemsSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageItemStreamSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageJdbcSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageKafkaSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageMapJournalSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) com.hazelcast.jet.pipeline.GeneralStageMapSource.source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig) -
Uses of StageConfig in com.hazelcast.pc.transforms
Methods in com.hazelcast.pc.transforms with parameters of type StageConfigModifier and TypeMethodDescriptioncom.hazelcast.jet.pipeline.GeneralStage<R>PythonTransform.transform(com.hazelcast.jet.pipeline.GeneralStage<T> stage, StageConfig stageConfig)