org.apache.flink.streaming.connectors.nifi

Interface NiFiDataPacketBuilder<T>

Type Parameters:

T -

All Superinterfaces:

Function, Serializable

public interface NiFiDataPacketBuilder<T>
extends Function, Serializable

A function that can create a NiFiDataPacket from an incoming instance of the given type.

Method Summary

Modifier and Type	Method and Description
NiFiDataPacket	createNiFiDataPacket(T t, RuntimeContext ctx)

Method Detail

createNiFiDataPacket

NiFiDataPacket createNiFiDataPacket(T t,
                                    RuntimeContext ctx)