org.apache.flink.streaming.connectors.nifi

Class StandardNiFiDataPacket

java.lang.Object

org.apache.flink.streaming.connectors.nifi.StandardNiFiDataPacket

All Implemented Interfaces:

Serializable, NiFiDataPacket

public class StandardNiFiDataPacket
extends Object
implements NiFiDataPacket, Serializable

An implementation of NiFiDataPacket.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StandardNiFiDataPacket(byte[] content, Map<String,String> attributes)

Method Summary

Modifier and Type	Method and Description
Map<String,String>	getAttributes()
byte[]	getContent()

Methods inherited from class java.lang.Object

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

Constructor Detail

StandardNiFiDataPacket

public StandardNiFiDataPacket(byte[] content,
                              Map<String,String> attributes)

Method Detail

getContent

public byte[] getContent()

Specified by:

getContent in interface NiFiDataPacket

Returns:

the contents of a NiFi FlowFile

getAttributes

public Map<String,String> getAttributes()

Specified by:

getAttributes in interface NiFiDataPacket

Returns:

a Map of attributes that are associated with the NiFi FlowFile