hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Wiki <wikidi...@apache.org>
Subject [Lucene-hadoop Wiki] Trivial Update of "DistributedLucene" by MarkButler
Date Mon, 14 Jan 2008 10:54:15 GMT
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);
  }
  }}}
  

Mime
View raw message