diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/util/construction/CoderTranslationTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/util/construction/CoderTranslationTest.java index f743b9a0b60c..81a79b65c34c 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/util/construction/CoderTranslationTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/util/construction/CoderTranslationTest.java @@ -224,14 +224,14 @@ public static Iterable> data() { .addAll(KNOWN_CODERS) .add( StringUtf8Coder.of(), - SerializableCoder.of(Record.class), - new RecordCoder(), - KvCoder.of(new RecordCoder(), StringUtf8Coder.of())) + SerializableCoder.of(TestRecord.class), + new TestRecordCoder(), + KvCoder.of(new TestRecordCoder(), StringUtf8Coder.of())) .add( StringUtf8Coder.of(), - SerializableCoder.of(Record.class), - new RecordCoder(), - KvCoder.of(new RecordCoder(), StringUtf8Coder.of())) + SerializableCoder.of(TestRecord.class), + new TestRecordCoder(), + KvCoder.of(new TestRecordCoder(), StringUtf8Coder.of())) .add(UnknownCoderWrapper.of("dummy_urn", new byte[] {})) .build(); } @@ -262,15 +262,16 @@ public void toAndFromProto() throws Exception { } } - static class Record implements Serializable {} + static class TestRecord implements Serializable {} - private static class RecordCoder extends AtomicCoder { + private static class TestRecordCoder extends AtomicCoder { @Override - public void encode(Record value, OutputStream outStream) throws CoderException, IOException {} + public void encode(TestRecord value, OutputStream outStream) + throws CoderException, IOException {} @Override - public Record decode(InputStream inStream) throws CoderException, IOException { - return new Record(); + public TestRecord decode(InputStream inStream) throws CoderException, IOException { + return new TestRecord(); } } }