Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
com.hazelcast.jet.server |
Contains Java program entry points that will start a Jet server
instance, submit jobs to a Jet cluster, etc.
|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
static JetInstance |
Jet.newJetClient()
Creates a Jet client with the default configuration.
|
static JetInstance |
Jet.newJetClient(com.hazelcast.client.config.ClientConfig config)
Creates a Jet client with the given Hazelcast client configuration.
|
static JetInstance |
Jet.newJetInstance()
Creates a member of the Jet cluster with the default configuration.
|
static JetInstance |
Jet.newJetInstance(JetConfig config)
Creates a member of the Jet cluster with the given configuration.
|
Modifier and Type | Method and Description |
---|---|
JetInstance |
Processor.Context.jetInstance()
Returns the current Jet instance
|
JetInstance |
ProcessorMetaSupplier.Context.jetInstance()
Returns the current Jet instance.
|
JetInstance |
ProcessorSupplier.Context.jetInstance()
Returns the current Jet instance
|
Modifier and Type | Method and Description |
---|---|
JetInstance |
TestProcessorSupplierContext.jetInstance() |
JetInstance |
TestProcessorContext.jetInstance() |
JetInstance |
TestProcessorMetaSupplierContext.jetInstance() |
Modifier and Type | Method and Description |
---|---|
TestProcessorSupplierContext |
TestProcessorSupplierContext.setJetInstance(JetInstance jetInstance)
Set the jet instance.
|
TestProcessorContext |
TestProcessorContext.setJetInstance(JetInstance jetInstance)
Set the jet instance.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setJetInstance(JetInstance jetInstance)
Set the jet instance.
|
Modifier and Type | Method and Description |
---|---|
static JetInstance |
JetBootstrap.getInstance()
Returns the bootstrapped
JetInstance . |
Modifier and Type | Method and Description |
---|---|
static <T> DistributedStream<T> |
DistributedStream.fromSource(JetInstance instance,
ProcessorMetaSupplier metaSupplier)
Returns a distributed
Stream with given processors as its source. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.