public void test_validateInputStream_doesNotConsumeStream() throws Exception {
        final byte[] testData = "test data for validation".getBytes();
        final ByteArrayInputStream in = new ByteArrayInputStream(testData);
        final int availableBefore = in.available();

        extractor.testValidateInputStream(in);

        final int availableAfter = in.available();

    private final boolean step1;

    private final boolean step2;

    private final boolean step3;

    private final boolean step4;

    private final boolean step5;

    private final boolean step6;

    public FlexiblePorterStemFilterFactory(final IndexSettings indexSettings, final Environment environment, final String name,
            final Settings settings) {

     */
    public static final int TT_EOF = -1;

    /**
     * Represents a Quote.
     */
    public static final int TT_QUOTE = '\'';

    /**
     * Represents a word.
     */
    public static final int TT_WORD = -3;

    private static final int TT_NOTHING = -4;

    private static final int NEED_CHAR = Integer.MAX_VALUE;

    private static final int QUOTE = '\'';

        final Date date = toDate("10/9/7");
        assertThat(new SimpleDateFormat("yyyy/MM/dd").format(date), is("2010/09/07"));
    }

    /**
     * @throws Exception
     */
    @Test
    public void testToDate_MediumStyle() throws Exception {
        final Date date = toDate("2010/9/7");

     */
    public FailureUrl store(final CrawlingConfig crawlingConfig, final String errorName, final String url, final Throwable e) {
        if (e instanceof ContainerNotAvailableException) {
            return null;
        }

        final FailureUrlBhv bhv = ComponentUtil.getComponent(FailureUrlBhv.class);
        final FailureUrl failureUrl = bhv.selectEntity(cb -> {

         */
        @Override
        protected Query getFieldQuery(final String field, final String queryText, final boolean quoted) throws ParseException {
            final org.apache.lucene.search.Query query = super.getFieldQuery(field, queryText, quoted);
            if (quoted && query instanceof final TermQuery termQuery) {
                final Pair<String, String> splitField = splitField(defaultField, field);

     * @return optional duplicate host entity with audit fields set
     */
    public static OptionalEntity<DuplicateHost> getDuplicateHost(final CreateForm form) {
        final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
        final String username = systemHelper.getUsername();
        final long currentTime = systemHelper.getCurrentTimeAsLong();
        return getEntity(form, username, currentTime).map(entity -> {

    SmbComReadAndXResponse() {
    }

    SmbComReadAndXResponse(final byte[] b, final int off) {
        this.b = b;
        this.off = off;
    }

    void setParam(final byte[] b, final int off) {
        this.b = b;
        this.off = off;
    }

    @Override
    int writeParameterWordsWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    @Override

     * @param offset The starting offset at which the SMB header begins.
     * @param length The length of the SMB data starting at offset.
     */
    void sign(final byte[] data, final int offset, final int length, final ServerMessageBlock request, final ServerMessageBlock response) {
        request.signSeq = signSequence;
        if (response != null) {
            response.signSeq = signSequence + 1;

        final String id = scheduledJob.getId();
        final String target = scheduledJob.getTarget();
        if (!ComponentUtil.getFessConfig().isSchedulerTarget(target)) {
            logger.info("Ignoring job: name={}, id={}, target={}", scheduledJob.getName(), id, scheduledJob.getTarget());
            return;
        }