private Optional getExistingEntry()

in src/main/java/com/google/cloud/solutions/autotokenize/datacatalog/DataCatalogWriter.java [219:239]

19 lines of code
3 McCabe index (conditional complexity)


      private Optional<Entry> getExistingEntry() {
        try {
          if (sourceType.equals(SourceType.BIGQUERY_TABLE)) {
            return Optional.ofNullable(
                catalogClient.lookupEntry(
                    LookupEntryRequest.newBuilder()
                        .setLinkedResource(makeBigQueryTableLinkedResource())
                        .build()));
          }

          return Optional.ofNullable(
              catalogClient.getEntry(
                  EntryName.parse(
                      String.format("%s/entries/%s", entryGroupId(), makeNonBigQueryEntryId()))));

        } catch (Exception ex) {
          logger.atInfo().withCause(ex).log(
              "error retrieving entry: (%s) %s", sourceType, inputPattern);
          return Optional.empty();
        }
      }