diff options
Diffstat (limited to 'vespa-hadoop')
-rw-r--r-- | vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/LegacyVespaRecordWriter.java (renamed from vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java) | 8 | ||||
-rw-r--r-- | vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaOutputFormat.java | 4 |
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); } |