GroupMaximum (Data Pipeline JavaDoc)

java.lang.Object

com.northconcepts.datapipeline.group.GroupOperation<Object>

com.northconcepts.datapipeline.group.operation.GroupMaximum

public class GroupMaximum extends GroupOperation<Object>

A GroupOperation that returns the largest non-null value of the source field in each group.

Constructor Summary

Constructors

Constructor

Description

GroupMaximum(FieldPath sourceFieldName)

GroupMaximum(FieldPath sourceFieldName, FieldPath targetFieldName)

GroupMaximum(FieldPath sourceFieldName, FieldPath targetFieldName, boolean excludeNulls)

GroupMaximum(String sourceFieldName)

GroupMaximum(String sourceFieldName, String targetFieldName)

GroupMaximum(String sourceFieldName, String targetFieldName, boolean excludeNulls)
Method Summary

Modifier and Type

Method

Description

protected GroupOperationField<Object>

createField()

Creates the accumulator that computes this operation's result for one group; called once per group in each window.

Methods inherited from class com.northconcepts.datapipeline.group.GroupOperation
getExcludeNulls, getFilter, getSourceFieldName, getSourceFieldPath, getTargetFieldName, getTargetFieldPath, setExcludeNulls, setFilter, setTargetFieldName, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- GroupMaximum
  
  public GroupMaximum(String sourceFieldName)
- GroupMaximum
  
  public GroupMaximum(FieldPath sourceFieldName)
- GroupMaximum
  
  public GroupMaximum(String sourceFieldName, String targetFieldName)
- GroupMaximum
  
  public GroupMaximum(FieldPath sourceFieldName, FieldPath targetFieldName)
- GroupMaximum
  
  public GroupMaximum(String sourceFieldName, String targetFieldName, boolean excludeNulls)
- GroupMaximum
  
  public GroupMaximum(FieldPath sourceFieldName, FieldPath targetFieldName, boolean excludeNulls)
Method Details
- createField
  
  protected GroupOperationField<Object> createField()
  
  Description copied from class: GroupOperation
  
  Creates the accumulator that computes this operation's result for one group; called once per group in each window.
  
  Specified by:
  
  createField in class GroupOperation<Object>