Uses of Package
com.hazelcast.jet.core
Packages that use com.hazelcast.jet.core
Package
Description
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Apache Avro file read/write support for Hazelcast Jet.
Jet's Core API.
Contains static utility classes with factories of Jet processors.
Utilities for writing tests of Core API Processors.
Apache Hadoop read/write support for Hazelcast Jet.
Apache Kafka reader/writer support for Hazelcast Jet.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
This package offers the
FileSourceBuilder
which allows you to construct various kinds of Pipeline sources that read from local or distributed files.This package contains various mock sources to help with pipeline testing
and development.
Provides interfaces/classes for Hazelcast security implementation.
-
Classes in com.hazelcast.jet.core used by com.hazelcast.jetClassDescriptionDescribes a computation to be performed by the Jet computation engine.Represents current status of the job from the perspective of the job coordinator.Description of the cause that has led to the job being suspended.
-
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.avro
-
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.coreClassDescriptionA helper that simplifies the implementation of
tryProcess(ordinal, item)for emitting collections.A traverser with an internalArrayDeque.Marks a key in the snapshot state to indicate that the corresponding entry should be broadcast to all processors when restoring the snapshot.Describes a computation to be performed by the Jet computation engine.A facade that hides the details of Hazelcast partitioning SPI and exposes just the partitioning strategy.An edge describes a connection from many upstream processors to many downstream processors.A holder of functions and parameters Jet needs to handle event time and the associated watermarks.A subset ofQueue<Object>API restricted to the consumer side, with additional support for bulk draining operations.Represents current status of the job from the perspective of the job coordinator.Data sink for aProcessor.Encapsulates the logic associated with aDAGedge that decides on the partition ID of an item traveling over it.When Jet executes a DAG, it creates one or more instances ofProcessoron each cluster member to do the work of a given vertex.Context passed to the processor in theinit()call.Factory ofProcessorSupplierinstances.Context passed to the meta-supplier at init time on the member that received a job request from the client.Factory ofProcessorinstances.Context passed to the supplier in theinit()call.Contains parameters that define a sliding/tumbling window over which Jet will apply an aggregate function.Enumerates the two possible kinds of timestamp: event timestamp and frame timestamp.Represents a unit of data processing in a Jet computation job.Watermark is an item occasionally inserted into a disordered (sub)stream of timestamped items.This object tracks and determines the currentWatermarkgiven the event timestamps as they occur for a single input stream. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.core.processorClassDescriptionA holder of functions and parameters Jet needs to handle event time and the associated watermarks.When Jet executes a DAG, it creates one or more instances of
Processoron each cluster member to do the work of a given vertex.Context passed to the processor in theinit()call.Factory ofProcessorSupplierinstances.Factory ofProcessorinstances.Context passed to the supplier in theinit()call.Contains parameters that define a sliding/tumbling window over which Jet will apply an aggregate function.Enumerates the two possible kinds of timestamp: event timestamp and frame timestamp. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.core.testClassDescriptionA subset of
Queue<Object>API restricted to the consumer side, with additional support for bulk draining operations.Data sink for aProcessor.When Jet executes a DAG, it creates one or more instances ofProcessoron each cluster member to do the work of a given vertex.Context passed to the processor in theinit()call.Factory ofProcessorSupplierinstances.Context passed to the meta-supplier at init time on the member that received a job request from the client.Factory ofProcessorinstances.Context passed to the supplier in theinit()call. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.hadoop
-
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.kafkaClassDescriptionA holder of functions and parameters Jet needs to handle event time and the associated watermarks.Factory of
ProcessorSupplierinstances. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.pipelineClassDescriptionDescribes a computation to be performed by the Jet computation engine.A holder of functions and parameters Jet needs to handle event time and the associated watermarks.When Jet executes a DAG, it creates one or more instances of
Processoron each cluster member to do the work of a given vertex.Context passed to the processor in theinit()call.Factory ofProcessorSupplierinstances.Factory ofProcessorinstances.Context passed to the supplier in theinit()call. -
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.pipeline.file
-
Classes in com.hazelcast.jet.core used by com.hazelcast.jet.pipeline.testClassDescriptionBase class to implement custom processors.A holder of functions and parameters Jet needs to handle event time and the associated watermarks.When Jet executes a DAG, it creates one or more instances of
Processoron each cluster member to do the work of a given vertex.Context passed to the processor in theinit()call. -
Classes in com.hazelcast.jet.core used by com.hazelcast.securityClassDescriptionContext passed to the meta-supplier at init time on the member that received a job request from the client.