| Modifier and Type | Method and Description |
|---|---|
TransformProcess.Builder |
TransformProcess.Builder.reduce(IAssociativeReducer reducer)
Reduce (i.e., aggregate/combine) a set of examples (typically by key).
|
TransformProcess.Builder |
TransformProcess.Builder.reduceSequence(IAssociativeReducer reducer)
Reduce (i.e., aggregate/combine) a set of sequence examples - for each sequence individually.
|
TransformProcess.Builder |
TransformProcess.Builder.reduceSequenceByWindow(IAssociativeReducer reducer,
WindowFunction windowFunction)
Reduce (i.e., aggregate/combine) a set of sequence examples - for each sequence individually - using a window function.
|
| Constructor and Description |
|---|
DataAction(IAssociativeReducer reducer) |
| Modifier and Type | Class and Description |
|---|---|
class |
Reducer
A Reducer is used to take a set of examples and reduce them.
|
| Constructor and Description |
|---|
ReduceSequenceTransform(IAssociativeReducer reducer) |
| Constructor and Description |
|---|
ReduceSequenceByWindowTransform(IAssociativeReducer reducer,
WindowFunction windowFunction) |
| Modifier and Type | Method and Description |
|---|---|
IAssociativeReducer |
BaseSerializer.deserializeReducer(String str)
Deserialize an IStringReducer serialized using
BaseSerializer.serialize(Object) |
| Modifier and Type | Method and Description |
|---|---|
List<IAssociativeReducer> |
BaseSerializer.deserializeReducerList(String str)
Deserialize an IStringReducer List serialized using
BaseSerializer.serializeReducerList(List), or
an array serialized using #serialize(IReducer[]) |
| Modifier and Type | Method and Description |
|---|---|
String |
BaseSerializer.serialize(IAssociativeReducer[] reducers) |
| Modifier and Type | Method and Description |
|---|---|
String |
BaseSerializer.serializeReducerList(List<IAssociativeReducer> list)
Serialize a list of IReducers
|
| Constructor and Description |
|---|
ReducerList(List<IAssociativeReducer> list) |
Copyright © 2020. All rights reserved.