• 如果您觉得本站非常有看点，那么赶紧使用Ctrl+D 收藏吧
> java > Java InputChunked类的典型用法和代码示例

Java InputChunked类的典型用法和代码示例

java 1次浏览

本文整理汇总了Java中com.esotericsoftware.kryo.io.InputChunked类的典型用法代码示例。如果您正苦于以下问题：Java InputChunked类的具体用法？Java InputChunked怎么用？Java InputChunked使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

InputChunked类属于com.esotericsoftware.kryo.io包，在下文中一共展示了InputChunked类的10个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: read

​ 点赞 2 ​ 

import com.esotericsoftware.kryo.io.InputChunked; //导入依赖的package包/类
public T read(InputStream in) throws IOException {
    KryoContext kryoContext = KRYOS.get();
    InputChunked input = kryoContext.getInputChunked();
    input.setInputStream(in);
    T object = readObject(kryoContext.getKryo(), input);
    return object;
}

开发者ID:jerrinot，
项目名称:subzero，
代码行数:8，
代码来源:KryoStrategy.java

示例2: read

​ 点赞 2 ​ 

import com.esotericsoftware.kryo.io.InputChunked; //导入依赖的package包/类
public Object read (Kryo kryo, Input input, Class type) {
	// The inflater would read from input beyond the compressed bytes if chunked enoding wasn't used.
	Inflater inflater = new Inflater(noHeaders);
	try {
		InflaterInputStream inflaterStream = new InflaterInputStream(new InputChunked(input, 256), inflater);
		return serializer.read(kryo, new Input(inflaterStream, 256), type);
	} finally {
		inflater.end();
	}
}

开发者ID:HoratiusTang，
项目名称:EsperDist，
代码行数:11，
代码来源:DeflateSerializer.java

示例3: testChunks

​ 点赞 2 ​ 

import com.esotericsoftware.kryo.io.InputChunked; //导入依赖的package包/类
public void testChunks () {
	Output output = new Output(512);
	output.writeInt(1234);
	OutputChunked outputChunked = new OutputChunked(output);
	outputChunked.writeInt(1);
	outputChunked.endChunks();
	outputChunked.writeInt(2);
	outputChunked.endChunks();
	outputChunked.writeInt(3);
	outputChunked.endChunks();
	outputChunked.writeInt(4);
	outputChunked.endChunks();
	outputChunked.writeInt(5);
	outputChunked.endChunks();
	output.writeInt(5678);
	output.close();

	Input input = new Input(output.getBuffer());
	assertEquals(1234, input.readInt());
	InputChunked inputChunked = new InputChunked(input);
	assertEquals(1, inputChunked.readInt());
	inputChunked.nextChunks();
	inputChunked.nextChunks(); // skip 3
	assertEquals(3, inputChunked.readInt());
	inputChunked.nextChunks();
	inputChunked.nextChunks(); // skip 4
	assertEquals(5, inputChunked.readInt());
	assertEquals(5678, input.readInt());
	input.close();
}

开发者ID:esialb，
项目名称:kryo-mavenized，
代码行数:31，
代码来源:ChunkedTest.java

示例4: initialValue

​ 点赞 2 ​ 

import com.esotericsoftware.kryo.io.InputChunked; //导入依赖的package包/类
protected KryoContext initialValue() {
    Kryo kryo = newKryoInstance();
    OutputChunked output = new OutputChunked(BUFFER_SIZE);
    InputChunked input = new InputChunked(BUFFER_SIZE);
    return new KryoContext(kryo, input, output);
}

开发者ID:jerrinot，
项目名称:subzero，
代码行数:7，
代码来源:KryoStrategy.java

示例5: KryoContext

​ 点赞 2 ​ 

import com.esotericsoftware.kryo.io.InputChunked; //导入依赖的package包/类
KryoContext(Kryo kryo, InputChunked inputChunked, OutputChunked outputChunked) {
    this.kryo = kryo;
    this.inputChunked = inputChunked;
    this.outputChunked = outputChunked;
}

开发者ID:jerrinot，
项目名称:subzero，
代码行数:6，
代码来源:KryoContext.java

示例6: getInputChunked

​ 点赞 2 ​ 

import com.esotericsoftware.kryo.io.InputChunked; //导入依赖的package包/类
public InputChunked getInputChunked() {
    return inputChunked;
}

开发者ID:jerrinot，
项目名称:subzero，
代码行数:4，
代码来源:KryoContext.java

示例7: read

​ 点赞 2 ​ 

