final BeanDesc beanDesc = new BeanDescImpl(MyBean.class);
        final FieldDesc aaa = beanDesc.getFieldDesc("aaa");
        aaa.getStaticFieldValue();
    }

    /**
     * @throws Exception
     */
    @Test(expected = FieldNotStaticRuntimeException.class)
    public void testAaa_SetStaticFieldValue() throws Exception {
        final BeanDesc beanDesc = new BeanDescImpl(MyBean.class);

     */
    // GET /api/admin/dict/mapping/settings/{dictId}
    @Execute
    public JsonResponse<ApiResult> get$settings(final String dictId, final SearchBody body) {
        body.dictId = dictId;
        validateApi(body, messages -> {});
        final CharMappingPager pager = copyBeanToNewBean(body, CharMappingPager.class);

            this.maximum_length = (short) _src.dec_ndr_short();
            final int _bufferp = _src.dec_ndr_long();

            if (_bufferp != 0) {
                _src = _src.deferred;
                final int _buffers = _src.dec_ndr_long();
                _src.dec_ndr_long();
                final int _bufferl = _src.dec_ndr_long();
                final int _bufferi = _src.index;
                _src.advance(2 * _bufferl);

import jcifs.SmbResource;

abstract class FileEntryAdapterIterator implements CloseableIterator<SmbResource> {

    private static final Logger log = LoggerFactory.getLogger(FileEntryAdapterIterator.class);

    private final CloseableIterator<FileEntry> delegate;
    private final ResourceFilter filter;
    private final SmbResource parent;
    private SmbResource next;

    /**
     * @param parent
     * @param delegate

    public void expired() {
        try {
            final SearchEngineClient client = ComponentUtil.getSearchEngineClient();
            final NodesStatsResponse response = client.admin().cluster().prepareNodesStats().addMetric("os").execute().actionGet(10000L);

            short maxCpu = 0;
            for (final NodeStats nodeStats : response.getNodes()) {
                final OsStats os = nodeStats.getOs();

    long delay = 100;
    String url = null;
    int numComplete = 0;
    long ltime = 0L;

    @Override
    public void run() {
        try {
            final SmbFile f = new SmbFile(url);
            final SmbFile d = new SmbFile(f.getParent());
            final byte[] buf = new byte[1024];

            for (int ii = 0; ii < numIter; ii++) {

                synchronized (this) {

    public void generateDocumentNotFoundResponse(final String userMessage, final String documentUrl, final List<LlmMessage> history,
            final LlmStreamCallback callback) {
        final LlmChatRequest request = new LlmChatRequest();

        final String sanitizedUrl = sanitizeDocumentContent(documentUrl != null ? documentUrl.replaceAll("[\\r\\n\\t]", "") : "");
        final String resolvedPrompt =

        final Set<String> used = new java.util.HashSet<>();
        final List<String> groupedQueries = new ArrayList<>();
        for (final FacetQueryView view : facetQueryViewList) {
            final Set<String> viewValues = new java.util.HashSet<>(view.getQueryMap().values());
            final List<String> matched = new ArrayList<>();
            for (final String vq : validQueries) {

     * @throws InvalidQueryException if geo point format is invalid or parsing fails
     */
    public GeoInfo(final HttpServletRequest request) {

        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final String[] geoFields = fessConfig.getQueryGeoFieldsAsArray();
        final Map<String, List<QueryBuilder>> geoMap = new HashMap<>();

        StreamUtil.stream(request.getParameterMap())

     */
    public static StorageClient createClient(final FessConfig fessConfig) {
        final String endpoint = fessConfig.getStorageEndpoint();
        final String accessKey = fessConfig.getStorageAccessKey();
        final String secretKey = fessConfig.getStorageSecretKey();
        final String bucket = fessConfig.getStorageBucket();

        // Get explicit type or auto-detect
        final String typeStr = fessConfig.getStorageType();