process all rows computes and writes aggregation values of current batch that are part of current partition . concode_field_sep VectorContainer container concode_elem_sep int frameLastRow concode_elem_sep List<WindowDataBatch> batches concode_elem_sep int outputCount concode_elem_sep long remainingPeers concode_elem_sep org.slf4j.Logger logger concode_elem_sep VectorContainer internal concode_elem_sep WindowDataBatch current concode_elem_sep WindowPOP popConfig concode_elem_sep long remainingRows concode_elem_sep boolean requireFullPartition concode_elem_sep boolean partialPartition concode_field_sep void setupSaveFirstValue concode_elem_sep boolean isPartitionDone concode_elem_sep void updatePartitionSize concode_elem_sep void saveFirstValue concode_elem_sep void writeLastValue concode_elem_sep void allocateInternal concode_elem_sep void setupPartition concode_elem_sep boolean isPeer concode_elem_sep int processRANGE concode_elem_sep void setupReadLastValue concode_elem_sep boolean resetValues concode_elem_sep void newPartition concode_elem_sep void outputRow concode_elem_sep void cleanup concode_elem_sep boolean isSamePartition concode_elem_sep void doWork concode_elem_sep int processROWS concode_elem_sep void setupWriteFirstValue concode_elem_sep void setup concode_elem_sep void reset concode_elem_sep void evaluatePeer concode_elem_sep long aggregatePeers concode_elem_sep void setupEvaluatePeer concode_elem_sep int getOutputCount
int function ( final int arg0 ) { logger . trace ( "srini_string" , remainingRows , arg0 , outputCount ) ; setupWriteFirstValue ( internal , container ) ; if ( popConfig . isFrameUnitsRows ( ) ) { return processROWS ( arg0 ) ; } else { return processRANGE ( arg0 ) ; } }