chore: add toString to StreamedRow (#3890)

confluentinc · Nov 18, 2019 · da244df · da244df
1 parent 149b4fe
commit da244df
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/ksql-rest-model/src/main/java/io/confluent/ksql/rest/entity/StreamedRow.java b/ksql-rest-model/src/main/java/io/confluent/ksql/rest/entity/StreamedRow.java
@@ -24,8 +24,10 @@
 import com.fasterxml.jackson.annotation.JsonInclude.Include;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.annotation.JsonSubTypes;
+import com.fasterxml.jackson.core.JsonProcessingException;
 import com.google.errorprone.annotations.Immutable;
 import io.confluent.ksql.GenericRow;
+import io.confluent.ksql.json.JsonMapper;
 import io.confluent.ksql.query.QueryId;
 import io.confluent.ksql.schema.ksql.LogicalSchema;
 import java.util.Arrays;
@@ -134,6 +136,15 @@ public int hashCode() {
     return Objects.hash(header, row, errorMessage, finalMessage);
   }
 
+  @Override
+  public String toString() {
+    try {
+      return JsonMapper.INSTANCE.mapper.writeValueAsString(this);
+    } catch (JsonProcessingException e) {
+      return super.toString();
+    }
+  }
+
   private static void checkUnion(final Optional<?>... fs) {
     final long count = Arrays.stream(fs)
         .filter(Optional::isPresent)