ChecksumHashCode extends DataSetAnalyticBase<T, Checksum> { @Override public ChecksumHashCode<T> run(DataSet<T> input) throws Exception { super.run(input); checksumHashCodeHelper = new ChecksumHashCodeHelper<>(); input .output(checksumHashCodeHelper) .name("ChecksumHashCode"); return this; }  @Override ChecksumHashCode<T> run(DataSet<T> input); @Override Checksum getResult();  }
@Test public void testEmptyList() throws Exception { DataSet<Long> dataset = env.fromCollection(Collections.emptyList(), TypeInformation.of(new TypeHint<Long>(){})); Checksum checksum = new ChecksumHashCode<Long>().run(dataset).execute(); assertEquals(0, checksum.getCount()); assertEquals(0, checksum.getChecksum()); }