@Test public void testDupSort() throws Exception { BufferManager mgr = BufferManagerFactory.getStandaloneBufferManager(); GroupingNode node = getExampleGroupingNode(); node.setRemoveDuplicates(true); CommandContext context = new CommandContext("pid", "test", null, null, 1); List[] expected = new List[] { Arrays.asList(new Object[] { null, new Integer(1) }), Arrays.asList(new Object[] { new Integer(0), new Integer(1) }), Arrays.asList(new Object[] { new Integer(1), new Integer(1) }), Arrays.asList(new Object[] { new Integer(2), new Integer(2) }), Arrays.asList(new Object[] { new Integer(3), new Integer(1) }), Arrays.asList(new Object[] { new Integer(4), new Integer(2) }), Arrays.asList(new Object[] { new Integer(5), new Integer(1) }), Arrays.asList(new Object[] { new Integer(6), new Integer(2) }) }; helpProcess(mgr, node, context, expected, null); }
public void setRemoveDuplicates(boolean removeDuplicates) { this.removeDuplicates = removeDuplicates; }
GroupingNode extends SubqueryAwareRelationalNode { public void setRemoveDuplicates(boolean removeDuplicates) { this.removeDuplicates = removeDuplicates; } }
GroupingNode extends SubqueryAwareRelationalNode { public void setRemoveDuplicates(boolean removeDuplicates) { this.removeDuplicates = removeDuplicates; } GroupingNode(int nodeID); }
GroupingNode extends SubqueryAwareRelationalNode { public void setRemoveDuplicates(boolean removeDuplicates) { this.removeDuplicates = removeDuplicates; } GroupingNode(int nodeID); void reset(); void setRemoveDuplicates(boolean removeDuplicates); void setOrderBy(List<OrderByItem> orderBy); void setOutputMapping(SymbolMap outputMapping); @Override void initialize(CommandContext context, BufferManager bufferManager,
            ProcessorDataManager dataMgr); TupleBatch nextBatchDirect(); TupleSource getGroupSortTupleSource(); @Override Collection<? extends LanguageObject> getObjects(); static int sameGroup(int[] indexes, List<?> newTuple, List<?> oldTuple); void closeDirect(); Object clone(); PlanNode getDescriptionProperties(); void setRollup(boolean rollup); }
GroupingNode extends SubqueryAwareRelationalNode { public void setRemoveDuplicates(boolean removeDuplicates) { this.removeDuplicates = removeDuplicates; } GroupingNode(int nodeID); void reset(); void setRemoveDuplicates(boolean removeDuplicates); void setOrderBy(List<OrderByItem> orderBy); void setOutputMapping(SymbolMap outputMapping); @Override void initialize(CommandContext context, BufferManager bufferManager,
            ProcessorDataManager dataMgr); TupleBatch nextBatchDirect(); TupleSource getGroupSortTupleSource(); @Override Collection<? extends LanguageObject> getObjects(); static int sameGroup(int[] indexes, List<?> newTuple, List<?> oldTuple); void closeDirect(); Object clone(); PlanNode getDescriptionProperties(); void setRollup(boolean rollup);  }