@Test @Category(UnitTest.class) public void getProgress() throws Exception { }
@Override public float getProgress() throws IOException, InterruptedException { if (startTileId == endTileId) { return 0.0f; } else { return Math.min(1.0f, (recordCount - startTileId) / (float) (endTileId - startTileId)); } }
HdfsMrsPyramidRecordReader extends RecordReader<TileIdWritable, RasterWritable> { @Override public float getProgress() throws IOException, InterruptedException { if (startTileId == endTileId) { return 0.0f; } else { return Math.min(1.0f, (recordCount - startTileId) / (float) (endTileId - startTileId)); } } }
HdfsMrsPyramidRecordReader extends RecordReader<TileIdWritable, RasterWritable> { @Override public float getProgress() throws IOException, InterruptedException { if (startTileId == endTileId) { return 0.0f; } else { return Math.min(1.0f, (recordCount - startTileId) / (float) (endTileId - startTileId)); } } HdfsMrsPyramidRecordReader();  HdfsMrsPyramidRecordReader(ReaderFactory readerFactory); }
HdfsMrsPyramidRecordReader extends RecordReader<TileIdWritable, RasterWritable> { @Override public float getProgress() throws IOException, InterruptedException { if (startTileId == endTileId) { return 0.0f; } else { return Math.min(1.0f, (recordCount - startTileId) / (float) (endTileId - startTileId)); } } HdfsMrsPyramidRecordReader();  HdfsMrsPyramidRecordReader(ReaderFactory readerFactory); @Override TileIdWritable getCurrentKey(); @Override RasterWritable getCurrentValue(); @Override // TODO eaw this should probably throw an UnsupportedOperationException since it does not meet the contract on getProgress because recordCount is never updated float getProgress(); @Override void close(); @Override void initialize(InputSplit split, TaskAttemptContext context); @Override boolean nextKeyValue(); }
HdfsMrsPyramidRecordReader extends RecordReader<TileIdWritable, RasterWritable> { @Override public float getProgress() throws IOException, InterruptedException { if (startTileId == endTileId) { return 0.0f; } else { return Math.min(1.0f, (recordCount - startTileId) / (float) (endTileId - startTileId)); } } HdfsMrsPyramidRecordReader();  HdfsMrsPyramidRecordReader(ReaderFactory readerFactory); @Override TileIdWritable getCurrentKey(); @Override RasterWritable getCurrentValue(); @Override // TODO eaw this should probably throw an UnsupportedOperationException since it does not meet the contract on getProgress because recordCount is never updated float getProgress(); @Override void close(); @Override void initialize(InputSplit split, TaskAttemptContext context); @Override boolean nextKeyValue();  }