blob: b1bce5f3997e171e97d2e12f6ce876acd24d0905 [file] [log] [blame]
/*
* Copyright 2009-2013 by The Regents of the University of California
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* you may obtain a copy of the License from
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package edu.uci.ics.hyracks.storage.am.rtree;
import edu.uci.ics.hyracks.api.dataflow.value.ISerializerDeserializer;
import edu.uci.ics.hyracks.api.exceptions.HyracksDataException;
import edu.uci.ics.hyracks.data.std.primitive.IntegerPointable;
import edu.uci.ics.hyracks.dataflow.common.data.marshalling.IntegerSerializerDeserializer;
import edu.uci.ics.hyracks.storage.am.common.AbstractIndexLifecycleTest;
import edu.uci.ics.hyracks.storage.am.common.CheckTuple;
import edu.uci.ics.hyracks.storage.am.common.IIndexTestContext;
import edu.uci.ics.hyracks.storage.am.common.TreeIndexTestUtils;
import edu.uci.ics.hyracks.storage.am.common.api.IPrimitiveValueProviderFactory;
import edu.uci.ics.hyracks.storage.am.common.api.ITreeIndexFrame;
import edu.uci.ics.hyracks.storage.am.rtree.frames.RTreePolicyType;
import edu.uci.ics.hyracks.storage.am.rtree.impls.RTree;
import edu.uci.ics.hyracks.storage.am.rtree.util.RTreeUtils;
import edu.uci.ics.hyracks.storage.am.rtree.utils.RTreeTestContext;
import edu.uci.ics.hyracks.storage.am.rtree.utils.RTreeTestHarness;
public class RTreeLifecycleTest extends AbstractIndexLifecycleTest {
private final RTreeTestHarness harness = new RTreeTestHarness();
private final TreeIndexTestUtils titu = new RTreeTestUtils();
@SuppressWarnings("rawtypes")
private final ISerializerDeserializer[] fieldSerdes = { IntegerSerializerDeserializer.INSTANCE,
IntegerSerializerDeserializer.INSTANCE, IntegerSerializerDeserializer.INSTANCE,
IntegerSerializerDeserializer.INSTANCE, IntegerSerializerDeserializer.INSTANCE };
private final IPrimitiveValueProviderFactory[] valueProviderFactories = RTreeUtils
.createPrimitiveValueProviderFactories(4, IntegerPointable.FACTORY);
private final int numKeys = 4;
@SuppressWarnings("rawtypes")
private IIndexTestContext<? extends CheckTuple> testCtx;
private ITreeIndexFrame frame = null;
@Override
public void setup() throws Exception {
harness.setUp();
testCtx = RTreeTestContext.create(harness.getBufferCache(), harness.getFileMapProvider(),
harness.getFileReference(), fieldSerdes, valueProviderFactories, numKeys, RTreePolicyType.RTREE);
index = testCtx.getIndex();
}
@Override
public void tearDown() throws HyracksDataException {
try {
testCtx.getIndex().deactivate();
} catch (Exception e) {
} finally {
testCtx.getIndex().destroy();
}
harness.tearDown();
}
@Override
protected boolean persistentStateExists() {
return harness.getFileReference().getFile().exists();
}
@Override
protected boolean isEmptyIndex() throws HyracksDataException {
RTree rtree = (RTree) testCtx.getIndex();
if (frame == null) {
frame = rtree.getInteriorFrameFactory().createFrame();
}
return rtree.isEmptyTree(frame);
}
@Override
protected void performInsertions() throws Exception {
titu.insertIntTuples(testCtx, 10, harness.getRandom());
}
@Override
protected void checkInsertions() throws Exception {
titu.checkScan(testCtx);
}
@Override
protected void clearCheckableInsertions() throws Exception {
testCtx.getCheckTuples().clear();
}
}