@Test public void testEmptySources() throws Exception { SortedGroupedMergedInput input = new SortedGroupedMergedInput(); SortedTestKeyValuesReader kvsReader1 = new SortedTestKeyValuesReader(new int[] {}, new int[][] {}); SortedTestKeyValuesReader kvsReader2 = new SortedTestKeyValuesReader(new int[] {}, new int[][] {}); SortedTestKeyValuesReader kvsReader3 = new SortedTestKeyValuesReader(new int[] {}, new int[][] {}); SortedTestInput sInput1 = new SortedTestInput(kvsReader1); SortedTestInput sInput2 = new SortedTestInput(kvsReader2); SortedTestInput sInput3 = new SortedTestInput(kvsReader3); List<Input> sInputs = new LinkedList<Input>(); sInputs.add(sInput1); sInputs.add(sInput2); sInputs.add(sInput3); input.initialize(sInputs); KeyValuesReader kvsReader = input.getReader(); assertFalse(kvsReader.next()); }
@Override public KeyValuesReader getReader() throws Exception { return new SortedGroupedMergedKeyValuesReader(getInputs()); }
SortedGroupedMergedInput extends MergedLogicalInput { @Override public KeyValuesReader getReader() throws Exception { return new SortedGroupedMergedKeyValuesReader(getInputs()); } }
SortedGroupedMergedInput extends MergedLogicalInput { @Override public KeyValuesReader getReader() throws Exception { return new SortedGroupedMergedKeyValuesReader(getInputs()); }  }
SortedGroupedMergedInput extends MergedLogicalInput { @Override public KeyValuesReader getReader() throws Exception { return new SortedGroupedMergedKeyValuesReader(getInputs()); }  @Override KeyValuesReader getReader(); @Override void setConstituentInputIsReady(Input input); }
SortedGroupedMergedInput extends MergedLogicalInput { @Override public KeyValuesReader getReader() throws Exception { return new SortedGroupedMergedKeyValuesReader(getInputs()); }  @Override KeyValuesReader getReader(); @Override void setConstituentInputIsReady(Input input);  }