File | # lines | # units | # long lines |
---|
|
|
221 |
10 |
21 |
|
177 |
11 |
12 |
OdpsCatalog.javain flink-connector-odps/src/main/java/org/apache/flink/odps/catalog |
650 |
59 |
10 |
|
128 |
4 |
10 |
|
157 |
9 |
8 |
|
74 |
6 |
7 |
|
790 |
113 |
7 |
|
76 |
6 |
7 |
|
233 |
5 |
7 |
|
80 |
3 |
6 |
|
361 |
16 |
6 |
|
86 |
5 |
6 |
|
162 |
16 |
5 |
|
73 |
3 |
5 |
|
142 |
4 |
5 |
|
141 |
4 |
4 |
|
128 |
8 |
4 |
|
227 |
7 |
4 |
OdpsScan.scalain spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps |
241 |
9 |
4 |
|
219 |
15 |
4 |
|
175 |
5 |
4 |
|
290 |
16 |
3 |
ColDataVector.javain cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/vectorized |
196 |
26 |
3 |
|
334 |
18 |
3 |
|
89 |
6 |
3 |
OdpsOptions.javain flink-connector-odps/src/main/java/org/apache/flink/odps/table |
117 |
- |
3 |
|
52 |
8 |
3 |
|
230 |
27 |
3 |
|
117 |
9 |
3 |
|
338 |
49 |
2 |
HiveShim.scalain spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/client |
1450 |
82 |
2 |
|
769 |
63 |
2 |
OdpsWriteBuilder.scalain spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps |
205 |
5 |
2 |
|
433 |
41 |
2 |
|
91 |
11 |
2 |
SinkPolicy.javain flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream |
10 |
- |
2 |
|
33 |
- |
2 |
|
272 |
- |
2 |
|
128 |
8 |
2 |
|
200 |
8 |
2 |
|
288 |
12 |
2 |
|
24 |
- |
2 |
DefaultSource.scalain spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/datasource |
69 |
5 |
2 |
|
262 |
12 |
2 |
TableUtils.javain cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/util |
62 |
3 |
1 |
|
24 |
2 |
1 |
|
70 |
7 |
1 |
|
77 |
2 |
1 |
ArrowUtils.javain presto-connector/src/main/java/com/facebook/presto/maxcompute/utils |
260 |
11 |
1 |
|
119 |
13 |
1 |