org.apache.flink.streaming.connectors.nifi

Interface NiFiDataPacket

All Known Implementing Classes:

StandardNiFiDataPacket

public interface NiFiDataPacket

The NiFiDataPacket provides a packaging around a NiFi FlowFile. It wraps both a FlowFile's content and its attributes so that they can be processed by Flink.

Method Summary

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

Method Detail

getContent

byte[] getContent()

Returns:

the contents of a NiFi FlowFile

getAttributes

Map<String,String> getAttributes()

Returns:

a Map of attributes that are associated with the NiFi FlowFile