org.apache.nifi.controller.swap

Class SchemaSwapSerializer

java.lang.Object

org.apache.nifi.controller.swap.SchemaSwapSerializer

All Implemented Interfaces:

SwapSerializer

public class SchemaSwapSerializer
extends java.lang.Object
implements SwapSerializer

Constructor Summary

Constructors

Constructor and Description
SchemaSwapSerializer()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getSerializationName()
void	serializeFlowFiles(java.util.List<FlowFileRecord> toSwap, FlowFileQueue queue, java.lang.String swapLocation, java.io.OutputStream out)

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaSwapSerializer

public SchemaSwapSerializer()

Method Detail

serializeFlowFiles

public void serializeFlowFiles(java.util.List<FlowFileRecord> toSwap,
                               FlowFileQueue queue,
                               java.lang.String swapLocation,
                               java.io.OutputStream out)
                        throws java.io.IOException

Specified by:

serializeFlowFiles in interface SwapSerializer

Throws:

java.io.IOException

getSerializationName

public java.lang.String getSerializationName()

Specified by:

getSerializationName in interface SwapSerializer