private void processInsert(Row row) {
		// limit the materialized table
		if (materializedTable.size() - validRowPosition >= maxRowCount) {
			cleanUp();
		}
		materializedTable.add(row);
		rowPositionCache.put(row, materializedTable.size() - 1);
	}
private void processInsert ( Row row ) { if ( materializedTable . size ( ) - validRowPosition >= maxRowCount ) { cleanUp ( ) ; } materializedTable . add ( row ) ; rowPositionCache . put ( row , materializedTable . size ( ) - 1 ) ; }
--------------------------------------------------------------------------------------------