@Test
@Ignore
public void testOnDiskStreamingIterator() {

    Database db = (Database) store;
    int count = TestData.getScaleCount() * 5;
    Set<Revision<PrimaryKey, Text, Value>> expected = Sets
            .newLinkedHashSetWithExpectedSize(count);
    for (int i = 0; i < count; ++i) {
        Write write = Write.add(TestData.getSimpleString(),
                TestData.getTObject(), i);
        db.accept(write);
        Revision<PrimaryKey, Text, Value> revision = Revision
                .createPrimaryRevision(write.getRecord(), write.getKey(),
                        write.getValue(), write.getVersion(),
                        write.getType());
        expected.add(revision);
        Variables.register("expected_" + i, revision);
        if(i % 100 == 0) {
            db.triggerSync();
        }
    }
    db.triggerSync();
    Iterator<Revision<PrimaryKey, Text, Value>> it = Database
            .onDiskStreamingIterator(db.getBackingStore());
    Iterator<Revision<PrimaryKey, Text, Value>> it2 = expected.iterator();
    int i = 0;
    while (it.hasNext()) {
        Revision<PrimaryKey, Text, Value> actual = it.next();
        Assert.assertEquals(it2.next(), actual);
        Variables.register("actual_" + i, actual);
        ++i;
    }
}