Table-Computing 框架快速入门教程

1. 项目目录结构及介绍

Table-Computing 的目录结构如下：

.
├── src           # 源代码目录
│   ├── src       # Java 代码源文件
│   │   └── ...   # 包含核心库、示例程序等代码
└── README.md     # 项目简介文件
└── pom.xml       # Maven 构建文件
└── ...            # 其他支持文件（如 .gitignore 和/LICENSE）

• src: 存放项目的所有源代码，包括核心组件和示例程序。
• README.md: 提供项目的基本信息、特性以及如何开始使用的简要指南。
• pom.xml: Maven 项目对象模型文件，用于构建和依赖管理。

2. 项目启动文件介绍

由于 Table-Computing 是一个计算框架，而非独立的服务应用，其启动方式取决于具体的应用场景。通常，你需要在自己的应用程序中集成 Table-Computing 库，并创建相应的流处理或批处理作业。这涉及到以下步骤：

1. 引入依赖： 在你的 pom.xml 文件中添加 Table-Computing 的依赖，例如：

   <dependency>
       <groupId>com.alibaba</groupId>
       <artifactId>table-computing</artifactId>
       <version>1.0.0</version>
   </dependency>
   

2. 编写计算逻辑： 创建 MysqlDimensionTable 和 KafkaStreamTable 等数据源，然后使用 StreamProcessing API 来定义滑动窗口、重分区等操作。

3. 执行计算任务： 调用相关方法启动计算任务，例如：

   kafkaStreamTable.start();
   // 启动你的 StreamProcessing 作业
   StreamProcessing sp = new StreamProcessing();
   ...
   slideWindow.setWatermark(Duration.ofSeconds(2));
   // 开始执行
   sp.execute();
   

请根据实际需求调整这些例子，并确保正确地设置配置参数。

3. 项目的配置文件介绍

Table-Computing 配置主要通过编程方式进行，这意味着你可以在代码中指定连接数据库的 URL、认证信息、超时设置、并行度等参数。例如，设置 MySQL 数据库连接：

MysqlDimensionTable mysqlDimensionTable = new MysqlDimensionTable(
    "jdbc:mysql://localhost:3306/e-commerce",
    "commodity",
    "userName",
    "password",
    Duration.ofHours(1),
    new ColumnTypeBuilder()
        .column("id", Type.INT)
        .column("name", Type.VARCHAR)
        .column("price", Type.INT)
        .build(),
    "id"
);

对于更复杂的配置项，可能需要自定义实现特定的配置类。一般来说，大部分配置可以通过 StreamProcessing 的构造函数或者相关的设置方法进行。

请注意，Table-Computing 没有提供标准的外部配置文件格式（如 .properties 或 YAML），而是鼓励将配置集成到应用程序代码中，以保持简洁和灵活性。如果你需要更加动态或中心化的配置管理，可以考虑结合 Spring Boot 这样的框架来实现。