Dear Wiki user, You have subscribed to a wiki page or wiki category on "Lucene-hadoop Wiki" for change notification.
The following page has been changed by MarkButler: http://wiki.apache.org/lucene-hadoop/DistributedLucene ------------------------------------------------------------------------------ public class IndexVersion implements Comparable<IndexVersion>, Writable, Constants { private String id; private int version; + public IndexVersion(String id); public IndexVersion nextVersion(); public String getId(); @@ -22, +23 @@ private IndexVersion indexVersion; private InetSocketAddress location; private IndexState state; + public IndexLocation(InetSocketAddress location, IndexVersion indexVersion, IndexState state); public IndexLocation(DataNodeStatusInformation dnsi, IndexVersion indexVersion, IndexState state); public IndexVersion getIndexVersion(); @@ -38, +40 @@ private long capacityUsed; private long capacityRemaining; private DataNodeConfiguration dataconf; + - public DataNodeStatusInformation() throws IOException; + public DataNodeStatusInformation(); public InetSocketAddress getAddress(); public String getRack() ; public long getCapacity(); @@ -52, +55 @@ private File rootDir; private InetSocketAddress addr; private String rack; + - public DataNodeConfiguration(Configuration conf, String machineName, int port, String rack) throws IOException; + public DataNodeConfiguration(Configuration conf, String machineName, int port, String rack); public DataNodeConfiguration() throws IOException; public File getRootDir(); public InetSocketAddress getAddress(); @@ -73, +77 @@ {{{ public interface ClientToDataNodeProtocol extends VersionedProtocol { - void addDocument(String index, Document doc) throws IOException; + void addDocument(String index, Document doc); - int removeDocuments(String index, Term term) throws IOException; // Change here, Doug suggested int[] but that is different to current Lucene API + int removeDocuments(String index, Term term); - IndexVersion commitVersion(String index) throws IOException; + IndexVersion commitVersion(String index); - void createIndex(String index) throws IOException; + void createIndex(String index); - void addIndex(String index, IndexLocation indexToAdd) throws IOException; + void addIndex(String index, IndexLocation indexToAdd); - SearchResults search(IndexVersion i, Query query, Sort sort, int n) throws IOException; + SearchResults search(IndexVersion i, Query query, Sort sort, int n); } }}} @@ -96, +100 @@ {{{ public interface DataNodeToDataNodeProtocol extends VersionedProtocol { - String[] getFileSet(IndexVersion indexVersion) throws IOException; + String[] getFileSet(IndexVersion indexVersion); - byte[] getFileContent(IndexVersion indexVersion, String file) throws IOException; // based on experience in Hadoop we probably wouldn't really use RPC to find file content, instead HTTP + byte[] getFileContent(IndexVersion indexVersion, String file); } }}} @@ -106, +110 @@ {{{ public interface DataNodeToNameNodeProtocol extends VersionedProtocol { public IndexLocation[] heartbeat(DataNodeStatusInformation datanode, - IndexLocation[] searchableIndexes) throws RemoteException; + IndexLocation[] searchableIndexes); } }}} @@ -114, +118 @@ {{{ public interface ClientAPI { - void createIndex(String index, boolean sharded) throws IOException; + void createIndex(String index, boolean sharded); String[] getIndexes(); - void addDocument(String index, Document doc) throws IOException; + void addDocument(String index, Document doc); - int removeDocuments(String index, Term term) throws IOException; + int removeDocuments(String index, Term term); - void commit(String index) throws IOException; + void commit(String index); - SearchResults search(String index, Query query, Sort sort, int n) throws IOException; + SearchResults search(String index, Query query, Sort sort, int n); } }}}
