AddElementsFromKafkaHandler (uk.gov.gchq.gaffer:gaffer2 2.2.0 API)

java.lang.Object
- uk.gov.gchq.gaffer.flink.operation.handler.AddElementsFromKafkaHandler

All Implemented Interfaces:

OperationHandler<AddElementsFromKafka>
```
public class AddElementsFromKafkaHandler
extends Object
implements OperationHandler<AddElementsFromKafka>
```
A AddElementsFromKafkaHandler handles the AddElementsFromKafka operation.

This uses Flink to stream the Element objects from a Kafka queue into Gaffer.

Rebalancing can be skipped by setting the operation option: gaffer.flink.operation.handler.skip-rebalancing to true

Constructor Summary

Constructors
Constructor	Description
`AddElementsFromKafkaHandler()`
`AddElementsFromKafkaHandler(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, org.apache.flink.streaming.api.functions.sink.SinkFunction<Element> sink)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Object`	`doOperation(AddElementsFromKafka op, Context context, Store store)`	Execute the given `Operation`.

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - AddElementsFromKafkaHandler
```
public AddElementsFromKafkaHandler()
```
  - AddElementsFromKafkaHandler
```
public AddElementsFromKafkaHandler(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
                                   org.apache.flink.streaming.api.functions.sink.SinkFunction<Element> sink)
```
- Method Detail
  - doOperation
```
public Object doOperation(AddElementsFromKafka op,
                          Context context,
                          Store store)
                   throws OperationException
```
    Description copied from interface: OperationHandler
    
    Execute the given Operation.
    
    Specified by:
    
    doOperation in interface OperationHandler<AddElementsFromKafka>
    
    Parameters:
    
    op - the Operation to be executed
    
    context - the operation chain context, containing the user who executed the operation
    
    store - the Store the operation should be run on
    
    Returns:
    
    the output for the operation or null.
    
    Throws:
    
    OperationException - thrown if the operation fails