Rename to LegacyVespaRecordWriter

2 files changed, 6 insertions, 6 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/LegacyVespaRecordWriter.java
index 4cc93bfd538..8b320fc9436 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/LegacyVespaRecordWriter.java
@@ -36,14 +36,14 @@ import java.util.concurrent.ThreadLocalRandom;
 import java.util.logging.Logger;
 
 /**
- * VespaRecordWriter sends the output <key, value> to one or more Vespa endpoints.
+ * {@link LegacyVespaRecordWriter} sends the output <key, value> to one or more Vespa endpoints.
  *
  * @author lesters
  */
 @SuppressWarnings("rawtypes")
-public class VespaRecordWriter extends RecordWriter {
+public class LegacyVespaRecordWriter extends RecordWriter {
 
-    private final static Logger log = Logger.getLogger(VespaRecordWriter.class.getCanonicalName());
+    private final static Logger log = Logger.getLogger(LegacyVespaRecordWriter.class.getCanonicalName());
 
     private boolean initialized = false;
     private FeedClient feedClient;
@@ -52,7 +52,7 @@ public class VespaRecordWriter extends RecordWriter {
 
     final VespaConfiguration configuration;
 
-    VespaRecordWriter(VespaConfiguration configuration, VespaCounters counters) {
+    LegacyVespaRecordWriter(VespaConfiguration configuration, VespaCounters counters) {
         this.counters = counters;
         this.configuration = configuration;
         this.progressInterval = configuration.progressInterval();
diff --git a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaOutputFormat.java b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaOutputFormat.java
index bef51e9ae08..74f23e8cc6a 100644
--- a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaOutputFormat.java
+++ b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaOutputFormat.java
@@ -10,7 +10,7 @@ import java.util.Properties;
 
 /**
  * An output specification for writing to Vespa instances in a Map-Reduce job.
- * Mainly returns an instance of a {@link VespaRecordWriter} that does the
+ * Mainly returns an instance of a {@link LegacyVespaRecordWriter} that does the
  * actual feeding to Vespa.
  *
  * @author lesters
@@ -35,7 +35,7 @@ public class VespaOutputFormat extends OutputFormat {
     public RecordWriter getRecordWriter(TaskAttemptContext context) throws IOException, InterruptedException {
         VespaCounters counters = VespaCounters.get(context);
         VespaConfiguration configuration = VespaConfiguration.get(context.getConfiguration(), configOverride);
-        return new VespaRecordWriter(configuration, counters);
+        return new LegacyVespaRecordWriter(configuration, counters);
     }