Package cascading.flow.stream.util

Examples of cascading.flow.stream.util.SparseTupleComparator$NaturalComparator


      compareFields[ pos ] = groupFields; // used for finding hashers

      if( groupFields.size() == 0 )
        groupComparators[ pos ] = groupFields;
      else
        groupComparators[ pos ] = new SparseTupleComparator( Fields.asDeclaration( groupFields ), defaultComparator );

      groupComparators[ pos ] = splice.isSortReversed() ? Collections.reverseOrder( groupComparators[ pos ] ) : groupComparators[ pos ];

      if( sortFields != null )
        {
        // we want the comparators, so don't use sortFields array
        Fields sortFields = splice.getSortingSelectors().get( incomingScope.getName() );
        valueComparators[ pos ] = new SparseTupleComparator( valuesFields[ pos ], sortFields, defaultComparator );

        if( splice.isSortReversed() )
          valueComparators[ pos ] = Collections.reverseOrder( valueComparators[ pos ] );
        }
      }
View Full Code Here


    list.add( new Tuple( "2", "10", "1" ) );
    list.add( new Tuple( "1", "1", "1" ) );
    list.add( new Tuple( "3", "1", "1" ) );

    Collections.sort( list, new SparseTupleComparator( fields, sortFields, defaultComparator ) );

    assertEquals( result, list );
    }
View Full Code Here

TOP

Related Classes of cascading.flow.stream.util.SparseTupleComparator$NaturalComparator

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.