Skip to content

Commit 99c35c8

Browse files
committed
dbsp: Always include csv support, even without the with-csv feature.
The feature is left in place just in case someone uses it, but it no longer does anything. Signed-off-by: Ben Pfaff <blp@feldera.com>
1 parent b9515df commit 99c35c8

File tree

4 files changed

+10
-15
lines changed

4 files changed

+10
-15
lines changed

crates/dbsp/Cargo.toml

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,9 @@ rustdoc-args = ["--cfg", "docsrs"]
2020
[features]
2121
# Note: If you add a feature, adjust the ALMOST_ALL_FEATURES environment variable in
2222
# main.yml and coverage.yml:
23-
default = ["with-serde"]
23+
default = ["with-serde", "with-csv"]
2424
with-serde = []
25-
with-csv = ["csv"]
25+
with-csv = []
2626

2727
[dependencies]
2828
num = "0.4.0"
@@ -33,7 +33,7 @@ crossbeam-utils = "0.8.6"
3333
once_cell = "1.9.0"
3434
priority-queue = "1.3.2"
3535
hashbrown = "0.14.2"
36-
csv = { version = "1.2.2", optional = true }
36+
csv = { version = "1.2.2" }
3737
impl-trait-for-tuples = "0.2"
3838
itertools = "0.10.5"
3939
textwrap = "0.15.0"
@@ -111,12 +111,10 @@ ijson = { git = "https://github.com/abhizer/ijson.git" }
111111
[[bench]]
112112
name = "galen"
113113
harness = false
114-
required-features = ["with-csv"]
115114

116115
#[[bench]]
117116
#name = "fraud"
118117
#harness = false
119-
#required-features = ["with-csv", "with-serde"]
120118

121119
[[bench]]
122120
name = "path"
@@ -128,7 +126,6 @@ harness = false
128126

129127
#[[bench]]
130128
#name = "ldbc-graphalytics"
131-
#required-features = ["with-csv"]
132129
#harness = false
133130

134131
[[bench]]

crates/dbsp/Makefile.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
[tasks.build]
2-
args = ["build", "--features", "with-serde with-csv"]
2+
args = ["build"]
33

44
[tasks.test]
5-
args = ["test", "--features", "with-serde with-csv"]
5+
args = ["test"]

crates/dbsp/src/operator/mod.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ pub(crate) mod inspect;
1616

1717
mod condition;
1818
mod count;
19-
#[cfg(feature = "with-csv")]
2019
mod csv;
2120
mod delta0;
2221
mod differentiate;
@@ -46,7 +45,6 @@ mod semijoin;
4645
pub mod time_series;
4746
mod trace;
4847

49-
#[cfg(feature = "with-csv")]
5048
pub use self::csv::CsvSource;
5149
pub use apply::Apply;
5250
pub use condition::Condition;

scripts/bench.bash

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ FELDERA_API=http://localhost:8080
5656
python3 benchmark/feldera-sql/run.py --storage --api-url $FELDERA_API --kafka-broker $KAFKA_BROKER --csv crates/nexmark/${NEXMARK_SQL_STORAGE_CSV_FILE} --csv-metrics crates/nexmark/${NEXMARK_SQL_STORAGE_METRICS_CSV_FILE} --metrics-interval 1
5757

5858
# Run galen benchmark
59-
cargo bench --bench galen --features="with-csv" -- --workers 10 --csv ${GALEN_CSV_FILE}
59+
cargo bench --bench galen -- --workers 10 --csv ${GALEN_CSV_FILE}
6060

6161
# Run ldbc benchmarks
6262
DATASET_SMALL='graph500-22'
@@ -65,10 +65,10 @@ if [ "$SMOKE" != "" ]; then
6565
DATASET_SMALL='wiki-Talk'
6666
DATASET_MEDIUM='kgs'
6767
fi
68-
#cargo bench --bench ldbc-graphalytics --features="with-csv" -- bfs ${DATASET_SMALL} --threads 1 --csv ${LDBC_CSV_FILE}
69-
#cargo bench --bench ldbc-graphalytics --features="with-csv" -- bfs ${DATASET_MEDIUM} --threads 6 --csv ${LDBC_CSV_FILE}
70-
#cargo bench --bench ldbc-graphalytics --features="with-csv" -- pagerank ${DATASET_SMALL} --threads 1 --csv ${LDBC_CSV_FILE}
71-
#cargo bench --bench ldbc-graphalytics --features="with-csv" -- pagerank ${DATASET_MEDIUM} --threads 6 --csv ${LDBC_CSV_FILE}
68+
#cargo bench --bench ldbc-graphalytics -- bfs ${DATASET_SMALL} --threads 1 --csv ${LDBC_CSV_FILE}
69+
#cargo bench --bench ldbc-graphalytics -- bfs ${DATASET_MEDIUM} --threads 6 --csv ${LDBC_CSV_FILE}
70+
#cargo bench --bench ldbc-graphalytics -- pagerank ${DATASET_SMALL} --threads 1 --csv ${LDBC_CSV_FILE}
71+
#cargo bench --bench ldbc-graphalytics -- pagerank ${DATASET_MEDIUM} --threads 6 --csv ${LDBC_CSV_FILE}
7272

7373
# Run nexmark benchmark with persistence
7474
EVENT_RATE=5000000

0 commit comments

Comments
 (0)