diff --git a/Cargo.lock b/Cargo.lock
index 61746ef5c..3c5c2e985 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -3111,6 +3111,8 @@ checksum = "a369332afd0ef5bd565f6db2139fb9f1dfdd0afa75a7f70f000b74208d76994f"
 dependencies = [
  "arrow",
  "base64 0.22.1",
+ "blake2",
+ "blake3",
  "chrono",
  "datafusion-common",
  "datafusion-execution",
@@ -3119,8 +3121,10 @@ dependencies = [
  "hex",
  "itertools 0.12.1",
  "log",
+ "md-5",
  "rand 0.8.5",
  "regex",
+ "sha2",
  "unicode-segmentation",
  "uuid",
 ]
diff --git a/Cargo.toml b/Cargo.toml
index 24701fe35..48c204cec 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -46,7 +46,7 @@ ahash = { version = "=0.8.7" }
 datafusion = { version = "40.0.0" }
 datafusion-common = { version = "40.0.0" }
 datafusion-proto = { version = "40.0.0" }
-datafusion-functions = { version = "40.0.0" }
+datafusion-functions = { version = "40.0.0", features = ["crypto_expressions"] }
 deltalake = { version = "0.18.2" }
 cornucopia = { version = "0.9.0" }
 cornucopia_async = {version = "0.6.0"}
diff --git a/crates/arroyo-planner/src/test/queries/crypto_function.sql b/crates/arroyo-planner/src/test/queries/crypto_function.sql
new file mode 100644
index 000000000..5147095ff
--- /dev/null
+++ b/crates/arroyo-planner/src/test/queries/crypto_function.sql
@@ -0,0 +1,7 @@
+create table impulse with (
+    connector = 'impulse',
+    event_rate = '10'
+);
+
+select sha256(cast(counter as TEXT))
+from impulse;
\ No newline at end of file