Added prefix to ignore to SchemaNamer

vamsi360 · Nov 25, 2018 · be563fc · be563fc
1 parent 72cacde
commit be563fc
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/lang/java/avro/src/main/java/org/apache/avro/specific/SchemaNamer.java b/lang/java/avro/src/main/java/org/apache/avro/specific/SchemaNamer.java
@@ -18,11 +18,13 @@ public class SchemaNamer {
 
   private final String prefixToAttach;
   private final String prefixToMatch;
-  public static final SchemaNamer DEFAULT_SCHEMA_NAMER = new SchemaNamer("", "");
+  private final String prefixToIgnore;
+  public static final SchemaNamer DEFAULT_SCHEMA_NAMER = new SchemaNamer("", "", "");
 
-  public SchemaNamer(String prefixToAttach, String prefixToMatch) {
+  public SchemaNamer(String prefixToAttach, String prefixToMatch, String prefixToIgnore) {
     this.prefixToAttach = prefixToAttach;
     this.prefixToMatch = prefixToMatch;
+    this.prefixToIgnore = prefixToIgnore;
   }
 
   public String getName(Class<?> clazz) {
@@ -39,7 +41,8 @@ public String getNamespace(Class<?> clazz) {
 
   public String getNamespace(Package pkg) {
     String pkgName = pkg.getName();
-    if (prefixToAttach != null && !"".equals(prefixToAttach) && pkgName.startsWith(prefixToMatch)) {
+    if (prefixToAttach != null && !"".equals(prefixToAttach) &&
+      pkgName.startsWith(prefixToMatch) && !pkgName.startsWith(prefixToIgnore)) {
       return prefixToAttach + "." + pkgName;
     } else {
       return pkgName;