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

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

public final class FlinkConstants
extends Object

Field Summary

Fields
Modifier and Type	Field	Description
`static String`	`MAX_QUEUE_SIZE`	Operation option key for setting the maximum queue size for adding to a Gaffer store.
`static String`	`SKIP_REBALANCING`	Operation option key for skipping rebalancing between flatMap and sink.

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

- Field Detail
  - SKIP_REBALANCING
```
public static final String SKIP_REBALANCING
```
    Operation option key for skipping rebalancing between flatMap and sink. This is false by default.
    
    See Also:
    
    Constant Field Values
  - MAX_QUEUE_SIZE
```
public static final String MAX_QUEUE_SIZE
```
    Operation option key for setting the maximum queue size for adding to a Gaffer store. If the queue size is exceeded Flink will be blocked from adding to the queue until the Gaffer Store has consumed the elements.
    
    See Also:
    
    Constant Field Values