kettle class diagram

2016-05-14 10:26:37   1  举报





Kettle（水壶）是一个用于数据集成的工具，它提供了图形化的界面和丰富的组件库，使得用户可以通过拖拽的方式完成复杂的数据转换和处理任务。在Kettle中，各个组件之间通过箭头连接，表示数据的流动方向。其中，输入步骤用于读取源数据，如数据库、文件等；转换步骤用于对数据进行处理和转换，如过滤、排序、合并等；输出步骤用于将处理后的数据写入目标系统，如数据库、文件等。此外，Kettle还提供了一些辅助功能，如作业调度、日志记录等。总之，Kettle是一个功能强大且易于使用的数据集成工具，广泛应用于各种数据处理场景。

作者其他创作

大纲/内容

SchedularServer

- Log : Logger- port : int- future : ChannelFuture

+ start() : ChannelFuture+ Stop()

DXTJobHandler

+ getJobprocessor() : DXTJobAction

AllSplittedSteps

SchedularServerManager

EventAndMsgHandler

- Log : Logger- serverManager : SchedularServerManager

JobProcess

- isClusterMode : boolean- jobID : String- timestamp : long- jobidString : String- splittedJobs : ArrayListSplittedJob- actiion : DXTJobAction

DXTJobProcResult

- isSuccess : boolean- data : byte[]

+ isSuccess() : boolean+ setSuccess(boolean isSuccess)+ getData() : byte[]+ setData(byte[] data)

JobInfo

- JobID : String- channel : Channel- jobUUID : String- timestamp : long

+ getChannel() : Channel+ setChannel(Channel channel)+ getJobID : String+ setJobID(String jobid)+ getJobUUID() : String+ setJobUUID(String jobuuid)+ getTimestamp() : long+ setTimestamp(long timestamp):+ send(Packet packet)

DXTJobProcess

- Log : Logger

Client

+ HOSTNAME : String+ PORT : int

+ init(DxtConfig config)

Runnable

+ run()

DXTJobAction