jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-25 02:09:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

Revert "update all connectors for new CDK version and more stringent javac checks"

Browse Source 
This reverts commit 18ad87bbd1.
This commit is contained in:
Stephane Geneix
2023-11-02 15:42:28 -07:00
parent 18ad87bbd1
commit 9c6ed93a9d
71 changed files with 21 additions and 507 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
airbyte-integrations/connectors/source-mongodb-v2/src/main/java/io/airbyte/integrations/source/mongodb/MongoUtil.java
View File

@@ -163,7 +163,6 @@ public class MongoUtil {
try (final MongoCursor<Document> cursor = output.allowDiskUse(true).cursor()) {
if (cursor.hasNext()) {
final Document stats = cursor.next();
@SuppressWarnings("unchecked")
final Map<String, Object> storageStats = (Map<String, Object>) stats.get(MongoConstants.STORAGE_STATS_KEY);
if (storageStats != null && !storageStats.isEmpty()) {
return Optional.of(new CollectionStatistics((Number) storageStats.get(MongoConstants.COLLECTION_STATISTICS_COUNT_KEY),
@@ -255,7 +254,6 @@ public class MongoUtil {
try (final MongoCursor<Document> cursor = output.allowDiskUse(true).cursor()) {
while (cursor.hasNext()) {
@SuppressWarnings("unchecked")
final Map<String, String> fields = ((List<Map<String, String>>) cursor.next().get("fields")).get(0);
discoveredFields.addAll(fields.entrySet().stream()
.map(e -> new MongoField(e.getKey(), convertToSchemaType(e.getValue())))