This is an automated email from the ASF dual-hosted git repository.
Abacn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new f5f60065ec9 rename TestRecord (#40728)
f5f60065ec9 is described below
commit f5f60065ec92242b562f87a5968337634c534b5d
Author: Abdelrahman Ibrahim <[email protected]>
AuthorDate: Thu Oct 22 17:01:58 2026 +0300
rename TestRecord (#40728)
---
.../util/construction/CoderTranslationTest.java | 23 +++++++++++-----------
1 file changed, 12 insertions(+), 11 deletions(-)
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 f743b9a0b60..81a79b65c34 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 class CoderTranslationTest {
.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 class CoderTranslationTest {
}
}
- static class Record implements Serializable {}
+ static class TestRecord implements Serializable {}
- private static class RecordCoder extends AtomicCoder<Record> {
+ private static class TestRecordCoder extends AtomicCoder<TestRecord> {
@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();
}
}
}