# 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.core.processor | Contains static utility classes with factories of Jet processors.
  com.hazelcast.jet.hadoop | Apache Hadoop HDFS 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.s3 | AWS S3 read/write support for Hazelcast Jet.

- Classes in com.hazelcast.jet.pipeline used by com.hazelcast.jet
  Class and 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 and 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 and Description
  ContextFactory A holder of functions needed to create and destroy a context object.
  JournalInitialPosition When passed to an IMap/ICache Event Journal source, specifies which event to start from.
  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.hadoop
  Class and 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 and 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 and 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.
  ContextFactory A holder of functions needed to create and destroy a context object.
  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.
  JmsSinkBuilder See `Sinks.jmsQueueBuilder(com.hazelcast.jet.function.SupplierEx<javax.jms.ConnectionFactory>)` or `Sinks.jmsTopicBuilder(com.hazelcast.jet.function.SupplierEx<javax.jms.ConnectionFactory>)`.
  JmsSourceBuilder See `Sources.jmsQueueBuilder(com.hazelcast.jet.function.SupplierEx<? extends javax.jms.ConnectionFactory>)` or `Sources.jmsTopicBuilder(com.hazelcast.jet.function.SupplierEx<? extends javax.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.
  Pipeline Models a distributed computation job using an analogy with a system of interconnected water pipes.
  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.jet.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 pieline 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 and 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.s3
  Class and Description
  BatchSource A finite source of data for a Jet pipeline.
  Sink A data sink in a Jet pipeline.

Copyright © 2020. All rights reserved.