Class FlinkConstants
- 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.
-
-
-
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
-
-