2525import io .delta .kernel .internal .actions .Metadata ;
2626import io .delta .kernel .internal .actions .Protocol ;
2727import io .delta .kernel .internal .data .GenericRow ;
28- import io .delta .kernel .internal .data .StructRow ;
2928import io .delta .kernel .internal .stats .FileSizeHistogram ;
3029import io .delta .kernel .internal .util .InternalUtils ;
3130import io .delta .kernel .internal .util .VectorUtils ;
@@ -86,14 +85,6 @@ public static Optional<CRCInfo> fromColumnarBatch(
8685 txnIdColumnVector .isNullAt (rowId )
8786 ? Optional .empty ()
8887 : Optional .of (txnIdColumnVector .getString (rowId ));
89- ColumnVector domainMetadataVector = batch .getColumnVector (getSchemaIndex (DOMAIN_METADATA ));
90- Optional <Set <DomainMetadata >> domainMetadata =
91- domainMetadataVector .isNullAt (rowId )
92- ? Optional .empty ()
93- : Optional .of (
94- VectorUtils .toJavaList (domainMetadataVector .getArray (rowId )).stream ()
95- .map (row -> DomainMetadata .fromRow ((StructRow ) row ))
96- .collect (Collectors .toSet ()));
9788 Optional <FileSizeHistogram > fileSizeHistogram =
9889 FileSizeHistogram .fromColumnVector (
9990 batch .getColumnVector (getSchemaIndex (FILE_SIZE_HISTOGRAM )), rowId );
@@ -111,7 +102,8 @@ public static Optional<CRCInfo> fromColumnarBatch(
111102 tableSizeBytes ,
112103 numFiles ,
113104 txnId ,
114- domainMetadata ,
105+ // TODO: load domain metadata from CRC.
106+ Optional .empty (),
115107 fileSizeHistogram ));
116108 }
117109
@@ -136,14 +128,14 @@ public CRCInfo(
136128 checkArgument (tableSizeBytes >= 0 );
137129 checkArgument (numFiles >= 0 );
138130 // Live Domain Metadata actions at this version, excluding tombstones.
131+ this .domainMetadata = requireNonNull (domainMetadata );
139132 domainMetadata .ifPresent (dms -> dms .forEach (dm -> checkArgument (!dm .isRemoved ())));
140133 this .version = version ;
141134 this .metadata = requireNonNull (metadata );
142135 this .protocol = requireNonNull (protocol );
143136 this .tableSizeBytes = tableSizeBytes ;
144137 this .numFiles = numFiles ;
145138 this .txnId = requireNonNull (txnId );
146- this .domainMetadata = requireNonNull (domainMetadata );
147139 this .fileSizeHistogram = requireNonNull (fileSizeHistogram );
148140 }
149141
0 commit comments