Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
com.hazelcast.jet.datamodel |
Generic data containers used by the Pipeline API.
|
Modifier and Type | Method and Description |
---|---|
static <T0,T1> AggregateOperation2<T0,T1,TwoBags<T0,T1>,TwoBags<T0,T1>> |
AggregateOperations.toTwoBags()
Returns an
AggregateOperation that accumulates the items from
exactly two inputs into TwoBags : items from inputN are
accumulated into bagN. |
static <T0,T1> AggregateOperation2<T0,T1,TwoBags<T0,T1>,TwoBags<T0,T1>> |
AggregateOperations.toTwoBags()
Returns an
AggregateOperation that accumulates the items from
exactly two inputs into TwoBags : items from inputN are
accumulated into bagN. |
Modifier and Type | Method and Description |
---|---|
TwoBags<T0,T1> |
TwoBags.finish()
Returns a safe copy of this container.
|
static <E0,E1> TwoBags<E0,E1> |
TwoBags.twoBags()
Returns a new, empty
TwoBags container. |
static <E0,E1> TwoBags<E0,E1> |
TwoBags.twoBags(Collection<E0> bag0,
Collection<E1> bag1)
Returns a new
TwoBags container populated with the supplied
collections. |
Modifier and Type | Method and Description |
---|---|
void |
TwoBags.combineWith(TwoBags<T0,T1> that)
Combines this and the supplied container by merging all the supplied
container's data into this one.
|
void |
TwoBags.deduct(TwoBags<T0,T1> that)
Deducts the supplied container from this one by removing all the items
that the supplied one contains.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.