Streaming (Fire : Engines : Flink 2.4.4 API)

```
@Inherited
 @Target(value=TYPE)
 @Retention(value=RUNTIME)
public @interface Streaming
```
基于注解flink配置，优先级低于配置文件，高于@Config注解低于@Checkpoint注解

从以下版本开始:

2.2.2

作者:

ChengLong 2022-04-26 11:16:00

可选元素概要

可选元素
限定符和类型	可选元素和说明
`boolean`	`autoStart` 是否自动提交job：call env.execute()
`org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup`	`cleanup` 当任务停止时checkpoint的保持策略
`int`	`concurrent` checkpoint的并发度
`boolean`	`disableOperatorChaining` 是否禁用OperatorChaining
`org.apache.flink.api.common.RuntimeExecutionMode`	`executionMode` Flink任务运行模式
`int`	`failureNumber` 运行checkpoint失败的总次数
`int`	`interval` checkpoint周期（s），同value
`org.apache.flink.streaming.api.CheckpointingMode`	`mode` checkpoint的模式
`int`	`parallelism` 任务的并行度
`int`	`pauseBetween` 两次checkpoint的最短时间间隔
`int`	`stateTTL` 状态的TTL时间（day）
`int`	`timeout` checkpoint超时时间（s）
`boolean`	`unaligned` 是否开启非对齐的checkpoint
`boolean`	`useStatementSet` 是否使用statementSet
`int`	`value` checkpoint周期（s）
`int`	`watermarkInterval` watermark生成周期

- 元素详细资料
  - value
```
public abstract int value
```
    checkpoint周期（s）
    
    默认值:
    
    -1
- - interval
```
public abstract int interval
```
    checkpoint周期（s），同value
    
    默认值:
    
    -1
- - timeout
```
public abstract int timeout
```
    checkpoint超时时间（s）
    
    默认值:
    
    -1
- - unaligned
```
public abstract boolean unaligned
```
    是否开启非对齐的checkpoint
    
    默认值:
    
    true
- - concurrent
```
public abstract int concurrent
```
    checkpoint的并发度
    
    默认值:
    
    -1
- - pauseBetween
```
public abstract int pauseBetween
```
    两次checkpoint的最短时间间隔
    
    默认值:
    
    -1
- - failureNumber
```
public abstract int failureNumber
```
    运行checkpoint失败的总次数
    
    默认值:
    
    -1
- - mode
```
public abstract org.apache.flink.streaming.api.CheckpointingMode mode
```
    checkpoint的模式
    
    默认值:
    
    org.apache.flink.streaming.api.CheckpointingMode.EXACTLY_ONCE
- - cleanup
```
public abstract org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup cleanup
```
    当任务停止时checkpoint的保持策略
    
    默认值:
    
    org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION
- - autoStart
```
public abstract boolean autoStart
```
    是否自动提交job：call env.execute()
    
    默认值:
    
    true
- - parallelism
```
public abstract int parallelism
```
    任务的并行度
    
    默认值:
    
    -1
- - disableOperatorChaining
```
public abstract boolean disableOperatorChaining
```
    是否禁用OperatorChaining
    
    默认值:
    
    false
- - stateTTL
```
public abstract int stateTTL
```
    状态的TTL时间（day）
    
    默认值:
    
    31
- - useStatementSet
```
public abstract boolean useStatementSet
```
    是否使用statementSet
    
    默认值:
    
    true
- - executionMode
```
public abstract org.apache.flink.api.common.RuntimeExecutionMode executionMode
```
    Flink任务运行模式
    
    默认值:
    
    org.apache.flink.api.common.RuntimeExecutionMode.STREAMING
- - watermarkInterval
```
public abstract int watermarkInterval
```
    watermark生成周期
    
    默认值:
    
    -1

注释类型 Streaming

可选元素概要

元素详细资料

value

interval

timeout

unaligned

concurrent

pauseBetween

failureNumber

mode

cleanup

autoStart

parallelism

disableOperatorChaining

stateTTL

useStatementSet

executionMode

watermarkInterval