Package uk.gov.gchq.gaffer.flink.operation.handler
Operation handlers (and associated classes) for operations using the Apache Flink
stream processing framework.
-
Class Summary Class Description AddElementsFromFileHandler AAddElementsFromFileHandler
handles theAddElementsFromFile
operation.AddElementsFromKafkaHandler AAddElementsFromKafkaHandler
handles theAddElementsFromKafka
operation.AddElementsFromSocketHandler AAddElementsFromSocketHandler
handles theAddElementsFromSocket
operation.GafferAdder Helper class to addElement
s to a Gaffer store.GafferMapFunction<T> Implementation ofFlatMapFunction
to allow CSV strings representingElement
s to be mapped to Element objects.GafferOutput Implementation ofRichOutputFormat
for Gaffer to allowElement
s to be consumed from external sources.GafferSink