diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-06-04 15:24:54 +0200 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-06-10 16:45:36 +0200 |
commit | 627e960f3261f0d8fbcfcebeab9fb05d5a1c1400 (patch) | |
tree | 0d339783df33e475ee0e1fdaf9081f05eede0b71 | |
parent | 0d9022bf30f71d068ba82d455d982c9ca7ada992 (diff) |
Rename to LegacyVespaRecordWriter
-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); } |