@Test public void testEnqueue() throws IOException, InterruptedException { setupWriter(_configuration); runQueueTest(TOTAL_ROWS_FOR_TESTS, TOTAL_ROWS_FOR_TESTS); runQueueTest(TOTAL_ROWS_FOR_TESTS, TOTAL_ROWS_FOR_TESTS * 2); runQueueTest(TOTAL_ROWS_FOR_TESTS, TOTAL_ROWS_FOR_TESTS * 3); }
@Override public void enqueue(List<RowMutation> mutations) throws IOException { startQueueIfNeeded(); try { for (RowMutation mutation : mutations) { _queue.put(mutation); } synchronized (_queue) { _queue.notifyAll(); } } catch (InterruptedException e) { throw new IOException(e); } }
BlurIndexSimpleWriter extends BlurIndex { @Override public void enqueue(List<RowMutation> mutations) throws IOException { startQueueIfNeeded(); try { for (RowMutation mutation : mutations) { _queue.put(mutation); } synchronized (_queue) { _queue.notifyAll(); } } catch (InterruptedException e) { throw new IOException(e); } } }
BlurIndexSimpleWriter extends BlurIndex { @Override public void enqueue(List<RowMutation> mutations) throws IOException { startQueueIfNeeded(); try { for (RowMutation mutation : mutations) { _queue.put(mutation); } synchronized (_queue) { _queue.notifyAll(); } } catch (InterruptedException e) { throw new IOException(e); } } BlurIndexSimpleWriter(BlurIndexConfig blurIndexConf); }
BlurIndexSimpleWriter extends BlurIndex { @Override public void enqueue(List<RowMutation> mutations) throws IOException { startQueueIfNeeded(); try { for (RowMutation mutation : mutations) { _queue.put(mutation); } synchronized (_queue) { _queue.notifyAll(); } } catch (InterruptedException e) { throw new IOException(e); } } BlurIndexSimpleWriter(BlurIndexConfig blurIndexConf); int getReaderGenerationCount(); @Override IndexSearcherCloseable getIndexSearcher(); IndexSearcherCloseable getIndexSearcher(boolean security); @Override void close(); @Override synchronized void optimize(final int numberOfSegmentsPerShard); @Override void createSnapshot(String name); @Override void removeSnapshot(String name); @Override List<String> getSnapshots(); @Override void process(IndexAction indexAction); Path getSnapshotsDirectoryPath(); @Override void enqueue(List<RowMutation> mutations); synchronized BulkEntry startBulkMutate(String bulkId); @Override void finishBulkMutate(final String bulkId, boolean apply, boolean blockUntilComplete); @Override void addBulkMutate(String bulkId, RowMutation mutation); @Override long getRecordCount(); @Override long getRowCount(); @Override long getIndexMemoryUsage(); @Override long getSegmentCount(); @Override long getSegmentImportPendingCount(); @Override long getSegmentImportInProgressCount(); @Override long getOnDiskSize(); }
BlurIndexSimpleWriter extends BlurIndex { @Override public void enqueue(List<RowMutation> mutations) throws IOException { startQueueIfNeeded(); try { for (RowMutation mutation : mutations) { _queue.put(mutation); } synchronized (_queue) { _queue.notifyAll(); } } catch (InterruptedException e) { throw new IOException(e); } } BlurIndexSimpleWriter(BlurIndexConfig blurIndexConf); int getReaderGenerationCount(); @Override IndexSearcherCloseable getIndexSearcher(); IndexSearcherCloseable getIndexSearcher(boolean security); @Override void close(); @Override synchronized void optimize(final int numberOfSegmentsPerShard); @Override void createSnapshot(String name); @Override void removeSnapshot(String name); @Override List<String> getSnapshots(); @Override void process(IndexAction indexAction); Path getSnapshotsDirectoryPath(); @Override void enqueue(List<RowMutation> mutations); synchronized BulkEntry startBulkMutate(String bulkId); @Override void finishBulkMutate(final String bulkId, boolean apply, boolean blockUntilComplete); @Override void addBulkMutate(String bulkId, RowMutation mutation); @Override long getRecordCount(); @Override long getRowCount(); @Override long getIndexMemoryUsage(); @Override long getSegmentCount(); @Override long getSegmentImportPendingCount(); @Override long getSegmentImportInProgressCount(); @Override long getOnDiskSize();  }