Skip to content

Commit

Permalink
adding StringSerDe helper class for NiFi utils package.
Browse files Browse the repository at this point in the history
  • Loading branch information
xmlking committed Jul 16, 2016
1 parent 1be9b82 commit 0755a36
Showing 1 changed file with 28 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,28 @@
package com.crossbusiness.nifi.processors;

import org.apache.nifi.distributed.cache.client.Deserializer;
import org.apache.nifi.distributed.cache.client.Serializer;
import org.apache.nifi.distributed.cache.client.exception.DeserializationException;
import org.apache.nifi.distributed.cache.client.exception.SerializationException;

import java.io.IOException;
import java.io.OutputStream;
import java.nio.charset.StandardCharsets;

public class StringSerDe implements Serializer<String>, Deserializer<String> {

@Override
public String deserialize(final byte[] value) throws DeserializationException, IOException {
if (value == null) {
return null;
}

return new String(value, StandardCharsets.UTF_8);
}

@Override
public void serialize(final String value, final OutputStream out) throws SerializationException, IOException {
out.write(value.getBytes(StandardCharsets.UTF_8));
}

}

0 comments on commit 0755a36

Please sign in to comment.