Skip to content

Commit bf79cfb

Browse files
committed
renamed flink-sql dir to table api
1 parent 2b7ef4b commit bf79cfb

30 files changed

+1054
-21
lines changed

Makefile

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -37,15 +37,15 @@ help:
3737
@echo "${BLUE}${INFO} 🏗️ build${RESET} - Build the entire project with Gradle"
3838
@echo "${BLUE}${INFO} 🏗️ build-data-generator${RESET} - Build the Flink Data Generator"
3939
@echo "${BLUE}${INFO} 🚀 run-streaming${RESET} - Run the Flink Streaming application"
40-
@echo "${BLUE}${INFO} 🚀 run-sql${RESET} - Run the Flink SQL application"
40+
@echo "${BLUE}${INFO} 🚀 run-sql${RESET} - Run the Flink Table API application"
4141
@echo "${BLUE}${INFO} 🧪 ci-checks${RESET} - Run CI checks locally"
4242
@echo ""
4343
@echo "${YELLOW}${STAR} Data Generator:${RESET}"
4444
@echo "${BLUE}${INFO} 🚀 run-data-generator-local${RESET} - Run the Flink Data Generator in local environment"
4545
@echo "${BLUE}${INFO} ☁️ run-data-generator-cloud${RESET} - Run the Flink Data Generator in cloud environment"
4646
@echo "${BLUE}${INFO} 🚀 run-data-generator-with-props${RESET} - Run with custom properties (PROPS=path/to/properties)"
4747
@echo ""
48-
@echo "${YELLOW}${STAR} Flink SQL with Table API:${RESET}"
48+
@echo "${YELLOW}${STAR} Flink Table API:${RESET}"
4949
@echo "${BLUE}${INFO} 🚀 run-sql-status-local${RESET} - Run Flight Status Dashboard locally"
5050
@echo "${BLUE}${INFO} 🚀 run-sql-routes-local${RESET} - Run Flight Route Analytics locally"
5151
@echo "${BLUE}${INFO} 🚀 run-sql-delays-local${RESET} - Run Airline Delay Analytics locally"
@@ -336,59 +336,59 @@ run-streaming:
336336
@echo "${BLUE}${ROCKET} Running Flink Streaming application...${RESET}"
337337
./gradlew :flink-streaming:run
338338

339-
# Run Flink SQL application
339+
# Run Flink Table API application
340340
.PHONY: run-sql
341341
run-sql:
342-
@echo "${BLUE}${ROCKET} Running Flink SQL application...${RESET}"
343-
./gradlew :flink-sql:run
342+
@echo "${BLUE}${ROCKET} Running Flink Table API application...${RESET}"
343+
./gradlew :flink-table-api:run
344344

345-
# Flink SQL Module with Table API
345+
# Flink Table API Module
346346
.PHONY: run-sql-status-local
347347
run-sql-status-local:
348348
@echo "${BLUE}${ROCKET} Running Flight Status Dashboard with Table API (local)...${RESET}"
349-
./gradlew :flink-sql:run --args="status local"
349+
./gradlew :flink-table-api:run --args="status local"
350350
@echo "${GREEN}${CHECK} Flight Status Dashboard completed!${RESET}"
351351

352352
.PHONY: run-sql-routes-local
353353
run-sql-routes-local:
354354
@echo "${BLUE}${ROCKET} Running Flight Route Analytics with Table API (local)...${RESET}"
355-
./gradlew :flink-sql:run --args="routes local"
355+
./gradlew :flink-table-api:run --args="routes local"
356356
@echo "${GREEN}${CHECK} Flight Route Analytics completed!${RESET}"
357357

358358
.PHONY: run-sql-delays-local
359359
run-sql-delays-local:
360360
@echo "${BLUE}${ROCKET} Running Airline Delay Analytics with Table API (local)...${RESET}"
361-
./gradlew :flink-sql:run --args="delays local"
361+
./gradlew :flink-table-api:run --args="delays local"
362362
@echo "${GREEN}${CHECK} Airline Delay Analytics completed!${RESET}"
363363

364364
.PHONY: run-sql-all-local
365365
run-sql-all-local:
366366
@echo "${BLUE}${ROCKET} Running all SQL use cases with Table API (local)...${RESET}"
367-
./gradlew :flink-sql:run --args="all local"
367+
./gradlew :flink-table-api:run --args="all local"
368368
@echo "${GREEN}${CHECK} All SQL use cases completed!${RESET}"
369369

