package com.xyz.topology.netflow.beam; import java.io.Serializable; import org.apache.avro.Schema; public class User extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { private String name; private int favoriteNumber; private String favoriteColor; public User() { } public User(String name, int favoriteNumber, String favoriteColor) { this.name = name; this.favoriteNumber = favoriteNumber; this.favoriteColor = favoriteColor; } public String getName() { return name; } public String getFavoriteColor() { return favoriteColor; } public int getFavoriteNumber() { return favoriteNumber; } @Override public Schema getSchema() { // TODO Auto-generated method stub return null; } @Override public Object get(int field) { // TODO Auto-generated method stub return null; } @Override public void put(int field, Object value) { // TODO Auto-generated method stub } }