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.