FieldsConfigurationProvider

FieldsConfigurationProvider.java

private void watch() {
        new Thread(() -> {

            Storage storage = StorageOptions.getDefaultInstance().getService();
            Bucket bucket = storage.get(bucketName);

            while(true) {
                try {
                    Blob blob = bucket.get(filePath);
                    long currentTime = blob.getUpdateTime();
                    if (currentTime > lastUpdateTime) {
                        FieldsConfiguration newConfig = loadConfig(filePath);
                        Map<String, ChangeStatus> mutateResult = bqSchemaMutator.addFields(newConfig);
                        config = newConfig;
                        }
                    }
                    Thread.sleep(fieldsConfigLoadInterval);
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            }
        }).start();
}