diff options
3 files changed, 6 insertions, 6 deletions
diff --git a/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java b/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java index 5c98c986990..40c6ac56022 100644 --- a/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java +++ b/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java @@ -59,7 +59,7 @@ public class CliClient { if (cliArgs.benchmarkModeEnabled()) { printBenchmarkResult(feeder.benchmark(in)); } else { - feeder.feed(in); + feeder.feedMany(in); } } return 0; diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/JsonFeeder.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/JsonFeeder.java index a4d75a0a7c7..0990e0edf60 100644 --- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/JsonFeeder.java +++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/JsonFeeder.java @@ -68,15 +68,15 @@ public class JsonFeeder implements Closeable { * </pre> * Note that {@code "id"} is an alias for the document put operation. */ - public void feed(InputStream jsonStream) throws IOException { - feed(jsonStream, 1 << 26, false); + public void feedMany(InputStream jsonStream) throws IOException { + feedMany(jsonStream, 1 << 26, false); } BenchmarkResult benchmark(InputStream jsonStream) throws IOException { - return feed(jsonStream, 1 << 26, true).get(); + return feedMany(jsonStream, 1 << 26, true).get(); } - Optional<BenchmarkResult> feed(InputStream jsonStream, int size, boolean benchmark) throws IOException { + Optional<BenchmarkResult> feedMany(InputStream jsonStream, int size, boolean benchmark) throws IOException { RingBufferStream buffer = new RingBufferStream(jsonStream, size); buffer.expect(JsonToken.START_ARRAY); AtomicInteger okCount = new AtomicInteger(); diff --git a/vespa-feed-client/src/test/java/ai/vespa/feed/client/JsonFeederTest.java b/vespa-feed-client/src/test/java/ai/vespa/feed/client/JsonFeederTest.java index 0f360fd94c7..60f6b3a4e73 100644 --- a/vespa-feed-client/src/test/java/ai/vespa/feed/client/JsonFeederTest.java +++ b/vespa-feed-client/src/test/java/ai/vespa/feed/client/JsonFeederTest.java @@ -61,7 +61,7 @@ class JsonFeederTest { @Override public void close(boolean graceful) { } - }).build().feed(in, 1 << 7, false); // TODO: hangs when buffer is smaller than largest document + }).build().feedMany(in, 1 << 7, false); // TODO: hangs when buffer is smaller than largest document System.err.println((json.length() / 1048576.0) + " MB in " + (System.nanoTime() - startNanos) * 1e-9 + " seconds"); assertEquals(docs + 1, ids.size()); } |