Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -224,14 +224,14 @@ public static Iterable<Coder<?>> 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();
}
Expand Down Expand Up @@ -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<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();
}
}
}
Expand Down
Loading