diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2022-01-24 15:00:56 +0100 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2022-01-24 15:00:56 +0100 |
commit | f9dee3e2a94ae91d25202c379d4f951a7977fb6b (patch) | |
tree | e87f6e3ea49a01b1546ec4bc94a030dec83a07d3 /vespa-hadoop | |
parent | b873f03349b85dec1bba04ed8af35da3902f3fbb (diff) |
Support feed over http using vespa-feed-client
Diffstat (limited to 'vespa-hadoop')
-rw-r--r-- | vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java index ecac9f67615..54de9e6c1c0 100644 --- a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java +++ b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java @@ -147,8 +147,9 @@ public class VespaRecordWriter extends RecordWriter<Object, Object> { } private static List<URI> endpointUris(VespaConfiguration config) { + String scheme = config.useSSL() ? "https" : "http"; return Arrays.stream(config.endpoint().split(",")) - .map(hostname -> URI.create(String.format("https://%s:%d/", hostname, config.defaultPort()))) + .map(hostname -> URI.create(String.format("%s://%s:%d/", scheme, hostname, config.defaultPort()))) .collect(toList()); } } |