| File | # lines | # units |
|---|
|
AbstractJdbcCatalog.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog |
484 |
53 |
|
284 |
27 |
|
304 |
26 |
|
233 |
26 |
|
198 |
22 |
TransactionId.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/domain |
222 |
22 |
JdbcSourceBuilder.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source |
207 |
20 |
JdbcSourceSplitReader.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader |
296 |
20 |
|
149 |
19 |
|
157 |
19 |
JdbcReadOptions.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options |
115 |
18 |
XidSerializer.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid |
96 |
17 |
XaTransaction.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa |
253 |
17 |
|
105 |
15 |
JdbcDmlOptions.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options |
109 |
15 |
|
90 |
14 |
|
183 |
14 |
|
190 |
14 |
|
93 |
13 |
|
264 |
13 |
PostgresCatalog.javain flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog |
181 |
13 |
|
73 |
12 |
JdbcSourceEnumerator.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator |
162 |
12 |
XaError.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions |
146 |
12 |
OceanBaseDialect.javain flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect |
78 |
11 |
OceanBaseCatalog.javain flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog |
139 |
11 |
JdbcSource.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source |
156 |
11 |
|
305 |
11 |
|
88 |
11 |
MySqlCatalog.javain flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/catalog |
147 |
11 |
JdbcSourceSplit.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split |
90 |
10 |
AbstractDialect.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect |
160 |
10 |
|
102 |
10 |
|
162 |
10 |
PostgresTablePath.javain flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog |
69 |
10 |
MySqlDialect.javain flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/dialect |
91 |
10 |
OracleDialect.javain flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect |
113 |
9 |
Db2Dialect.javain flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect |
114 |
9 |
TrinoDialect.javain flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database/dialect |
73 |
9 |
CrateDBCatalog.javain flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog |
120 |
9 |
DerbyDialect.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/dialect |
68 |
9 |
JdbcSinkBuilder.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink |
80 |
9 |
|
102 |
9 |
|
211 |
9 |
XaCommand.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa |
96 |
9 |
XaTransactionResult.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa |
55 |
9 |
SqlServerDialect.javain flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database/dialect |
118 |
9 |
PostgresDialect.javain flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect |
91 |
9 |
JdbcWriterState.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer |
64 |
8 |
JdbcSourceSplitState.javain flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split |
61 |
8 |