Package org.jboss.dashboard.dataset

Examples of org.jboss.dashboard.dataset.DataSet


        try {
            // Ensure data retrieved is refreshed.
            Chronometer crono = new Chronometer();
            crono.start();
            DataSet ds = dataProvider.refreshDataSet();
            crono.stop();
            elapsedTime = crono.elapsedTime();
            nrows = 0;
            if (ds != null && ds.getProperties().length > 0) nrows = ds.getRowCount();
            loadAttemptOk = true;
        } catch (Exception e) {
            throw new Exception(e.getMessage() != null ? e.getMessage() : getErrorMessage("error5") );
        }
        return null;
View Full Code Here


            memoryProfiler.freeMemory();
            long timeBegin = System.currentTimeMillis();
            long memBegin = memoryProfiler.getMemoryUsedInBytes();

            int n = 10;
            DataSet dataSet = buildDataSet(n, dataProvider, dataLoader);

            memoryProfiler.freeMemory();
            long timeEnd = System.currentTimeMillis();
            long memEnd = memoryProfiler.getMemoryUsedInBytes();
            long mem = memEnd-memBegin;
            log.info("500 rows - Load time = " + Chronometer.formatElapsedTime(timeEnd-timeBegin));
            log.info("500 rows - Size of = " + MemoryProfiler.formatSize(dataSet.sizeOf()));
            log.info("500 rows - Memory consumption = " + MemoryProfiler.formatSize(mem));

            assertThat(mem).isLessThan(1024 * 1024);
            assertThat(dataSet).isNotNull();
            assertThat(dataSet.getProperties().length).isGreaterThan(0);
            assertThat(dataSet.getRowCount()).isEqualTo(50*n);
        } catch (DataSetException e) {
            fail("Load constraints violated.", e);
        }
    }
View Full Code Here

            memoryProfiler.freeMemory();
            long timeBegin = System.currentTimeMillis();
            long memBegin = memoryProfiler.getMemoryUsedInBytes();

            int n = 1000;
            DataSet dataSet = buildDataSet(n, dataProvider, dataLoader);

            memoryProfiler.freeMemory();
            long timeEnd = System.currentTimeMillis();
            long memEnd = memoryProfiler.getMemoryUsedInBytes();
            long mem = memEnd-memBegin;
            log.info("50000 rows - Load time = " + Chronometer.formatElapsedTime(timeEnd - timeBegin));
            log.info("50000 rows - Size of = " + MemoryProfiler.formatSize(dataSet.sizeOf()));
            log.info("50000 rows - Memory consumption = " + MemoryProfiler.formatSize(mem));


            assertThat(mem).isLessThan(50 * 1024 * 1024);
            assertThat(dataSet).isNotNull();
            assertThat(dataSet.getProperties().length).isGreaterThan(0);
            assertThat(dataSet.getRowCount()).isEqualTo(50*n);
        } catch (DataSetException e) {
            fail("Load constraints violated.", e);
        }
    }
