GroupLast (Data Pipeline JavaDoc)

java.lang.Object

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

com.northconcepts.datapipeline.group.operation.GroupLast

public class GroupLast extends GroupOperation<Object>

A GroupOperation that returns the last value of the source field in each group (the last non-null value when excludeNulls is set).

Constructor Summary

Constructors

Constructor

Description

GroupLast(FieldPath sourceFieldName)

GroupLast(FieldPath sourceFieldName, FieldPath targetFieldName)

GroupLast(FieldPath sourceFieldName, FieldPath targetFieldName, boolean excludeNulls)

GroupLast(String sourceFieldName)

GroupLast(String sourceFieldName, String targetFieldName)

GroupLast(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
- GroupLast
  
  public GroupLast(String sourceFieldName)
- GroupLast
  
  public GroupLast(FieldPath sourceFieldName)
- GroupLast
  
  public GroupLast(String sourceFieldName, String targetFieldName)
- GroupLast
  
  public GroupLast(FieldPath sourceFieldName, FieldPath targetFieldName)
- GroupLast
  
  public GroupLast(String sourceFieldName, String targetFieldName, boolean excludeNulls)
- GroupLast
  
  public GroupLast(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>