GroupCount (Data Pipeline JavaDoc)

java.lang.Object

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

com.northconcepts.datapipeline.group.operation.GroupCount

public class GroupCount extends GroupOperation<Long>

A GroupOperation that counts the records in each group.

Constructor Summary

Constructors

Constructor

Description

GroupCount(FieldPath targetFieldName)

GroupCount(String targetFieldName)
Method Summary

Modifier and Type

Method

Description

protected GroupOperationField<Long>

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
- GroupCount
  
  public GroupCount(String targetFieldName)
- GroupCount
  
  public GroupCount(FieldPath targetFieldName)
Method Details
- createField
  
  protected GroupOperationField<Long> 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<Long>