add exception messages

apache · Feb 6, 2024 · 53cfd92 · 53cfd92
1 parent d12ed0b
commit 53cfd92
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/...connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordProjection.java b/...connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordProjection.java
@@ -164,7 +164,7 @@ public <T> T get(int pos, Class<T> javaClass) {
 
   @Override
   public <T> void set(int pos, T value) {
-    throw new UnsupportedOperationException();
+    throw new UnsupportedOperationException("RecordProjection.set(int, Object) is not supported");
   }
 
   @Override
@@ -174,12 +174,13 @@ public StructType struct() {
 
   @Override
   public Object getField(String name) {
-    throw new UnsupportedOperationException();
+    throw new UnsupportedOperationException("RecordProjection.getField(String) is not supported");
   }
 
   @Override
   public void setField(String name, Object value) {
-    throw new UnsupportedOperationException();
+    throw new UnsupportedOperationException(
+        "RecordProjection.setField(String, Object) is not supported");
   }
 
   @Override
@@ -189,11 +190,11 @@ public Object get(int pos) {
 
   @Override
   public Record copy() {
-    throw new UnsupportedOperationException();
+    throw new UnsupportedOperationException("RecordProjection.copy() is not supported");
   }
 
   @Override
   public Record copy(Map<String, Object> overwriteValues) {
-    throw new UnsupportedOperationException();
+    throw new UnsupportedOperationException("RecordProjection.copy(Map) is not supported");
   }
 }