[pulsar] 02/13: More better check

[sanjeevrk]

This is an automated email from the ASF dual-hosted git repository.

sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 48f5233f3eb0975aaf37974b4aa1310f292f41f9
Author: Sanjeev Kulkarni <sanj...@streaml.io>
AuthorDate: Thu Oct 4 20:09:24 2018 -0700

    More better check
---
 .../src/main/java/org/apache/pulsar/functions/utils/SourceConfig.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfig.java
 
b/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfig.java
index 38e200a..c1ff240 100644
--- 
a/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfig.java
+++ 
b/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfig.java
@@ -25,6 +25,7 @@ import lombok.Setter;
 import lombok.ToString;
 import org.apache.pulsar.client.api.Schema;
 import org.apache.pulsar.functions.api.SerDe;
+import 
org.apache.pulsar.functions.utils.validation.ConfigValidationAnnotations;
 import 
org.apache.pulsar.functions.utils.validation.ConfigValidationAnnotations.NotNull;
 import 
org.apache.pulsar.functions.utils.validation.ConfigValidationAnnotations.isFileExists;
 import 
org.apache.pulsar.functions.utils.validation.ConfigValidationAnnotations.isImplementationOfClass;
@@ -55,7 +56,7 @@ public class SourceConfig {
     @isValidTopicName
     private String topicName;
 
-    @isImplementationOfClass(implementsClass = SerDe.class)
+    @ConfigValidationAnnotations.isValidSerde
     private String serdeClassName;
 
     private String schemaType;