View Full Code Here

    /**
     * @throws DataSetException In case any it doesn't meet the thresholds set.
     */
    public void validate() throws Exception {
        DataSet dataSet = dataSetRef.get();
        MemoryProfiler memoryProfiler = MemoryProfiler.lookup().freeMemory();
        long memoryUsed = memoryProfiler.getMemoryUsedInBytes() - startMemory;
        long elapsedTime = System.currentTimeMillis() - startTime;
        long sizeInBytes = dataSet.sizeOf();
        long maxSize = dataSet.getDataProvider().getDataLoader().getMaxDataSetSizeInBytes();
        long maxTime = dataSet.getDataProvider().getDataLoader().getMaxDataSetLoadTimeInMillis();
        long maxMemUsed = dataSet.getDataProvider().getDataLoader().getMaxMemoryUsedInDataLoad();

        if (maxMemUsed > 0 && memoryUsed > maxMemUsed) {
            String total = MemoryProfiler.formatSize(maxMemUsed);
            throw new DataSetException("Data set load memory usage has been exceeded = " + total);
        }
View Full Code Here

    /**
     * @throws DataSetException In case any it doesn't meet the thresholds set.
     */
    public void validate() throws Exception {
        DataSet dataSet = dataSetRef.get();
        long elapsedTime = System.currentTimeMillis() - startTime;
        long maxTime = dataSet.getDataProvider().getDataLoader().getMaxDataSetSortTimeInMillis();

        if (maxTime > 0 && elapsedTime > maxTime) {
            String time = Chronometer.formatElapsedTime(maxTime);
            throw new DataSetException("Data set sort time has been exceeded = " + time);
        }
View Full Code Here

    /**
     * @throws DataSetException In case any it doesn't meet the thresholds set.
     */
    public void validate() throws Exception {
        DataSet dataSet = dataSetRef.get();
        long elapsedTime = System.currentTimeMillis() - startTime;
        long maxTime = dataSet.getDataProvider().getDataLoader().getMaxDataSetFilterTimeInMillis();

        if (maxTime > 0 && elapsedTime > maxTime) {
            String time = Chronometer.formatElapsedTime(maxTime);
            throw new DataSetException("Data set filter time has been exceeded = " + time);
        }
View Full Code Here

    /**
     * @throws DataSetException In case any it doesn't meet the thresholds set.
     */
    public void validate() throws Exception {
        DataSet dataSet = dataSetRef.get();
        long elapsedTime = System.currentTimeMillis() - startTime;
        long maxTime = dataSet.getDataProvider().getDataLoader().getMaxDataSetGroupTimeInMillis();

        if (maxTime > 0 && elapsedTime > maxTime) {
            String time = Chronometer.formatElapsedTime(maxTime);
            throw new DataSetException("Data set group-by time has been exceeded = " + time);
        }
View Full Code Here

            }
            if (isTestConfigButtonPressed()) return;

            // Merge property configurations.
            DataProvider dpDO = getDataProvider();
            DataSet newDataSetConfigured = dpDO.getDataSet(); // Cached data set with properties configured (deserialized).
            DataSet newDataSetNotConfigured = dpDO.refreshDataSet(); // New data set. No configuration applied to it's properties.
            DataProperty[] properties = newDataSetConfigured.getProperties();
            for (int i = 0; i < properties.length; i++) {
                DataProperty configuredProperty = properties[i];
                DataProperty notConfiguredProperty = newDataSetNotConfigured.getPropertyById(configuredProperty.getPropertyId());

                Domain oldDomain = configuredProperty.getDomain();
                if (!(oldDomain instanceof LabelDomain && ((LabelDomain) oldDomain).isConvertedFromNumeric())) {
                    configuredProperty.setDomain(notConfiguredProperty.getDomain());
                }
View Full Code Here

        }
        return null;
    }

    public DataProperty getGroupByProperty() {
        DataSet originalDataSet = getOriginalDataSet();
        if (originalDataSet == null) return null;
       
        // If the group by property is null or it disappears from the data set then reload it from persistence.
        if (groupByProperty == null || originalDataSet.getPropertyById(groupByProperty.getPropertyId()) == null)  {
            if (groupByConfig != null) {
                groupByProperty = originalDataSet.getPropertyById(groupByConfig.getPropertyId());
                if (groupByProperty != null) {
                    groupByProperty = groupByProperty.cloneProperty();
                    groupByConfig.apply(groupByProperty);
                }
            }
View Full Code Here

    protected void catchDataSetChanges() {
        if (dataProvider == null) return;
        try {
            // Be aware of the dataset changes.
            DataSet uptodateDataSet = dataProvider.getDataSet();
            boolean dataSetChanged = (dataSet != null && (dataSet != uptodateDataSet || dataSetRowCount != uptodateDataSet.getRowCount()));
            dataSet = uptodateDataSet;

            // If the data set is updated then refresh the current group by (if any).
            if (dataSetChanged) {
                currentPage = 1;
View Full Code Here

TOP

Related Classes of org.jboss.dashboard.dataset.DataSet

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.