Package org.apache.nifi.processors.standard.util

Class FlowFileAttributesSerializer

java.lang.Object

org.apache.nifi.processors.standard.util.FlowFileAttributesSerializer

All Implemented Interfaces:

Deserializer<Map<String,String>>, Serializer<Map<String,String>>

public class FlowFileAttributesSerializer
extends Object
implements Deserializer<Map<String,String>>, Serializer<Map<String,String>>

Offers serialization and deserialization for flow file attribute maps.

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	ATTRIBUTE_SEPARATOR

Constructor Summary

Constructors

Constructor	Description
FlowFileAttributesSerializer()

Method Summary

Modifier and Type	Method	Description
Map<String,String>	deserialize(byte[] input)
void	serialize(Map<String,String> value, OutputStream output)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ATTRIBUTE_SEPARATOR

private static final String ATTRIBUTE_SEPARATOR

See Also:

• Constant Field Values

Constructor Details

FlowFileAttributesSerializer

public FlowFileAttributesSerializer()

Method Details

deserialize

public Map<String,String> deserialize(byte[] input)
                               throws DeserializationException

Specified by:

deserialize in interface Deserializer<Map<String,String>>

Throws:

DeserializationException

serialize

public void serialize(Map<String,String> value,
 OutputStream output)
               throws SerializationException,
IOException

Specified by:

serialize in interface Serializer<Map<String,String>>

Throws:

SerializationException

IOException