Java 类com.esotericsoftware.kryo.NotNull 实例源码
项目:apex-malhar
文件:S3RecordReader.java
/**
* Initialize the AmazonS3 client using the accessKey, secretAccessKey, sets
* endpoint for the s3Client if provided
*
* @param accessKey
* @param secretAccessKey
* @param endPoint
*/
public void initializeS3Client(@javax.validation.constraints.NotNull String accessKey,
@javax.validation.constraints.NotNull String secretAccessKey, String endPoint)
{
Preconditions.checkNotNull(accessKey);
Preconditions.checkNotNull(secretAccessKey);
s3Client = new AmazonS3Client(new BasicAWSCredentials(accessKey, secretAccessKey));
if (endPoint != null) {
s3Client.setEndpoint(endPoint);
}
}
项目:EsperDist
文件:FieldSerializer.java
CachedField newCachedField (Field field, int fieldIndex, int accessIndex) {
Class[] fieldClass = new Class[] {field.getType()};
Type fieldGenericType = field.getGenericType();
CachedField cachedField;
if (fieldGenericType == fieldClass[0]) {
// This is a field without generic type parameters
if (TRACE) trace("kryo", "Field " + field.getName() + ": " + fieldClass[0]);
cachedField = newMatchingCachedField(field, accessIndex, fieldClass[0], fieldGenericType, null);
} else {
cachedField = genericsUtil.newCachedFieldOfGenericType(field, accessIndex, fieldClass, fieldGenericType);
}
if (cachedField instanceof ObjectField) {
hasObjectFields = true;
}
cachedField.field = field;
cachedField.varIntsEnabled = varIntsEnabled;
if (!useAsmEnabled) {
cachedField.offset = unsafeUtil.getObjectFieldOffset(field);
}
cachedField.access = (FieldAccess)access;
cachedField.accessIndex = accessIndex;
cachedField.canBeNull = fieldsCanBeNull && !fieldClass[0].isPrimitive() && !field.isAnnotationPresent(NotNull.class);
// Always use the same serializer for this field if the field's class is final.
if (kryo.isFinal(fieldClass[0]) || fixedFieldTypes) cachedField.valueClass = fieldClass[0];
return cachedField;
}
项目:EsperDist
文件:FieldSerializer.java
CachedField newCachedField (Field field, int fieldIndex, int accessIndex) {
Class[] fieldClass = new Class[] { field.getType() };
Type fieldGenericType = field.getGenericType();
CachedField cachedField;
if (fieldGenericType == fieldClass[0]) {
// This is a field without generic type parameters
if (TRACE) {
trace("kryo", "Field '" + field.getName() + "' of type " + fieldClass[0]);
}
cachedField = newMatchingCachedField(field, accessIndex, fieldClass[0], fieldGenericType, null);
} else {
cachedField = genericsUtil.newCachedFieldOfGenericType(field, accessIndex, fieldClass, fieldGenericType);
}
if (cachedField instanceof ObjectField) {
hasObjectFields = true;
}
cachedField.field = field;
cachedField.varIntsEnabled = varIntsEnabled;
if (!useAsmEnabled) {
cachedField.offset = unsafeUtil.getObjectFieldOffset(field);
}
cachedField.access = (FieldAccess)access;
cachedField.accessIndex = accessIndex;
cachedField.canBeNull = fieldsCanBeNull && !fieldClass[0].isPrimitive() && !field.isAnnotationPresent(NotNull.class);
// Always use the same serializer for this field if the field's class is final.
if (kryo.isFinal(fieldClass[0]) || fixedFieldTypes) cachedField.valueClass = fieldClass[0];
return cachedField;
}
项目:JourneyPlanner
文件:FieldSerializer.java
CachedField newCachedField (Field field, int fieldIndex, int accessIndex) {
Class[] fieldClass = new Class[] {field.getType()};
Type fieldGenericType = field.getGenericType();
CachedField cachedField;
if (fieldGenericType == fieldClass[0]) {
// This is a field without generic type parameters
if (TRACE) trace("kryo", "Field " + field.getName() + ": " + fieldClass[0]);
cachedField = newMatchingCachedField(field, accessIndex, fieldClass[0], fieldGenericType, null);
} else {
cachedField = genericsUtil.newCachedFieldOfGenericType(field, accessIndex, fieldClass, fieldGenericType);
}
if (cachedField instanceof ObjectField) {
hasObjectFields = true;
}
cachedField.field = field;
cachedField.varIntsEnabled = varIntsEnabled;
if (!useAsmEnabled) {
cachedField.offset = unsafeUtil.getObjectFieldOffset(field);
}
cachedField.access = (FieldAccess)access;
cachedField.accessIndex = accessIndex;
cachedField.canBeNull = fieldsCanBeNull && !fieldClass[0].isPrimitive() && !field.isAnnotationPresent(NotNull.class);
// Always use the same serializer for this field if the field's class is final.
if (kryo.isFinal(fieldClass[0]) || fixedFieldTypes) cachedField.valueClass = fieldClass[0];
return cachedField;
}
项目:apex-malhar
文件:S3RecordReader.java
/**
* Set the AmazonS3 service
*
* @param s3Client
* given s3Client
*/
public void setS3Client(@javax.validation.constraints.NotNull AmazonS3 s3Client)
{
Preconditions.checkNotNull(s3Client);
this.s3Client = s3Client;
}
项目:apex-malhar
文件:S3RecordReader.java
/**
* Set the bucket name
*
* @param bucketName
* given bucketName
*/
public void setBucketName(@javax.validation.constraints.NotNull String bucketName)
{
Preconditions.checkNotNull(bucketName);
this.bucketName = bucketName;
}
项目:apex-malhar
文件:S3RecordReader.java
/**
* Set the bucket name where the file resides
*
* @param bucketName
* bucket name
*/
public void setBucketName(@javax.validation.constraints.NotNull String bucketName)
{
Preconditions.checkNotNull(bucketName);
this.bucketName = bucketName;
}
项目:apex-malhar
文件:S3RecordReader.java
/**
* Set the access key
*
* @param accessKey
* given accessKey
*/
public void setAccessKey(@javax.validation.constraints.NotNull String accessKey)
{
Preconditions.checkNotNull(accessKey);
this.accessKey = accessKey;
}
项目:apex-malhar
文件:S3RecordReader.java
/**
* Set the secretAccessKey
*
* @param secretAccessKey
* secretAccessKey
*/
public void setSecretAccessKey(@javax.validation.constraints.NotNull String secretAccessKey)
{
Preconditions.checkNotNull(secretAccessKey);
this.secretAccessKey = secretAccessKey;
}