File tree Expand file tree Collapse file tree
data/src/main/java/org/apache/iceberg/data Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -98,7 +98,7 @@ protected S equalityDeleteInputSchema() {
9898 @ Override
9999 public DataWriter <T > newDataWriter (
100100 EncryptedOutputFile file , PartitionSpec spec , StructLike partition ) {
101- Preconditions .checkNotNull (dataSchema , "Data schema must not be null" );
101+ Preconditions .checkArgument (dataSchema != null , "Invalid data schema: null" );
102102 EncryptionKeyMetadata keyMetadata = file .keyMetadata ();
103103 Map <String , String > properties = table != null ? table .properties () : ImmutableMap .of ();
104104 MetricsConfig metricsConfig =
@@ -127,7 +127,7 @@ public DataWriter<T> newDataWriter(
127127 @ Override
128128 public EqualityDeleteWriter <T > newEqualityDeleteWriter (
129129 EncryptedOutputFile file , PartitionSpec spec , StructLike partition ) {
130- Preconditions .checkNotNull (equalityDeleteRowSchema , "Equality delete schema must not be null" );
130+ Preconditions .checkArgument (equalityDeleteRowSchema != null , "Invalid delete schema: null" );
131131
132132 EncryptionKeyMetadata keyMetadata = file .keyMetadata ();
133133 Map <String , String > properties = table != null ? table .properties () : ImmutableMap .of ();
You can’t perform that action at this time.
0 commit comments