Add ExportOutput equality and relation collection to Julia SDK

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: davidwzhao

sdks/julia/LogicalQueryProtocol.jl/src/equality.jl

@@ -478,6 +478,38 @@ function Base.isequal(a::Export, b::Export)
     _isequal_oneof(a.export_config, b.export_config)
 end
 
+# ExportCSVColumns
+Base.:(==)(a::ExportCSVColumns, b::ExportCSVColumns) = a.columns == b.columns
+Base.hash(a::ExportCSVColumns, h::UInt) = hash(a.columns, h)
+Base.isequal(a::ExportCSVColumns, b::ExportCSVColumns) = isequal(a.columns, b.columns)
+
+# ExportCSVSource
+function Base.:(==)(a::ExportCSVSource, b::ExportCSVSource)
+    _isequal_oneof(a.csv_source, b.csv_source)
+end
+function Base.hash(a::ExportCSVSource, h::UInt)
+    _hash_oneof(a.csv_source, h)
+end
+function Base.isequal(a::ExportCSVSource, b::ExportCSVSource)
+    _isequal_oneof(a.csv_source, b.csv_source)
+end
+
+# ExportCSVOutput
+Base.:(==)(a::ExportCSVOutput, b::ExportCSVOutput) = a.csv_source == b.csv_source && a.csv_config == b.csv_config
+Base.hash(a::ExportCSVOutput, h::UInt) = hash(a.csv_config, hash(a.csv_source, h))
+Base.isequal(a::ExportCSVOutput, b::ExportCSVOutput) = isequal(a.csv_source, b.csv_source) && isequal(a.csv_config, b.csv_config)
+
+# ExportOutput
+function Base.:(==)(a::ExportOutput, b::ExportOutput)
+    _isequal_oneof(a.export_output, b.export_output)
+end
+function Base.hash(a::ExportOutput, h::UInt)
+    _hash_oneof(a.export_output, h)
+end
+function Base.isequal(a::ExportOutput, b::ExportOutput)
+    _isequal_oneof(a.export_output, b.export_output)
+end
+
 # IVMConfig
 Base.:(==)(a::IVMConfig, b::IVMConfig) = a.level == b.level
 Base.hash(a::IVMConfig, h::UInt) = hash(a.level, h)

sdks/julia/LogicalQueryProtocol.jl/src/properties.jl

@@ -132,6 +132,8 @@ function _collect_read_ids!(ids::Set{LQPRelationId}, read::Read)
         _collect_read_ids!(ids, read.read_type[]::Abort)
     elseif read.read_type.name == :var"#export"
         _collect_read_ids!(ids, read.read_type[]::Export)
+    elseif read.read_type.name == :export_output
+        _collect_read_ids!(ids, read.read_type[]::ExportOutput)
     else
         @assert false
     end
@@ -178,6 +180,24 @@ function _collect_read_ids!(ids::Set{LQPRelationId}, _export::Export)
     end
     return nothing
 end
+function _collect_read_ids!(ids::Set{LQPRelationId}, export_output::ExportOutput)
+    isnothing(export_output.export_output) && return nothing
+    config = export_output.export_output
+    if config.name == :csv
+        csv_output = config[]::ExportCSVOutput
+        src = isnothing(csv_output.csv_source) ? nothing : csv_output.csv_source.csv_source
+        if !isnothing(src)
+            if src.name == :gnf_columns
+                for column in (src[]::ExportCSVColumns).columns
+                    !isnothing(column.column_data) && push!(ids, persistent_id(column.column_data))
+                end
+            elseif src.name == :table_def
+                push!(ids, persistent_id(src[]::RelationId))
+            end
+        end
+    end
+    return nothing
+end
 
 persistent_id(fragment::Fragment) = persistent_id(fragment.id::FragmentId)
 persistent_id(id::FragmentId) = LQPFragmentId(id.id)