Skip to content

Commit

Permalink
fix build
Browse files Browse the repository at this point in the history
  • Loading branch information
edgao committed Feb 1, 2024
1 parent 218715c commit f729fc7
Showing 1 changed file with 7 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@
import io.airbyte.integrations.base.destination.typing_deduping.StreamId;
import java.math.BigInteger;
import java.util.Comparator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
Expand Down Expand Up @@ -52,6 +53,12 @@ public Optional<TableDefinition> findExistingTable(final StreamId id) {
return Optional.ofNullable(table).map(Table::getDefinition);
}

@Override
public LinkedHashMap<String, TableDefinition> findExistingFinalTables(final List<StreamId> streamIds) throws Exception {
// Currently unused
return null;
}

@Override
public boolean isFinalTableEmpty(final StreamId id) {
return BigInteger.ZERO.equals(bq.getTable(TableId.of(id.finalNamespace(), id.finalName())).getNumRows());
Expand Down

0 comments on commit f729fc7

Please sign in to comment.