summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2021-06-08 17:07:08 +0200
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2021-06-08 17:07:08 +0200
commitfe640886026882b7e44de43ed39deaec7f8636b7 (patch)
tree678fde72bef5265d11605776f506ec1056c453ac
parentc2dde0aa56a1b20961db4e9b10a802a44b61b795 (diff)
Rename 'feed' to 'feedMany'
-rw-r--r--vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java2
-rw-r--r--vespa-feed-client/src/main/java/ai/vespa/feed/client/JsonFeeder.java8
-rw-r--r--vespa-feed-client/src/test/java/ai/vespa/feed/client/JsonFeederTest.java2
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());
}