Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.server |
Contains Java program entry points that will start a Jet server
instance, submit jobs to a Jet cluster, etc.
|
Modifier and Type | Method and Description |
---|---|
static JetInstance |
Jet.newJetClient()
Creates a Jet client with the default configuration.
|
static JetInstance |
Jet.newJetClient(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 configuration loaded from
default location.
|
static JetInstance |
Jet.newJetInstance(JetConfig config)
Creates a member of the Jet cluster with the given configuration.
|
Modifier and Type | Method and Description |
---|---|
JetInstance |
ProcessorMetaSupplier.Context.jetInstance()
Returns the current Jet instance.
|
Modifier and Type | Method and Description |
---|---|
JetInstance |
TestProcessorMetaSupplierContext.jetInstance() |
Modifier and Type | Method and Description |
---|---|
TestSupport |
TestSupport.jetInstance(JetInstance jetInstance)
Use the given instance for
ProcessorMetaSupplier.Context.jetInstance() |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setJetInstance(JetInstance jetInstance) |
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setJetInstance(JetInstance jetInstance)
Sets the jet instance.
|
TestProcessorContext |
TestProcessorContext.setJetInstance(JetInstance jetInstance) |
Modifier and Type | Method and Description |
---|---|
DistributedFunction<JetInstance,? extends C> |
ContextFactory.createFn()
Returns the create-function.
|
Modifier and Type | Method and Description |
---|---|
static <C> ContextFactory<C> |
ContextFactory.withCreateFn(DistributedFunction<JetInstance,? extends C> createContextFn)
Creates a new
ContextFactory with the given create-function. |
Modifier and Type | Method and Description |
---|---|
static JetInstance |
JetBootstrap.getInstance()
Returns the bootstrapped
JetInstance . |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.