import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
@Override
public Portable create(int classId) {
    switch (classId) {
        case ADD:
            return new AddRequest();
        case ADD_ALL:
            return new AddAllRequest();
        case CARDINALITY:
            return new CardinalityRequest();
        case UNION:
            return new UnionRequest();
        case RESET:
            return new ResetRequest();
        default:
            return null;
    }
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
@Override
public Portable create(int classId) {
    if (DeviceNotification.CLASS_ID == classId) {
        return new DeviceNotification();
    } else if (DeviceCommand.CLASS_ID == classId) {
        return new DeviceCommand();
    } else if (HivePrincipal.CLASS_ID == classId) {
        return new HivePrincipal();
    } else if (Filter.CLASS_ID == classId) {
        return new Filter();
    } else if (Subscriber.CLASS_ID == classId) {
        return new Subscriber();
    }
    
    return null;
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
@Override
public Collection<String> getExtraImplements(JMessage<?> message) throws GeneratorException {
    if (message.hasAnnotation(ThriftAnnotation.JAVA_HAZELCAST_CLASS_ID)) {
        return ImmutableList.of(Portable.class.getName());
    } else {
        return new ArrayList<>();
    }
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
/**
 * Method to write the create method from implemented PortableFactory
 *
 * @param messages List with CStructDescriptor.
 * <pre>
 * {@code
 *  @Override
 *  public com.hazelcast.nio.serialization.Portable create(int classId) {
 *      switch(classId) {
 *          ...
 *          default: {
 *              return null;
 *          }
 *      }
 *  }
 * }
 * </pre>
 */
private void appendCreateMethod(List<CStructDescriptor> messages) {
    writer.appendln("@Override")
          .formatln("public %s create(int classId) {", Portable.class.getName())
          .begin()
          .appendln("switch(classId) {")
          .begin();
    for (CStructDescriptor message : messages) {
        writer.formatln("case %s: {", getHazelcastClassId(message.getName()))
              .begin()
              .formatln("return new %s.%s();",
                        message.getName(),
                        HazelcastPortableMessageFormatter.WRAPPER_CLASS_NAME)
              .end()
              .appendln("}");
    }
    writer.appendln("default: {")
          .begin()
          .appendln("return null;")
          .end()
          .appendln("}")
          .end();
    writer.appendln("}")
          .end()
          .appendln("}")
          .newline();
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
@Override
public Portable create(int classId) {
	if (classId == cli_XDMCredentials) {
		return new SecureCredentials();
	}
	return super.create(classId);
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
@Override
public Portable create(int classId) {
	if (classId == cli_XDMCredentials) {
		return new SecureCredentials();
	}
	return null;
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
@Override
public Portable create(int classId) {
    switch (classId) {
        case ADD:
            return new IncrementByRequest();
        case RESET:
            return new GetRequest();
        default:
            return null;
    }
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
@Override
public PortableFactory createFactory() {
    return new PortableFactory() {
        @Override
        public Portable create(int classId) {
            switch (classId) {
                case 1:
                    return null;
                default:
                    return null;
            }
        }
    };
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
@Override
public Portable create(int classId) {
    switch (classId) {
        case ComplexDomainObject.PORTABLE_CLASS_ID:
            return new ComplexDomainObject();
        default:
            return null;
    }
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
@Override
public Portable create(int classId) {
    switch (classId) {
        case PortableDomainObject.CLASS_ID:
            return new PortableDomainObject();
        default:
            throw new IllegalArgumentException("Unknown class ID" + classId);
    }
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
@Override
public Portable create(int i) {
    return new SillySequencePortable();
}
 

import com.hazelcast.nio.serialization.Portable; //导入依赖的package包/类
public Portable getPortable() {
    SillySequencePortable portable = new SillySequencePortable();
    portable.count = this.count;
    portable.payloadField = ArrayUtils.toPrimitive(payloadField.toArray(new Integer[payloadField.size()]));
    return portable;
}