remove schema field on parsed message
@@ -29,7 +29,6 @@ import java.util.Arrays;
*/
public class ParsedMessage extends Message {
private String[] mPartitions;
- private Schema schema;
@Override
public String toString() {
@@ -43,14 +42,6 @@ public class ParsedMessage extends Message {
this.mPartitions = mPartitions;
}
- public Schema getSchema(){
- return schema;
- }
-
- public void setSchema(Schema schema){
- this.schema = schema;
- }
-
public String[] getPartitions() {
return mPartitions;
}
