Class FlinkConstants


  • public final class FlinkConstants
    extends Object
    • 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