Uses of Package
com.hazelcast.jet.pipeline

Packages that use com.hazelcast.jet.pipeline

Package	Description
com.hazelcast.jet	Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology.
com.hazelcast.jet.avro	Apache Avro file read/write support for Hazelcast Jet.
com.hazelcast.jet.cdc	Contains source/sink connectors that deal with Change Data Capture (CDC) events from various databases as well as a generic connector for Debezium CDC sources.
com.hazelcast.jet.cdc.mysql	Contains connectors for change data capture events from MySQL databases.
com.hazelcast.jet.cdc.postgres	Contains connectors for change data capture events from PostgreSQL databases.
com.hazelcast.jet.core.processor	Contains static utility classes with factories of Jet processors.
com.hazelcast.jet.elastic	Contains sources and sinks for Elasticsearch 7
com.hazelcast.jet.grpc	Contributes gRPC service factories that can be to apply transformations to a pipeline which for each input item calls to a gRPC service.
com.hazelcast.jet.hadoop	Apache Hadoop read/write support for Hazelcast Jet.
com.hazelcast.jet.kafka	Apache Kafka reader/writer support for Hazelcast Jet.
com.hazelcast.jet.kafka.connect	Contains a generic Kafka Connect source provides ability to plug any Kafka Connect source for data ingestion to Jet pipelines.
com.hazelcast.jet.kinesis	Amazon Kinesis Data Streams producer/consumer support for Hazelcast Jet.
com.hazelcast.jet.mongodb	Contains sources and sinks for MongoDB.
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.
com.hazelcast.jet.pipeline.file	This package offers the FileSourceBuilder which allows you to construct various kinds of Pipeline sources that read from local or distributed files.
com.hazelcast.jet.pipeline.test	This package contains various mock sources to help with pipeline testing and development.
com.hazelcast.jet.python	Contributes a PythonTransforms.mapUsingPython(com.hazelcast.jet.python.PythonServiceConfig) transform that allows you to transform Jet pipeline data using a Python function.
com.hazelcast.jet.s3	AWS S3 read/write support for Hazelcast Jet.
com.hazelcast.spring.jet	Provides Jet related Spring interfaces/classes for Hazelcast.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet

Class	Description
Pipeline	Models a distributed computation job using an analogy with a system of interconnected water pipes.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.avro

Class	Description
BatchSource	A finite source of data for a Jet pipeline.
Sink	A data sink in a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.cdc

Class	Description
Sink	A data sink in a Jet pipeline.
StreamSource	An infinite source of data for a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.cdc.mysql

Class	Description
StreamSource	An infinite source of data for a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.cdc.postgres

Class	Description
StreamSource	An infinite source of data for a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.core.processor

Class	Description
DataConnectionRef	Represents a reference to the data connection, used with Sources.jdbc(DataConnectionRef, ToResultSetFunction, FunctionEx).
JournalInitialPosition	When passed to an IMap/ICache Event Journal source, specifies which event to start from.
ServiceFactory	A holder of functions needed to create and destroy a service object used in pipeline transforms such as stage.mapUsingService().
SourceBuilder.SourceBuffer	The buffer object that the fillBufferFn gets on each call.
SourceBuilder.TimestampedSourceBuffer	The buffer object that the fillBufferFn gets on each call.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.elastic

Class	Description
BatchSource	A finite source of data for a Jet pipeline.
Sink	A data sink in a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.grpc

Class	Description
ServiceFactory	A holder of functions needed to create and destroy a service object used in pipeline transforms such as stage.mapUsingService().

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.hadoop

Class	Description
BatchSource	A finite source of data for a Jet pipeline.
Sink	A data sink in a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.kafka

Class	Description
DataConnectionRef	Represents a reference to the data connection, used with Sources.jdbc(DataConnectionRef, ToResultSetFunction, FunctionEx).
Sink	A data sink in a Jet pipeline.
StreamSource	An infinite source of data for a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.kafka.connect

Class	Description
StreamSource	An infinite source of data for a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.kinesis

Class	Description
Sink	A data sink in a Jet pipeline.
StreamSource	An infinite source of data for a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.mongodb

Class	Description
BatchSource	A finite source of data for a Jet pipeline.
DataConnectionRef	Represents a reference to the data connection, used with Sources.jdbc(DataConnectionRef, ToResultSetFunction, FunctionEx).
Sink	A data sink in a Jet pipeline.
StreamSource	An infinite source of data for a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.pipeline

