}

    public ModelParserException(Throwable cause) {
        this(null, cause);
    }

    public int getLineNumber() {
        return lineNumber;
    }

    public int getColumnNumber() {
        return columnNumber;
    }

     */
    public MsPublisherExtractor() {
        super();
    }

    /**
     * Extracts text from the Publisher input stream.
     * @param in The input stream.
     * @param params The parameters.
     * @return The extracted data.
     */
    @Override
    public ExtractData getText(final InputStream in, final Map<String, String> params) {
        if (in == null) {

    /**
     * Analyzes the given text and returns a list of tokens.
     *
     * @param text the text to analyze
     * @param field the field associated with the text
     * @param lang the language of the text
     * @return a list of analyzed tokens
     */
    List<AnalyzeToken> analyze(String text, String field, String lang);

    /**
     * Analyzes the given text and returns a list of tokens along with their readings.
     *

        this.rawData = rawData;
        if (rawData != null) {
            data = null;
        }
    }

    /**
     * Get the raw data.
     * @return rawData
     */
    public Object getRawData() {
        return rawData;
    }

    /**
     * Set the serializer.
     * @param serializer the serializer function to convert raw data to byte array
     */

            }
        }

        return masked;
    }

    private String maskUsername(String username) {
        if (!maskSensitiveData || username == null) {
            return username;
        }

        // Show first and last character only
        if (username.length() <= 2) {
            return "***";
        }

        final JobProcess jobProcess = runningProcessMap.remove(sessionId);
        return destroyProcess(sessionId, jobProcess);
    }

    /**
     * Checks if any processes are currently running.
     *
     * @return true if at least one process is running, false otherwise
     */
    public boolean isProcessRunning() {
        return !runningProcessMap.isEmpty();
    }

    /**

        params[i] = cause;
      } else {
        return null;
      }
    }
    try {
      return constructor.newInstance(params);
    } catch (IllegalArgumentException
        | InstantiationException
        | IllegalAccessException
        | InvocationTargetException e) {
      return null;
    }
  }

  @VisibleForTesting

    public String getUserId() {
        return authResult.account().username();
    }

    @Override
    public String toString() {
        return "{" + authResult.account().username() + "}";
    }

    /**
     * Gets the Azure AD user associated with this credential.
     * @return The Azure AD user instance.
     */
    public AzureAdUser getUser() {
        return new AzureAdUser(authResult);
    }

    /**

     * Gets the domain SID for this SID.
     *
     * @return domain SID
     */
    SID getDomainSid();

    /**
     * Get the RID
     *
     * This is the last subauthority identifier
     *
     * @return the RID
     */
    int getRid();

    /**
     * Return a String representing this SID ideal for display to
     * users. This method should return the same text that the ACL

    //                                                                             =======
    @Override
    public CrawlingInfoDbm asDBMeta() {
        return CrawlingInfoDbm.getInstance();
    }

    @Override
    public String asTableDbName() {
        return "crawling_info";
    }

    // ===================================================================================