code: @Override
      public Query query(Schema schema) {
  
          if (field == null || field.trim().isEmpty()) {
              throw new IllegalArgumentException("Field name required");
          }
          if (value == null) {
              throw new IllegalArgumentException("Field value required");
          }
  
          ColumnMapperSingle<?> columnMapper = getMapper(schema, field);
          Class<?> clazz = columnMapper.baseClass();
          Query query;
          if (clazz == String.class) {
              Term term = new Term(field, value);
              query = new PrefixQuery(term);
          } else {
              String message = String.format("Prefix queries are not supported by %s mapper", clazz.getSimpleName());
              throw new UnsupportedOperationException(message);
          }
          query.setBoost(boost);
          return query;
      }
docs: {@inheritDoc}