iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: Typos in Avro module

Browse Source
This commit is contained in:
gantoin
2023-01-18 11:09:58 +01:00
parent a4f6d89cc7
commit b62dcfbb36
3 changed files with 23 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apache-libraries/src/main/java/com/baeldung/avro/util/serealization/AvroDeSerealizer.java → apache-libraries/src/main/java/com/baeldung/avro/util/serialization/AvroDeSerializer.java
+5 -5
View File
@@ -1,4 +1,4 @@
package com.baeldung.avro.util.serealization;
package com.baeldung.avro.util.serialization;
import com.baeldung.avro.util.model.AvroHttpRequest;
import org.apache.avro.io.DatumReader;
@@ -10,11 +10,11 @@ import org.slf4j.LoggerFactory;
import java.io.IOException;
public class AvroDeSerealizer {
public class AvroDeSerializer {
private static Logger logger = LoggerFactory.getLogger(AvroDeSerealizer.class);
private static Logger logger = LoggerFactory.getLogger(AvroDeSerializer.class);
public AvroHttpRequest deSerealizeAvroHttpRequestJSON(byte[] data) {
public AvroHttpRequest deSerializeAvroHttpRequestJSON(byte[] data) {
DatumReader<AvroHttpRequest> reader = new SpecificDatumReader<>(AvroHttpRequest.class);
Decoder decoder = null;
try {
@@ -27,7 +27,7 @@ public class AvroDeSerealizer {
return null;
}
public AvroHttpRequest deSerealizeAvroHttpRequestBinary(byte[] data) {
public AvroHttpRequest deSerializeAvroHttpRequestBinary(byte[] data) {
DatumReader<AvroHttpRequest> employeeReader = new SpecificDatumReader<>(AvroHttpRequest.class);
Decoder decoder = DecoderFactory.get()
.binaryDecoder(data, null);
apache-libraries/src/main/java/com/baeldung/avro/util/serealization/AvroSerealizer.java → apache-libraries/src/main/java/com/baeldung/avro/util/serialization/AvroSerializer.java
+5 -5
View File
@@ -1,4 +1,4 @@
package com.baeldung.avro.util.serealization;
package com.baeldung.avro.util.serialization;
import com.baeldung.avro.util.model.AvroHttpRequest;
import org.apache.avro.io.*;
@@ -9,11 +9,11 @@ import org.slf4j.LoggerFactory;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
public class AvroSerealizer {
public class AvroSerializer {
private static final Logger logger = LoggerFactory.getLogger(AvroSerealizer.class);
private static final Logger logger = LoggerFactory.getLogger(AvroSerializer.class);
public byte[] serealizeAvroHttpRequestJSON(AvroHttpRequest request) {
public byte[] serializeAvroHttpRequestJSON(AvroHttpRequest request) {
DatumWriter<AvroHttpRequest> writer = new SpecificDatumWriter<>(AvroHttpRequest.class);
byte[] data = new byte[0];
ByteArrayOutputStream stream = new ByteArrayOutputStream();
@@ -30,7 +30,7 @@ public class AvroSerealizer {
return data;
}
public byte[] serealizeAvroHttpRequestBinary(AvroHttpRequest request) {
public byte[] serializeAvroHttpRequestBinary(AvroHttpRequest request) {
DatumWriter<AvroHttpRequest> writer = new SpecificDatumWriter<>(AvroHttpRequest.class);
byte[] data = new byte[0];
ByteArrayOutputStream stream = new ByteArrayOutputStream();