370370
.PHONY: run-sql-status-cloud
371371
run-sql-status-cloud:
372372
@echo "${BLUE}${CLOUD} Running Flight Status Dashboard with Table API (cloud)...${RESET}"
373-
./gradlew :flink-sql:run --args="status cloud"
373+
./gradlew :flink-table-api:run --args="status cloud"
374374
@echo "${GREEN}${CHECK} Flight Status Dashboard completed!${RESET}"
375375

376376
.PHONY: run-sql-routes-cloud
377377
run-sql-routes-cloud:
378378
@echo "${BLUE}${CLOUD} Running Flight Route Analytics with Table API (cloud)...${RESET}"
379-
./gradlew :flink-sql:run --args="routes cloud"
379+
./gradlew :flink-table-api:run --args="routes cloud"
380380
@echo "${GREEN}${CHECK} Flight Route Analytics completed!${RESET}"
381381

382382
.PHONY: run-sql-delays-cloud
383383
run-sql-delays-cloud:
384384
@echo "${BLUE}${CLOUD} Running Airline Delay Analytics with Table API (cloud)...${RESET}"
385-
./gradlew :flink-sql:run --args="delays cloud"
385+
./gradlew :flink-table-api:run --args="delays cloud"
386386
@echo "${GREEN}${CHECK} Airline Delay Analytics completed!${RESET}"
387387

388388
.PHONY: run-sql-all-cloud
389389
run-sql-all-cloud:
390390
@echo "${BLUE}${CLOUD} Running all SQL use cases with Table API (cloud)...${RESET}"
391-
./gradlew :flink-sql:run --args="all cloud"
391+
./gradlew :flink-table-api:run --args="all cloud"
392392
@echo "${GREEN}${CHECK} All SQL use cases completed!${RESET}"
393393

394394
# Docker Compose targets

build.gradle.kts

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ subprojects {
7070
}
7171

7272
// Configuration for the main application modules
73-
configure(subprojects.filter { it.name == "flink-streaming" || it.name == "flink-sql" }) {
73+
configure(subprojects.filter { it.name == "flink-streaming" || it.name == "flink-table-api" }) {
7474
apply(plugin = "application")
7575
apply(plugin = "com.gradleup.shadow")
7676

@@ -95,8 +95,8 @@ configure(subprojects.filter { it.name == "flink-streaming" || it.name == "flink
9595
}
9696
}
9797

98-
// Configuration specific to the flink-sql module
99-
project(":flink-sql") {
98+
// Configuration specific to the flink-table-api module
99+
project(":flink-table-api") {
100100
dependencies {
101101
// Flink Table API & SQL
102102
implementation("org.apache.flink:flink-table-api-java-bridge:$flinkVersion")
@@ -106,19 +106,19 @@ project(":flink-sql") {
106106

107107
tasks.jar {
108108
manifest {
109-
attributes["Main-Class"] = "io.confluent.developer.sql.FlinkSqlMain"
109+
attributes["Main-Class"] = "io.confluent.developer.tableapi.FlinkTableApiMain"
110110
}
111111
}
112112

113113
tasks.named<ShadowJar>("shadowJar") {
114-
archiveBaseName.set("flink-sql")
114+
archiveBaseName.set("flink-table-api")
115115
archiveClassifier.set("")
116116
archiveVersion.set("")
117117
mergeServiceFiles()
118118
}
119119

120120
application {
121-
mainClass.set("io.confluent.developer.sql.FlinkSqlMain")
121+
mainClass.set("io.confluent.developer.tableapi.FlinkTableApiMain")
122122
}
123123
}
124124

File renamed without changes.

flink-sql/src/main/java/io/confluent/developer/sql/FlinkSqlMain.java renamed to flink-table-api/src/main/java/io/confluent/developer/sql/FlinkSqlMain.java

File renamed without changes.

flink-sql/src/main/java/io/confluent/developer/sql/config/ConfigLoader.java renamed to flink-table-api/src/main/java/io/confluent/developer/sql/config/ConfigLoader.java

File renamed without changes.

flink-sql/src/main/java/io/confluent/developer/sql/table/AvroTableUtils.java renamed to flink-table-api/src/main/java/io/confluent/developer/sql/table/AvroTableUtils.java

File renamed without changes.

flink-sql/src/main/java/io/confluent/developer/sql/table/FlightTableApiFactory.java renamed to flink-table-api/src/main/java/io/confluent/developer/sql/table/FlightTableApiFactory.java

File renamed without changes.

flink-sql/src/main/java/io/confluent/developer/sql/table/FlightTableFactory.java renamed to flink-table-api/src/main/java/io/confluent/developer/sql/table/FlightTableFactory.java

File renamed without changes.

0 commit comments

Comments
 (0)