C D E F G H L M P S T V W

C

Checkpoint - com.zto.fire.flink.anno中的注释类型

基于注解flink checkpoint配置，优先级低于配置文件，高于@Config注解 注：@Checkpoint中相关时间单位均为秒

CheckpointParams - com.zto.fire.flink.bean中的类

checkpoint热修改参数 {"interval":10000, "timeout":20000, "minPauseBetween": 10000}

CheckpointParams() - 类 的构造器com.zto.fire.flink.bean.CheckpointParams

com.zto.fire.flink.anno - 程序包 com.zto.fire.flink.anno

com.zto.fire.flink.bean - 程序包 com.zto.fire.flink.bean

com.zto.fire.flink.enu - 程序包 com.zto.fire.flink.enu

com.zto.fire.flink.ext.watermark - 程序包 com.zto.fire.flink.ext.watermark

com.zto.fire.flink.task - 程序包 com.zto.fire.flink.task

D

DistributeBean - com.zto.fire.flink.bean中的类

用于解析restful中的参数

DistributeBean() - 类 的构造器com.zto.fire.flink.bean.DistributeBean

DistributeBean(DistributeModule, String) - 类 的构造器com.zto.fire.flink.bean.DistributeBean

DistributeModule - com.zto.fire.flink.enu中的枚举

模块类型，用于标识不同的模块

E

equals(Object) - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

F

FirePeriodicWatermarks<T> - com.zto.fire.flink.ext.watermark中的类

已过时。

FirePeriodicWatermarks() - 类 的构造器com.zto.fire.flink.ext.watermark.FirePeriodicWatermarks

已过时。

FirePeriodicWatermarks(long) - 类 的构造器com.zto.fire.flink.ext.watermark.FirePeriodicWatermarks

已过时。

用于自定义允许最大的乱序时间

FlinkConf - com.zto.fire.flink.anno中的注释类型

基于注解进行任务的配置，支持纯注解方式进行Flink相关参数配置

FlinkSchedulerManager - com.zto.fire.flink.task中的类

Flink 定时调度任务管理器

FlinkTableSchema - com.zto.fire.flink.bean中的类

flink表模式，支持序列化

FlinkTableSchema(TableSchema) - 类 的构造器com.zto.fire.flink.bean.FlinkTableSchema

G

getCurrentWatermark() - 类 中的方法com.zto.fire.flink.ext.watermark.FirePeriodicWatermarks

已过时。

计算并返回当前的水位线 如果未指定水位线的时间戳，则默认获取当前系统时间

getFieldCount() - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

Returns the number of fields.

getFieldDataType(int) - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

Returns the specified data type for the given field index.

getFieldDataType(String) - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

Returns the specified data type for the given field name.

getFieldDataTypes() - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

Returns all field data types as an array.

getFieldName(int) - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

Returns the specified name for the given field index.

getFieldNames() - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

Returns all field names as an array.

getFieldType(int) - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

This method will be removed in future versions as it uses the old type system.

getFieldType(String) - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

This method will be removed in future versions as it uses the old type system.

getFieldTypes() - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

This method will be removed in future versions as it uses the old type system.

getInstance() - 类 中的静态方法com.zto.fire.flink.task.FlinkSchedulerManager

获取单例实例

getInterval() - 类 中的方法com.zto.fire.flink.bean.CheckpointParams

getJson() - 类 中的方法com.zto.fire.flink.bean.DistributeBean

getMinPauseBetween() - 类 中的方法com.zto.fire.flink.bean.CheckpointParams

getModule() - 类 中的方法com.zto.fire.flink.bean.DistributeBean

getTimeout() - 类 中的方法com.zto.fire.flink.bean.CheckpointParams

H

hashCode() - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

L

label() - 类 中的方法com.zto.fire.flink.task.FlinkSchedulerManager

M

maxOutOfOrder - 类 中的变量com.zto.fire.flink.ext.watermark.FirePeriodicWatermarks

已过时。

maxTimestamp - 类 中的变量com.zto.fire.flink.ext.watermark.FirePeriodicWatermarks

已过时。

P

parse(String) - 枚举 中的静态方法com.zto.fire.flink.enu.DistributeModule

将字符串解析成指定的枚举类型

S

setInterval(Long) - 类 中的方法com.zto.fire.flink.bean.CheckpointParams

setJson(String) - 类 中的方法com.zto.fire.flink.bean.DistributeBean

setMinPauseBetween(Long) - 类 中的方法com.zto.fire.flink.bean.CheckpointParams

setModule(DistributeModule) - 类 中的方法com.zto.fire.flink.bean.DistributeBean

setTimeout(Long) - 类 中的方法com.zto.fire.flink.bean.CheckpointParams

Streaming - com.zto.fire.flink.anno中的注释类型

基于注解flink配置，优先级低于配置文件，高于@Config注解低于@Checkpoint注解

T

toString() - 类 中的方法com.zto.fire.flink.bean.FlinkTableSchema

V

valueOf(String) - 枚举 中的静态方法com.zto.fire.flink.enu.DistributeModule

返回带有指定名称的该类型的枚举常量。

values() - 枚举 中的静态方法com.zto.fire.flink.enu.DistributeModule

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

W

watermark - 类 中的变量com.zto.fire.flink.ext.watermark.FirePeriodicWatermarks

已过时。

C D E F G H L M P S T V W