When received assets from DataApi

@param dataEvents
421141
@Override
    public void onDataChanged(DataEventBuffer dataEvents) {
        for (DataEvent dataEvent : dataEvents) {
            String path = dataEvent.getDataItem().getUri().getPath();
            Log.d(TAG, "onDataChanged(" + path + ")");
            if (path.startsWith(DAVINCI_PATH)) { //if it's a davinci path
                Log.d(TAG, "davinci-onDataChanged " + path);

                //download the bitmap and add it to cache
                Asset asset = DataMapItem.fromDataItem(dataEvent.getDataItem()).getDataMap().getAsset(DAVINCI_ASSET_IMAGE);
                Bitmap bitmap = loadBitmapFromAsset(asset);
                if (bitmap != null)
                    saveBitmap(getKey(path), bitmap);

                //callbacks
                callIntoWaiting(path);
            }
        }
    }
733804
public void setEvents(java.util.Collection<String> events) {
        if (events == null) {
            this.events = null;
            return;
        }

        this.events = new java.util.ArrayList<String>(events);
    }
1012921
private void onDataSetModifiedEvent(@Observes DataSetModifiedEvent event) {
        if (!editOn) {

            String targetUUID = event.getDataSetDef().getUUID();
            for (Displayer displayer : displayerCoordinator.getDisplayerList()) {
                DisplayerSettings settings = displayer.getDisplayerSettings();

                // Do nothing if the displayer:
                // - Is not drawn
                // - Is handling the refresh by itself
                // - Is not configured to be updated on stale data
                if (!displayer.isDrawn() || displayer.isRefreshOn() || !settings.isRefreshStaleData()) {
                    continue;
                }

                String uuid = null;
                DataSet dataSet = settings.getDataSet();
                if (dataSet != null) {
                    uuid = dataSet.getUUID();
                }
                DataSetLookup dataSetLookup = settings.getDataSetLookup();
                if (uuid == null && dataSetLookup != null) {
                    uuid = dataSetLookup.getDataSetUUID();
                }
                if (uuid != null && targetUUID.equals(uuid)) {
                    displayer.redraw();
                }
            }
        }
    }
1012333
public void installAssets(Collection<String> assetIds, RepositoryConnectionList loginInfo) throws InstallException {
        fireProgressEvent(InstallProgressEvent.CHECK, 1, Messages.INSTALL_KERNEL_MESSAGES.getLogMessage("STATE_CHECKING_ASSETS"));

        if (assetIds == null || assetIds.isEmpty()) {
            throw ExceptionUtils.createByKey("ERROR_ASSETS_LIST_INVALID");
        }

        RepositoryConnectionList li = loginInfo == null ? getResolveDirector().getRepositoryConnectionList(null, null, null,
                                                                                                           this.getClass().getCanonicalName() + ".installAssets") : loginInfo;
        Map<String, List<List<RepositoryResource>>> installResources = getResolveDirector().resolveMap(assetIds, li, false);
        if (isEmpty(installResources)) {
            throw ExceptionUtils.createByKey(InstallException.ALREADY_EXISTS, "ASSETS_ALREADY_INSTALLED",
                                             InstallUtils.getShortNames(product.getFeatureDefinitions(), assetIds).toString());
        }
        downloadAssets(installResources, InstallConstants.TO_USER);
    }
1058135
@PostMapping("/setting/update/param/from/url")
    public void updateValidationDataLists(HttpServletRequest req, @RequestBody List<ValidationData> datas) {
        this.validationSessionComponent.sessionCheck(req);
        this.msgSettingService.updateValidationData(datas);
    }
1103319
@Override
	public void onApplicationEvent(ApplicationEvent event) {
		if (event instanceof ContextRefreshedEvent) {
		    // Firstly dump out all the properties read from the various files
		    dumpProperties();
            // now init the identity resolver
            setIdentityResolver(identityResolverFactory.getIdentityResolver());
            // start
            start();
		}
	}
313947
private void onDataSetModifiedEvent(@Observes DataSetModifiedEvent event) {
        checkNotNull("event",
                     event);

        DataSetDef def = event.getDataSetDef();
        String targetUUID = event.getDataSetDef().getUUID();
        TimeAmount timeFrame = def.getRefreshTimeAmount();
        boolean noRealTime = timeFrame == null || timeFrame.toMillis() > 60000;

        if ((!def.isRefreshAlways() || noRealTime) && widget != null && widget.feedsFrom(targetUUID)) {
            workbenchNotification.fire(new NotificationEvent(AppConstants.INSTANCE.gallerywidget_dataset_modif(),
                                                             INFO));
            widget.redrawAll();
        }
    }