Class	Description
AggregateBuilder	Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
AggregateBuilder1	Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
BatchSource	A finite source of data for a Jet pipeline.
BatchStage	A stage in a distributed computation pipeline that will observe a finite amount of data (a batch).
BatchStageWithKey	An intermediate step while constructing a group-and-aggregate batch pipeline stage.
DataConnectionRef	Represents a reference to the data connection, used with Sources.jdbc(DataConnectionRef, ToResultSetFunction, FunctionEx).
FileSinkBuilder	See Sinks.filesBuilder(java.lang.String).
FileSourceBuilder	Builder for a file source which reads lines from files in a directory (but not its subdirectories) and emits output object created by mapOutputFn
GeneralHashJoinBuilder	Offers a step-by-step fluent API to build a hash-join pipeline stage.
GeneralStage	The common aspect of batch and stream pipeline stages, defining those operations that apply to both.
GeneralStageWithKey	An intermediate step when constructing a group-and-aggregate pipeline stage.
GroupAggregateBuilder	Offers a step-by-step API to build a pipeline stage that co-groups and aggregates the data from several input stages.
GroupAggregateBuilder1	Offers a step-by-step API to build a pipeline stage that co-groups and aggregates the data from several input stages.
HashJoinBuilder	Offers a step-by-step fluent API to build a hash-join pipeline stage.
JdbcSinkBuilder	See Sinks.jdbcBuilder().
JmsSinkBuilder	See Sinks.jmsQueueBuilder(com.hazelcast.function.SupplierEx<jakarta.jms.ConnectionFactory>) or Sinks.jmsTopicBuilder(com.hazelcast.function.SupplierEx<jakarta.jms.ConnectionFactory>).
JmsSourceBuilder	See Sources.jmsQueueBuilder(com.hazelcast.function.SupplierEx<? extends jakarta.jms.ConnectionFactory>) or Sources.jmsTopicBuilder(com.hazelcast.function.SupplierEx<? extends jakarta.jms.ConnectionFactory>).
JoinClause	Specifies how to join an enriching stream to the primary stream in a hash-join operation.
JournalInitialPosition	When passed to an IMap/ICache Event Journal source, specifies which event to start from.
MapSinkBuilder	Builder for a map that is used as sink.
MapSinkEntryProcessorBuilder	Parameters for using a map as a sink with an EntryProcessor: TODO review if this can be merged with MapSinkEntryProcessorBuilder, add full javadoc if not
Pipeline	Models a distributed computation job using an analogy with a system of interconnected water pipes.
RemoteMapSourceBuilder	Builder providing a fluent API to build a remote map source.
ServiceFactory	A holder of functions needed to create and destroy a service object used in pipeline transforms such as stage.mapUsingService().
SessionWindowDefinition	Represents the definition of a session window.
Sink	A data sink in a Jet pipeline.
SinkBuilder	See SinkBuilder.sinkBuilder(String, FunctionEx).
SinkStage	A pipeline stage that doesn't allow any downstream stages to be attached to it.
SlidingWindowDefinition	Represents the definition of a sliding window.
SourceBuilder.Batch	See SourceBuilder.batch(String, FunctionEx).
SourceBuilder.FaultTolerant	Represents a step in building a custom source where you add a SourceBuilder.FaultTolerant.restoreSnapshotFn(com.hazelcast.function.BiConsumerEx<? super C, ? super java.util.List<S>>) after adding a createSnapshotFn.
SourceBuilder.SourceBuffer	The buffer object that the fillBufferFn gets on each call.
SourceBuilder.Stream	See SourceBuilder.stream(String, FunctionEx).
SourceBuilder.TimestampedSourceBuffer	The buffer object that the fillBufferFn gets on each call.
SourceBuilder.TimestampedStream	See SourceBuilder.timestampedStream(String, FunctionEx).
Stage	The basic element of a Jet pipeline, represents a computation step.
StageWithKeyAndWindow	Represents an intermediate step in the construction of a pipeline stage that performs a windowed group-and-aggregate operation.
StageWithWindow	Represents an intermediate step in the construction of a pipeline stage that performs a windowed aggregate operation.
StreamHashJoinBuilder	Offers a step-by-step fluent API to build a hash-join pipeline stage.
StreamSource	An infinite source of data for a Jet pipeline.
StreamSourceStage	A source stage in a distributed computation pipeline that will observe an unbounded amount of data (i.e., an event stream).
StreamStage	A stage in a distributed computation pipeline that will observe an unbounded amount of data (i.e., an event stream).
StreamStageWithKey	An intermediate step while constructing a pipeline transform that involves a grouping key, such as windowed group-and-aggregate.
WindowAggregateBuilder	Offers a step-by-step fluent API to build a pipeline stage that performs a windowed co-aggregation of the data from several input stages.
WindowAggregateBuilder1	Offers a step-by-step fluent API to build a pipeline stage that performs a windowed co-aggregation of the data from several input stages.
WindowDefinition	The definition of the window for a windowed aggregation operation.
WindowGroupAggregateBuilder	Offers a step-by-step API to build a pipeline stage that performs a windowed co-grouping and aggregation of the data from several input stages.
WindowGroupAggregateBuilder1	Offers a step-by-step API to build a pipeline stage that performs a windowed co-grouping and aggregation of the data from several input stages.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.pipeline.file

Class	Description
BatchSource	A finite source of data for a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.pipeline.test

Class	Description
BatchSource	A finite source of data for a Jet pipeline.
BatchStage	A stage in a distributed computation pipeline that will observe a finite amount of data (a batch).
Sink	A data sink in a Jet pipeline.
StreamSource	An infinite source of data for a Jet pipeline.
StreamStage	A stage in a distributed computation pipeline that will observe an unbounded amount of data (i.e., an event stream).

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.python

Class	Description
BatchStage	A stage in a distributed computation pipeline that will observe a finite amount of data (a batch).
StreamStage	A stage in a distributed computation pipeline that will observe an unbounded amount of data (i.e., an event stream).

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet.s3

Class	Description
BatchSource	A finite source of data for a Jet pipeline.
Sink	A data sink in a Jet pipeline.

Classes in com.hazelcast.jet.pipeline used by com.hazelcast.spring.jet

Class	Description
ServiceFactory	A holder of functions needed to create and destroy a service object used in pipeline transforms such as stage.mapUsingService().