请问一下，我想获取原始表结构，怎么获取呢？

具体描述清楚一些，不太理解你的含义，是什么数据库的表结构？

在 Flink 中，获取原始表结构可以通过 TableSchema 类来实现。具体来说，你可以使用以下代码获取一个表的原始结构：

Table table = ...; // 获取原始表 TableSchema schema = table.getSchema(); // 获取原始表结构

需要注意的是，如果你使用的是 Flink SQL，那么原始表结构就是你在 SQL 中定义的表结构。如果你使用的是 Flink DataSet 或 DataStream，那么原始表结构就是你在代码中定义的表结构。

如果你想要获取一个 DataStream 或 DataSet 的原始结构，可以使用 getInputDataSet() 或 getInputDataStream() 方法来获取输入数据集，然后再调用 getParallelInput() 方法获取原始表。具体代码示例如下：

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); DataSet<Tuple2<String, Integer>> input = env.fromElements( Tuple2.of("a",1), Tuple2.of("b",2), Tuple2.of("c",3));

// 获取输入数据集的原始表结构 TableSchema schema = input.getInputDataSet().getParallelInput().getSchema();

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); DataStream<Tuple2<String, Integer>> input = env.fromElements( Tuple2.of("a",1), Tuple2.of("b",2), Tuple2.of("c",3));

// 获取输入数据流的原始表结构 TableSchema schema = input.getInputDataStream().getParallelInput().getSchema();

除了获取输入数据集的原始表结构外，你还可以通过 TableEnvironment 的 getSchema() 方法来获取一个已注册表的原始结构。具体代码示例如下：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

DataStream<Tuple2<String, Integer>> input = env.fromElements( Tuple2.of("a",1), Tuple2.of("b",2), Tuple2.of("c",3));

// 注册一个表 tableEnv.createTemporaryView("my_table", input);

// 获取已注册表的原始表结构 TableSchema schema = tableEnv.getSchema("my_table");

以上是基于 Flink1.12 版本的示例代码，不同版本可能会有细微的差异，请根据你使用的 Flink 版本进行相应的调整。