import com.esotericsoftware.kryo.io.InputChunked; //导入依赖的package包/类
public T read (Kryo kryo, Input input, Class<T> type) {
	T object = create(kryo, input, type);
	kryo.reference(object);
	ObjectMap context = kryo.getGraphContext();
	CachedField[] fields = (CachedField[])context.get(this);
	if (fields == null) {
		int length = input.readVarInt(true);
		if (TRACE) trace("kryo", "Read " + length + " field names.");
		String[] names = new String[length];
		for (int i = 0; i < length; i++)
			names[i] = input.readString();

		fields = new CachedField[length];
		CachedField[] allFields = getFields();
		outer:
		for (int i = 0, n = names.length; i < n; i++) {
			String schemaName = names[i];
			for (int ii = 0, nn = allFields.length; ii < nn; ii++) {
				if (allFields[ii].field.getName().equals(schemaName)) {
					fields[i] = allFields[ii];
					continue outer;
				}
			}
			if (TRACE) trace("kryo", "Ignore obsolete field: " + schemaName);
		}
		context.put(this, fields);
	}

	InputChunked inputChunked = new InputChunked(input, 1024);
	boolean hasGenerics = getGenerics() != null;
	for (int i = 0, n = fields.length; i < n; i++) {
		CachedField cachedField = fields[i];
		if(cachedField != null && hasGenerics) {
			// Generic type used to instantiate this field could have 
			// been changed in the meantime. Therefore take the most 
			// up-to-date definition of a field
			cachedField = getField(cachedField.field.getName());
		}
		if (cachedField == null) {
			if (TRACE) trace("kryo", "Skip obsolete field.");
			inputChunked.nextChunks();
			continue;
		}
		cachedField.read(inputChunked, object);
		inputChunked.nextChunks();
	}
	return object;
}

开发者ID:HoratiusTang，
项目名称:EsperDist，
代码行数:49，
代码来源:CompatibleFieldSerializer.java

示例8: read

​ 点赞 2 ​ 

import com.esotericsoftware.kryo.io.InputChunked; //导入依赖的package包/类
public Object read (Kryo kryo, Input input, Class type) {
	// The inflater would read from input beyond the compressed bytes if chunked enoding wasn't used.
	InflaterInputStream inflaterStream = new InflaterInputStream(new InputChunked(input, 256), new Inflater(noHeaders));
	return kryo.readObject(new Input(inflaterStream, 256), type, serializer);
}

开发者ID:HoratiusTang，
项目名称:EsperDist，
代码行数:6，
代码来源:DeflateSerializer.java

示例9: read

​ 点赞 2 ​ 

import com.esotericsoftware.kryo.io.InputChunked; //导入依赖的package包/类
public T read (Kryo kryo, Input input, Class<T> type) {
	T object = create(kryo, input, type);
	kryo.reference(object);
	ObjectMap context = kryo.getGraphContext();
	CachedField[] fields = (CachedField[])context.get(this);
	if (fields == null) {
		int length = input.readVarInt(true);
		if (TRACE) trace("kryo", "Read " + length + " field names.");
		String[] names = new String[length];
		for (int i = 0; i < length; i++)
			names[i] = input.readString();

		fields = new CachedField[length];
		CachedField[] allFields = getFields();
		outer:
		for (int i = 0, n = names.length; i < n; i++) {
			String schemaName = names[i];
			for (int ii = 0, nn = allFields.length; ii < nn; ii++) {
				if (allFields[ii].field.getName().equals(schemaName)) {
					fields[i] = allFields[ii];
					continue outer;
				}
			}
			if (TRACE) trace("kryo", "Ignore obsolete field: " + schemaName);
		}
		context.put(this, fields);
	}

	InputChunked inputChunked = new InputChunked(input, 1024);
	for (int i = 0, n = fields.length; i < n; i++) {
		CachedField cachedField = fields[i];
		if (cachedField == null) {
			if (TRACE) trace("kryo", "Skip obsolete field.");
			inputChunked.nextChunks();
			continue;
		}
		cachedField.read(inputChunked, object);
		inputChunked.nextChunks();
	}
	return object;
}

开发者ID:HoratiusTang，
项目名称:EsperDist，
代码行数:42，
代码来源:CompatibleFieldSerializer.java

示例10: test

​ 点赞 2 ​ 

import com.esotericsoftware.kryo.io.InputChunked; //导入依赖的package包/类
@Test
public void test()
		throws SchemaException {
	final Kryo kryo = new Kryo();

	kryo.register(
			SimpleFeatureImpl.class,
			new FeatureSerializer());

	final SimpleFeatureType schema = DataUtilities.createType(
			"testGeo",
			"location:Point:srid=4326,name:String");
	final List<AttributeDescriptor> descriptors = schema.getAttributeDescriptors();
	final Object[] defaults = new Object[descriptors.size()];
	int p = 0;
	for (final AttributeDescriptor descriptor : descriptors) {
		defaults[p++] = descriptor.getDefaultValue();
	}

	final SimpleFeature feature = SimpleFeatureBuilder.build(
			schema,
			defaults,
			UUID.randomUUID().toString());
	final GeometryFactory geoFactory = new GeometryFactory();

	feature.setAttribute(
			"location",
			geoFactory.createPoint(new Coordinate(
					-45,
					45)));
	final Output output = new OutputChunked();
	kryo.getSerializer(
			SimpleFeatureImpl.class).write(
			kryo,
			output,
			feature);
	final Input input = new InputChunked();
	input.setBuffer(output.getBuffer());
	final SimpleFeature f2 = (SimpleFeature) kryo.getSerializer(
			SimpleFeatureImpl.class).read(
			kryo,
			input,
			SimpleFeatureImpl.class);
	assertEquals(
			feature,
			f2);

}

开发者ID:locationtech，
项目名称:geowave，
代码行数:49，
代码来源:FeatureSerializationTest.java

版权声明：本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系管理员进行删除。
喜欢 (0)