Package com.findwise.hydra

Examples of com.findwise.hydra.DatabaseException


   */
  public void addLibrary(String id, String filename, InputStream stream) throws DatabaseException {
    try {
      getConnector().getPipelineWriter().save(id, filename, stream);
    } catch (IOException e) {
      throw new DatabaseException("Failed to connect to database", e);
    }
  }
View Full Code Here


        libraries.add(getLibraryMap(df));
      }
      map.put("libraries", libraries);
      return map;
    } catch (IOException e) {
      throw new DatabaseException("Failed to scan pipeline", e);
    }
  }
View Full Code Here

          return getLibraryMap(df);
        }
      }
      return null;
    } catch (IOException e) {
      throw new DatabaseException("Failed to scan pipeline", e);
    }
  }
View Full Code Here

        throw new StageClassNotFoundException("Stage class '" + stageClass
            + "' for stage '" + stage.getName() + "' not found."
            + " Available stage classes: '" + stages.keySet() + "'");
      }
    } catch (IOException e) {
      throw new DatabaseException("Failed to scan pipeline", e);
    }
  }
View Full Code Here

    PipelineScanner<T> scanner = null;
    try {
      databaseConnector = getConnector();
      scanner = getPipelineScanner();
    } catch (IOException e) {
      throw new DatabaseException("Failed to connect to database", e);
    }
    DocumentReader<T> documentReader = databaseConnector.getDocumentReader();
    PipelineStatus<T> pipelineStatus = databaseConnector.getStatusReader().getStatus();
    documentMap.put("current", documentReader.getActiveDatabaseSize());
    documentMap.put("throughput", 0); // TODO actually implement this
View Full Code Here

TOP

Related Classes of com.findwise.hydra.DatabaseException

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.