Uses of Package
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.core.processor |
Contains static utility classes with factories of Jet processors.
|
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.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
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.jet.spring |
Spring integration for Hazelcast Jet
|
-
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.core.processor Class Description 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 asstage.mapUsingService()
.SourceBuilder.SourceBuffer The buffer object that thefillBufferFn
gets on each call.SourceBuilder.TimestampedSourceBuffer The buffer object that thefillBufferFn
gets on each call. -
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 asstage.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 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 computationpipeline
that will observe a finite amount of data (a batch).BatchStageWithKey An intermediate step while constructing a group-and-aggregate batch pipeline stage.FileSinkBuilder FileSourceBuilder Builder for a file source which reads lines from files in a directory (but not its subdirectories) and emits output object created bymapOutputFn
GeneralHashJoinBuilder Offers a step-by-step fluent API to build a hash-join pipeline stage.GeneralStage 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 SeeSinks.jdbcBuilder()
.JmsSinkBuilder JmsSourceBuilder JoinClause Specifies how to join an enriching stream to the primary stream in ahash-join
operation.JournalInitialPosition When passed to an IMap/ICache Event Journal source, specifies which event to start from.Pipeline Models a distributed computation job using an analogy with a system of interconnected water pipes.ServiceFactory A holder of functions needed to create and destroy a service object used in pipeline transforms such asstage.mapUsingService()
.SessionWindowDefinition Represents the definition of a session window.Sink A data sink in a Jet pipeline.SinkBuilder 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 SourceBuilder.FaultTolerant Represents a step in building a custom source where you add aSourceBuilder.FaultTolerant.restoreSnapshotFn(com.hazelcast.function.BiConsumerEx<? super C, ? super java.util.List<S>>)
after adding acreateSnapshotFn
.SourceBuilder.SourceBuffer The buffer object that thefillBufferFn
gets on each call.SourceBuilder.Stream SourceBuilder.TimestampedSourceBuffer The buffer object that thefillBufferFn
gets on each call.SourceBuilder.TimestampedStream Stage The basic element of a Jetpipeline
, 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 computationpipeline
that will observe an unbounded amount of data (i.e., an event stream).StreamStage A stage in a distributed computationpipeline
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.test Class Description BatchSource A finite source of data for a Jet pipeline.BatchStage A stage in a distributed computationpipeline
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 computationpipeline
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 computationpipeline
that will observe a finite amount of data (a batch).StreamStage A stage in a distributed computationpipeline
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.jet.spring Class Description ServiceFactory A holder of functions needed to create and destroy a service object used in pipeline transforms such asstage.mapUsingService()
.