Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Class and Description |
---|---|
class |
SessionWindowDef<T>
Represents the definition of a
session window. |
class |
SlidingWindowDef
Represents the definition of a
sliding
window . |
Modifier and Type | Method and Description |
---|---|
<W extends WindowDefinition> |
WindowDefinition.downcast()
Returns this window definition downcast to the type determined through
type inference at the call site.
|
Modifier and Type | Method and Description |
---|---|
WindowDefinition |
StageWithWindow.windowDefinition()
Returns the definition of the window for the windowed aggregation
operation that you are about to construct using this object.
|
WindowDefinition |
StageWithKeyAndWindow.windowDefinition()
Returns the definition of the window for the windowed aggregation
operation that you are about to construct using this object.
|
Modifier and Type | Method and Description |
---|---|
StageWithKeyAndWindow<T,K> |
StreamStageWithKey.window(WindowDefinition wDef)
Adds the definition of the window to use in the group-and-aggregate
pipeline stage being constructed.
|
StageWithWindow<T> |
StreamStage.window(WindowDefinition wDef)
Adds the given window definition to this stage, as the first step in the
construction of a pipeline stage that performs windowed aggregation.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.