import org.apache.samza.serializers.SerdeFactory; //导入依赖的package包/类
/**
 * set the serde for this appender. It looks for the stream serde first, then system serde.
 * If still can not get the serde, throws exceptions.
 *
 * @param log4jSystemConfig log4jSystemConfig for this appender
 * @param systemName name of the system
 * @param streamName name of the stream
 */
private void setSerde(Log4jSystemConfig log4jSystemConfig, String systemName, String streamName) {
  String serdeClass = LoggingEventJsonSerdeFactory.class.getCanonicalName();
  String serdeName = log4jSystemConfig.getStreamSerdeName(systemName, streamName);

  if (serdeName != null) {
    serdeClass = log4jSystemConfig.getSerdeClass(serdeName);
  }

  if (serdeClass != null) {
    SerdeFactory<LoggingEvent> serdeFactory = Util.<SerdeFactory<LoggingEvent>>getObj(serdeClass);
    serde = serdeFactory.getSerde(systemName, config);
  } else {
    String serdeKey = String.format(SerializerConfig.SERDE_FACTORY_CLASS(), serdeName);
    throw new SamzaException("Can not find serializers class for key '" + serdeName + "'. Please specify " +
        serdeKey + " property");
  }
}
 

import org.apache.samza.serializers.SerdeFactory; //导入依赖的package包/类
public SamzaJobConfigBuilder addSerde(String name, Class<? extends SerdeFactory> serdeClass) {
  isNullOrEmpty(name, "Serde name");
  isNull(serdeClass, "Serde class");

  put(format(SERIALIZER_SERDE_CLASS, name), serdeClass.getName());

  return this;
}
 

import org.apache.samza.serializers.SerdeFactory; //导入依赖的package包/类
/**
 * A helper method to get the Serde from the serdeName
 *
 * @param name serde name
 * @param serializerConfig serializer config
 * @return a Serde of this serde name
 */
private Serde<Object> getSerdeFromName(String name, JavaSerializerConfig serializerConfig) {
  String serdeClassName = serializerConfig.getSerdeClass(name);
  if (serdeClassName == null) {
    serdeClassName = Util.defaultSerdeFactoryFromSerdeName(name);
  }
  return Util.<SerdeFactory<Object>> getObj(serdeClassName).getSerde(name, serializerConfig);
}