diff --git a/java/src/main/java/com/logicalclocks/hsfs/FeatureGroup.java b/java/src/main/java/com/logicalclocks/hsfs/FeatureGroup.java index 025a7107aa..341bf16401 100644 --- a/java/src/main/java/com/logicalclocks/hsfs/FeatureGroup.java +++ b/java/src/main/java/com/logicalclocks/hsfs/FeatureGroup.java @@ -118,7 +118,7 @@ public FeatureGroup(FeatureStore featureStore, @NonNull String name, Integer ver this.onlineEnabled = onlineEnabled; this.defaultStorage = defaultStorage != null ? defaultStorage : Storage.OFFLINE; this.features = features; - this.statisticsEnabled = statisticsEnabled; + this.statisticsEnabled = statisticsEnabled != null ? statisticsEnabled : true; this.histograms = histograms; this.correlations = correlations; this.statisticColumns = statisticColumns; diff --git a/java/src/main/java/com/logicalclocks/hsfs/TrainingDataset.java b/java/src/main/java/com/logicalclocks/hsfs/TrainingDataset.java index 6b2b1b2306..1f6bf0080a 100644 --- a/java/src/main/java/com/logicalclocks/hsfs/TrainingDataset.java +++ b/java/src/main/java/com/logicalclocks/hsfs/TrainingDataset.java @@ -120,7 +120,7 @@ public TrainingDataset(@NonNull String name, Integer version, String description this.splits = splits; this.seed = seed; this.featureStore = featureStore; - this.statisticsEnabled = statisticsEnabled; + this.statisticsEnabled = statisticsEnabled != null ? statisticsEnabled : true; this.histograms = histograms; this.correlations = correlations; this.statisticColumns = statisticColumns; @@ -307,6 +307,7 @@ public Statistics computeStatistics() throws FeatureStoreException, IOException * @throws FeatureStoreException * @throws IOException */ + @JsonIgnore public Statistics getStatistics() throws FeatureStoreException, IOException { return statisticsEngine.getLast(this); } @@ -319,6 +320,7 @@ public Statistics getStatistics() throws FeatureStoreException, IOException { * @throws FeatureStoreException * @throws IOException */ + @JsonIgnore public Statistics getStatistics(String commitTime) throws FeatureStoreException, IOException { return statisticsEngine.get(this, commitTime); }