Uses of Package
com.hazelcast.jet.core
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 |
Jet's Core API.
|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
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.
|
-
Classes in com.hazelcast.jet.core used by com.hazelcast.jet Class Description DAG Describes a computation to be performed by the Jet computation engine.JobStatus Represents current status of the job from the perspective of the job coordinator. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.avro Class Description ProcessorMetaSupplier Factory ofProcessorSupplier
instances. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.core Class Description AbstractProcessor.FlatMapper A helper that simplifies the implementation oftryProcess(ordinal, item)
for emitting collections.AppendableTraverser A traverser with an internalArrayDeque
.BroadcastKey Marks a key in the snapshot state to indicate that the corresponding entry should be broadcast to all processors when restoring the snapshot.DAG Describes a computation to be performed by the Jet computation engine.DefaultPartitionStrategy A facade that hides the details of Hazelcast partitioning SPI and exposes just the partitioning strategy.Edge Edge.RoutingPolicy An edge describes a connection from many upstream processors to many downstream processors.EventTimePolicy A holder of functions and parameters Jet needs to handle event time and the associated watermarks.Inbox A subset ofQueue<Object>
API restricted to the consumer side, with additional support for bulk draining operations.JobStatus Represents current status of the job from the perspective of the job coordinator.Outbox Data sink for aProcessor
.Partitioner Encapsulates the logic associated with aDAG
edge that decides on the partition ID of an item traveling over it.Processor When Jet executes a DAG, it creates one or more instances ofProcessor
on each cluster member to do the work of a given vertex.Processor.Context Context passed to the processor in theinit()
call.ProcessorMetaSupplier Factory ofProcessorSupplier
instances.ProcessorMetaSupplier.Context Context passed to the meta-supplier at init time on the member that received a job request from the client.ProcessorSupplier Factory ofProcessor
instances.ProcessorSupplier.Context Context passed to the supplier in theinit()
call.SlidingWindowPolicy Contains parameters that define a sliding/tumbling window over which Jet will apply an aggregate function.TimestampKind Enumerates the two possible kinds of timestamp: event timestamp and frame timestamp.Vertex Represents a unit of data processing in a Jet computation job.Watermark Watermark is an item occasionally inserted into a disordered (sub)stream of timestamped items.WatermarkPolicy This object tracks and determines the currentWatermark
given the event timestamps as they occur for a single input stream. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.core.processor Class Description EventTimePolicy A holder of functions and parameters Jet needs to handle event time and the associated watermarks.Processor When Jet executes a DAG, it creates one or more instances ofProcessor
on each cluster member to do the work of a given vertex.Processor.Context Context passed to the processor in theinit()
call.ProcessorMetaSupplier Factory ofProcessorSupplier
instances.ProcessorSupplier Factory ofProcessor
instances.SlidingWindowPolicy Contains parameters that define a sliding/tumbling window over which Jet will apply an aggregate function.TimestampKind Enumerates the two possible kinds of timestamp: event timestamp and frame timestamp. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.core.test Class Description Inbox A subset ofQueue<Object>
API restricted to the consumer side, with additional support for bulk draining operations.Outbox Data sink for aProcessor
.Processor When Jet executes a DAG, it creates one or more instances ofProcessor
on each cluster member to do the work of a given vertex.Processor.Context Context passed to the processor in theinit()
call.ProcessorMetaSupplier Factory ofProcessorSupplier
instances.ProcessorMetaSupplier.Context Context passed to the meta-supplier at init time on the member that received a job request from the client.ProcessorSupplier Factory ofProcessor
instances.ProcessorSupplier.Context Context passed to the supplier in theinit()
call. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.hadoop Class Description ProcessorMetaSupplier Factory ofProcessorSupplier
instances. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.kafka Class Description EventTimePolicy A holder of functions and parameters Jet needs to handle event time and the associated watermarks.ProcessorMetaSupplier Factory ofProcessorSupplier
instances. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.pipeline Class Description DAG Describes a computation to be performed by the Jet computation engine.EventTimePolicy A holder of functions and parameters Jet needs to handle event time and the associated watermarks.Processor When Jet executes a DAG, it creates one or more instances ofProcessor
on each cluster member to do the work of a given vertex.Processor.Context Context passed to the processor in theinit()
call.ProcessorMetaSupplier Factory ofProcessorSupplier
instances.ProcessorSupplier Factory ofProcessor
instances.ProcessorSupplier.Context Context passed to the supplier in theinit()
call.