org.apache.nifi.spark

Class StandardNiFiDataPacket

java.lang.Object

org.apache.nifi.spark.StandardNiFiDataPacket

All Implemented Interfaces:

Serializable, NiFiDataPacket

public class StandardNiFiDataPacket
extends Object
implements NiFiDataPacket, Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
private Map<String,String>	attributes
private byte[]	content
private static long	serialVersionUID

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

content

private final byte[] content

attributes

private final Map<String,String> attributes

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