/home/palakars/workspace-inprogress/code-in-progress/aitools3/aitools3-aq-invertedindex2-java/src/de/aitools/aq/invertedindex/core/Indexer.java

Go to the documentation of this file.

// Copyright (C) 2011 webis.de. All rights reserved.
package de.aitools.aq.invertedindex.core;

import com.sun.jna.Native;
import com.sun.jna.Pointer;

import de.aitools.aq.check.A;
import de.aitools.aq.invertedindex.core.Configuration.ConfigurationImpl;
import de.aitools.aq.invertedindex.core.Configuration.KeySorting;
import de.aitools.aq.invertedindex.core.Configuration.ValueSorting;
import de.aitools.aq.invertedindex.core.Properties.PropertiesImpl;
import de.aitools.aq.util.Record;
import de.aitools.aq.util.ToAsciiEncoder;
import de.aitools.aq.value.Value;

public class Indexer<V extends Value> {

        static {
                Native.register(Configuration.NATIVE_LIB);
                System.out.println(Configuration.NATIVE_LIB + " loaded");
        }
        
        public static <V extends Value> Indexer<V>
        open(Class<V> clazz, Configuration config) {
                Pointer natIndexer =
                        indexer_open(Value.getNativeTypeId(clazz), config.impl);
                if (natIndexer == null) {
                        throw new RuntimeException("Cannot create native Indexer");
                }
                return new Indexer<V>(natIndexer);
        }
        
        private Indexer(Pointer nativeIndexer) {
                A.CHECK_NOT_NULL(nativeIndexer);
                this.nativeIndexer = nativeIndexer;
        }
        
        public void close() {
                indexer_close(nativeIndexer);
                nativeIndexer = null;
        }
        
        public void setExpectedNumberOfRecords(long numberOfRecords) {
                indexer_set_expected_record_count(nativeIndexer, numberOfRecords);
        }
        
        @Override
        protected void finalize() throws Throwable {
                close();
                super.finalize();
        }

        public Properties index() {
                Properties props = new Properties();
                indexer_index(nativeIndexer, props.impl);
                nativeIndexer = null;
                return props;
        }
        
        public boolean put(String key, V value) {
                Pointer buffer = value.getSharedMemory();
                value.copyTo(buffer);
                return indexer_insert(nativeIndexer,
                                ToAsciiEncoder.encode(key), buffer);
        }
        
        public boolean put(Record<V> record) {
                return put(record.getKey(), record.getValue());
        }
        
        private Pointer nativeIndexer;
        
        // -------------------------------------------------------------------------
        // JNA functions - TOUCH AND DIE
        // -------------------------------------------------------------------------
        
        private static native Pointer indexer_open(
                        int type_id, ConfigurationImpl config);
        private native void indexer_set_expected_record_count(
                        Pointer raw_indexer, long record_count);
        private native boolean indexer_insert(
                        Pointer raw_indexer, String key, Pointer value);
        private native void indexer_index(
                        Pointer raw_indexer, PropertiesImpl props);
        private native void indexer_close(Pointer raw_indexer);
}

---