103362
public void handleData(String data) {
		if (data == null) return;
		text = data;
		sendEvent(new TextInputEvent(this.user, getPayload(), data));
		if (handler != null)
			handler.onType(data);
	}
630934
function(options) {
  options = options || {};
  
  this.datasources = [];
  this.styles = [];
  this.projection = DEFAULT_PROJECTION;
  this.assetsPath = ".";
  
  if (options.projection){
    this.projection = projector.util.cleanProjString(options.projection);
    console.log(this.projection);
  }
  
  this.boundsBuffer =
    ("boundsBuffer" in options) ? options.boundsBuffer : BUFFER_RATIO;
  
  this._renderer = cartoRenderer;
}
688409
@Override
    public void onAdd(Collection<? extends IDataType> dataTypes) throws AtlasException {
        AtlasGraphManagement management = provider.get().getManagementSystem();
               
        for (IDataType dataType : dataTypes) {
            if (LOG.isDebugEnabled()) {
                LOG.debug("Creating indexes for type name={}, definition={}", dataType.getName(), dataType.getClass());
            }

            try {
                addIndexForType(management, dataType);
                LOG.info("Index creation for type {} complete", dataType.getName());
            } catch (Throwable throwable) {
                LOG.error("Error creating index for type {}", dataType, throwable);
                //Rollback indexes if any failure
                rollback(management);
                throw new IndexCreationException("Error while creating index for type " + dataType, throwable);
            }
        }

        //Commit indexes
        commit(management);
    }
4845
public void setEventTopics(java.util.Collection<EventTopic> eventTopics) {
        if (eventTopics == null) {
            this.eventTopics = null;
            return;
        }

        this.eventTopics = new com.amazonaws.internal.SdkInternalList<EventTopic>(eventTopics);
    }
808179
public void setData(List<ImageItem> images) {
		selectedImages.clear();

		if (images != null && images.size() > 0) {
			this.images = images;
		} else {
			this.images.clear();
		}
		notifyDataSetChanged();
	}
666886
private void onDataSetStaleEvent(@Observes DataSetStaleEvent event) {
        DataSetDef def = event.getDataSetDef();
        if (DataSetProviderType.ELASTICSEARCH.equals(def.getProvider())) {
            remove(def.getUUID());
        }
    }
702023
void onDataSetDefRegisteredEvent(@Observes DataSetDefRegisteredEvent event) {
        checkNotNull("event",
                     event);

        final DataSetDef def = event.getDataSetDef();
        if (def != null && def.isPublic() && isSupported(def)) {
            // Reload the whole data set panels list.
            show();
        }
    }
1117080
@JsOverlay
  public final void initData(boolean useFactory, Set<String> fieldNames) {
    JsPropertyMap<Object> dataFields = JsPropertyMap.of();
    dataFieldsToProxy = new HashSet<>();
    for (String fieldName : fieldNames) {
      dataFields.set(fieldName, null);

      // If field name starts with $ or _ Vue.js won't proxify it so we must do it
      if (fieldName.startsWith("$") || fieldName.startsWith("_")) {
        dataFieldsToProxy.add(fieldName);
      }
    }

    if (useFactory) {
      String dataFieldsJSON = JSON.stringify(dataFields);
      this.setData((DataFactory) () -> JSON.parse(dataFieldsJSON));
    } else {
      this.setData((DataFactory) () -> dataFields);
    }
  }
691926
function DataChanneMessageEvent (event) {
    this.data = event.data;
    this.source = event.source;
    this.lastEventId = event.lastEventId;
    this.origin = event.origin;
    this.timeStamp = event.timeStamp;
    this.type = event.type;
    this.ports = event.ports;
    this.path = event.path;
  }
679531
public function onDataReady(DataEvent $event)
    {
         
        $data  = array();
       
        foreach ($event->getData() as $key => $row){
            foreach ($row as $field => $value){
                
                if($value instanceof \DateTime){
                    $value->setTimezone(new \DateTimeZone($this->timezone));
                }
                
                $data[$key][$field] = $value;
            }
        }
        
        $event->setData($data);
    }