Java SnappyOutputStream类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

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

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

示例1: allFloatParameterCombinationsKnockout

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
@Test
public void allFloatParameterCombinationsKnockout() throws IOException {
    final List<float[]> fullData = loadFullFloatData();

    try (BufferedWriter noSplitWriter = openWriter("floats-knockout-nosplit");
         BufferedWriter splitWriter = openWriter("floats-knockout")) {
        for (float knockout : new float[] { 0f, 0.1f, 0.5f, 0.75f }) {
            final Random r = new Random(1337);
            final List<float[]> check = fullData.stream().map(xs -> {
                final float[] ys = xs.clone();
                for (int i = 0; i < ys.length; i++) {
                    if (r.nextDouble() < knockout) {
                        ys[i] = Float.NaN;
                    }
                }
                return ys;
            }).collect(Collectors.toList());

            allFloatParameterCombinationsWork(check, "Snappy\t" + knockout, SnappyOutputStream::new, SnappyInputStream::new, noSplitWriter, splitWriter);
        }
    }
}

开发者ID:batterseapower，项目名称:timeseries-compression，代码行数:23，代码来源:ConditionerParameterSearchTest.java

示例2: allDoubleParameterCombinationsKnockout

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
@Test
public void allDoubleParameterCombinationsKnockout() throws IOException {
    final List<double[]> fullData = loadFullDoubleData();

    try (BufferedWriter noSplitWriter = openWriter("doubles-knockout-nosplit");
         BufferedWriter splitWriter = openWriter("doubles-knockout")) {
        for (float knockout : new float[] { 0f, 0.1f, 0.5f, 0.75f }) {
            final Random r = new Random(1337);
            final List<double[]> check = fullData.stream().map(xs -> {
                final double[] ys = xs.clone();
                for (int i = 0; i < ys.length; i++) {
                    if (r.nextDouble() < knockout) {
                        ys[i] = Double.NaN;
                    }
                }
                return ys;
            }).collect(Collectors.toList());

            allDoubleParameterCombinationsWork(check, "Snappy\t" + knockout, SnappyOutputStream::new, SnappyInputStream::new, noSplitWriter, splitWriter);
        }
    }
}

开发者ID:batterseapower，项目名称:timeseries-compression，代码行数:23，代码来源:ConditionerParameterSearchTest.java

示例3: archiveState

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
@Nonnull
private static byte[] archiveState(@Nonnull Element state) {
  BufferExposingByteArrayOutputStream byteOut = new BufferExposingByteArrayOutputStream();
  try {
    OutputStreamWriter writer = new OutputStreamWriter(new SnappyOutputStream(byteOut), CharsetToolkit.UTF8_CHARSET);
    try {
      XMLOutputter xmlOutputter = new JDOMUtil.MyXMLOutputter();
      xmlOutputter.setFormat(XML_FORMAT);
      xmlOutputter.output(state, writer);
    }
    finally {
      writer.close();
    }
  }
  catch (IOException e) {
    throw new StateStorageException(e);
  }
  return ArrayUtil.realloc(byteOut.getInternalBuffer(), byteOut.size());
}

开发者ID:consulo，项目名称:consulo，代码行数:20，代码来源:StateMap.java

示例4: benchmark

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
@Test
public void benchmark() throws IOException {
    /*
    Snappy compress: 0.156672s
    Compressed to 10876881 bytes
    Uncompresses to 12908620 bytes
    Snappy decompress: 0.162463s

    Deflate Fastest compress: 6.017877s
    Compressed to 7770401 bytes
    Uncompresses to 12908620 bytes
    Deflate Fastest decompress: 4.260146s

    Deflate Slowest compress: 7.06043s
    Compressed to 7492001 bytes
    Uncompresses to 12908620 bytes
    Deflate Slowest decompress: 3.968221s

    Deflate Normal compress: 5.201332s
    Compressed to 7515522 bytes
    Uncompresses to 12908620 bytes
    Deflate Normal decompress: 4.056792s
     */
    benchmark("None",            x -> x,                                                                         x -> x);
    benchmark("None",            x -> x,                                                                         x -> x);
    benchmark("Snappy",          SnappyOutputStream::new,                                                        SnappyInputStream::new);
    benchmark("GZip",            GZIPOutputStream::new,                                                          GZIPInputStream::new);
    benchmark("Deflate Fastest", os -> new DeflaterOutputStream(os, new Deflater(Deflater.BEST_SPEED)),          InflaterInputStream::new);
    benchmark("Deflate Normal",  os -> new DeflaterOutputStream(os, new Deflater(Deflater.DEFAULT_COMPRESSION)), InflaterInputStream::new);
    benchmark("Deflate Slowest", os -> new DeflaterOutputStream(os, new Deflater(Deflater.BEST_COMPRESSION)),    InflaterInputStream::new);
    benchmark("BZip2 Fastest",   os -> new BZip2CompressorOutputStream(os, BZip2CompressorOutputStream.MIN_BLOCKSIZE), BZip2CompressorInputStream::new);
    benchmark("BZip2 Slowest",   os -> new BZip2CompressorOutputStream(os, BZip2CompressorOutputStream.MAX_BLOCKSIZE), BZip2CompressorInputStream::new);
    benchmark("XZ Fastest",      os -> new XZCompressorOutputStream(os, LZMA2Options.PRESET_MIN),                      XZCompressorInputStream::new);
    benchmark("XZ Normal",       os -> new XZCompressorOutputStream(os, LZMA2Options.PRESET_DEFAULT),                  XZCompressorInputStream::new);
    benchmark("XZ Slowest",      os -> new XZCompressorOutputStream(os, LZMA2Options.PRESET_MAX),                      XZCompressorInputStream::new);
}

开发者ID:batterseapower，项目名称:timeseries-compression，代码行数:37，代码来源:ConditionerParameterSearchTest.java

示例5: allFloatParameterCombinationsWork

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
@Test
public void allFloatParameterCombinationsWork() throws IOException {
    try (BufferedWriter noSplitWriter = openWriter("floats-nosplit");
         BufferedWriter splitWriter = openWriter("floats")) {
        allFloatParameterCombinationsWork(loadFullFloatData(), "Snappy", SnappyOutputStream::new,                                                              SnappyInputStream::new,          noSplitWriter, splitWriter);
        allFloatParameterCombinationsWork(loadFullFloatData(), "BZ2",    os -> new BZip2CompressorOutputStream(os, BZip2CompressorOutputStream.MIN_BLOCKSIZE), BZip2CompressorInputStream::new, noSplitWriter, splitWriter);
    }
}

开发者ID:batterseapower，项目名称:timeseries-compression，代码行数:9，代码来源:ConditionerParameterSearchTest.java

示例6: allDoubleParameterCombinationsWork

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
@Test
public void allDoubleParameterCombinationsWork() throws IOException {
    try (BufferedWriter noSplitWriter = openWriter("doubles-nosplit");
         BufferedWriter splitWriter = openWriter("doubles")) {
        allDoubleParameterCombinationsWork(loadFullDoubleData(), "Snappy", SnappyOutputStream::new,                                                              SnappyInputStream::new,          noSplitWriter, splitWriter);
        allDoubleParameterCombinationsWork(loadFullDoubleData(), "BZ2",    os -> new BZip2CompressorOutputStream(os, BZip2CompressorOutputStream.MIN_BLOCKSIZE), BZip2CompressorInputStream::new, noSplitWriter, splitWriter);
    }
}

开发者ID:batterseapower，项目名称:timeseries-compression，代码行数:9，代码来源:ConditionerParameterSearchTest.java

示例7: writeBlock

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
void writeBlock(int[] block, int blockNo, String name) throws Exception {
	String directory = index.cacheDir;
	File f = index.getFilesInterface().createFile(
			directory + File.separator + name + File.separator + blockNo);
	if (f.exists()) {
		File savedDir = index.getFilesInterface().createFile(
				directory + File.separator + "saved-" + name);
		savedDir.mkdirs();
		File savedF = index.getFilesInterface().createFile(
				directory + File.separator + "saved-" + name
						+ File.separator + blockNo);
		int i = 1;
		while (savedF.exists()) {
			savedF = index.getFilesInterface().createFile(
					directory + File.separator + "saved-" + name
							+ File.separator + blockNo + "-" + i++);
		}
		f.renameTo(savedF);
	}
	OutputStream writer = index.getFilesInterface().createOutputStream(f);
	DataOutputStream stream = new DataOutputStream(new SnappyOutputStream(
			writer));
	// writer);

	int sz = block[0];
	if (tmpBuffer.length < sz * 4) {
		tmpBuffer = new byte[sz * 4];
		intBuffer = ByteBuffer.wrap(tmpBuffer).asIntBuffer();
	}

	intBuffer.rewind();
	intBuffer.put(block, 0, sz);
	stream.write(tmpBuffer, 0, sz * 4);
	stream.close();
	writer.close();
	trimFile(f);
}

开发者ID:jrbn，项目名称:querypie，代码行数:38，代码来源:FirstLayer.java

示例8: createStream

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
private static FDataOutput createStream(File cacheFile)
		throws FileNotFoundException, IOException {
	cacheFile.deleteOnExit();

	OutputStream fout = new SnappyOutputStream(new BufferedOutputStream(
			new FileOutputStream(cacheFile)));
	return new FDataOutput(fout);
}

开发者ID:jrbn，项目名称:ajira，代码行数:9，代码来源:SortedBucketCache.java

示例9: saveContent

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
public void saveContent(@Nonnull String fileSpec, @Nonnull RoamingType roamingType, byte[] content, int size) throws IOException {
  UnsyncByteArrayOutputStream out = new UnsyncByteArrayOutputStream(size);
  try (SnappyOutputStream snappyOutputStream = new SnappyOutputStream(out)) {
    snappyOutputStream.write(content, 0, size);
  }

  byte[] compressedContent = out.toByteArray();

  myQueue.wantSave(myProxyDirectory, fileSpec, roamingType, compressedContent);
}

开发者ID:consulo，项目名称:consulo，代码行数:11，代码来源:ExternalStorage.java

示例10: init

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
@Override
public void init(File file) {
	try {
		os = new DataOutputStream(new SnappyOutputStream(
				new BufferedOutputStream(new FileOutputStream(file),
						65536)));
	} catch (Exception e) {
		log.error("Error", e);
	}
}

开发者ID:jrbn，项目名称:dynamite，代码行数:11，代码来源:TripleFileStorage.java

示例11: OutputStream

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
public OutputStream(java.io.OutputStream stream) throws IOException {
  myUnderlyingOutputStream = new SnappyOutputStream(stream);
  myOutputStream = new CompactDataOutput(myUnderlyingOutputStream);
}

开发者ID:jskierbi，项目名称:intellij-ce-playground，代码行数:5，代码来源:OutputInfoSerializer.java

示例12: snappy

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
@Benchmark
public int snappy() throws IOException {
    return benchmark(SnappyOutputStream::new,                                                        SnappyInputStream::new);
}

开发者ID:batterseapower，项目名称:timeseries-compression，代码行数:5，代码来源:JMHCompressorTest.java

示例13: output

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
@Override
public OutputStream output(OutputStream out) throws IOException {
    return new SnappyOutputStream(out);
}

开发者ID:yammer，项目名称:backups，代码行数:5，代码来源:SnappyCompressionCodec.java

示例14: writeListBlockToFile

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
void writeListBlockToFile(ListBlocks b, int no, boolean writeBlocks)
		throws Exception {
	String name = "lb-" + no;
	File file = index.getFilesInterface().createFile(
			index.cacheDir + "/" + name);
	if (!file.mkdirs() && (!file.exists() || !file.isDirectory())) {
		log.warn(index.cacheDir + File.separator + name
				+ ": could not create");
		/*
		 * Don't make this a fatal error ... --Ceriel throw new
		 * IOException("Could not create" + index.cacheDir + File.separator
		 * + name);
		 */
	}
	file = index.getFilesInterface().createFile(
			index.cacheDir + "/" + name + "/index");
	if (log.isDebugEnabled()) {
		log.debug("write index of ListBlock " + index.cacheDir + "/" + name);
	}
	if (file.exists()) {
		File savedDir = index.getFilesInterface().createFile(
				index.cacheDir + "/" + "saved-" + name);
		savedDir.mkdirs();
		File savedF = index.getFilesInterface().createFile(
				index.cacheDir + "/" + "saved-" + name + "/index");
		int i = 1;
		while (savedF.exists()) {
			savedF = index.getFilesInterface().createFile(
					index.cacheDir + "/" + "saved-" + name + "/index-"
							+ i++);
		}
		file.renameTo(savedF);
	}
	OutputStream writer = index.getFilesInterface()
			.createOutputStream(file);
	DataOutputStream stream = new DataOutputStream(new SnappyOutputStream(
			writer));
	// writer);
	b.writeTo(stream, writeBlocks);
	stream.flush();
	stream.close();
	writer.flush();
	writer.close();
	trimFile(file);
}

开发者ID:jrbn，项目名称:querypie，代码行数:46，代码来源:FirstLayer.java

示例15: wrapOutputStream

import org.iq80.snappy.SnappyOutputStream; //导入依赖的package包/类
protected OutputStream wrapOutputStream(OutputStream underlying) throws IOException {
    return new SnappyOutputStream(underlying);
}

开发者ID:we7，项目名称:voldemort，代码行数:4，代码来源:SnappyCompressionStrategy.java

注：本文中的org.iq80.snappy.SnappyOutputStream类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java ScriptAssert类代码示例发布时间：2022-05-23

Java Role类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18818|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9871|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8283|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8640|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8569|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9573|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8565|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7959|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8567|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7496|2022-11-06

客服电话

电子邮件

Java SnappyOutputStream类代码示例

示例1: allFloatParameterCombinationsKnockout

示例2: allDoubleParameterCombinationsKnockout

示例3: archiveState

示例4: benchmark

示例5: allFloatParameterCombinationsWork

示例6: allDoubleParameterCombinationsWork

示例7: writeBlock

示例8: createStream

示例9: saveContent

示例10: init

示例11: OutputStream

示例12: snappy

示例13: output

示例14: writeListBlockToFile

示例15: wrapOutputStream

请发表评论

全部评论

上一篇：

下一篇：

GitbookIO/gitbook:

juleswhite/mobile-cloud-asgn1

kyamagu/matlab-json: Use official API: h

墙壁眼睛膝盖

sevenjay/cpp-markdown: Cpp-Markdown is a

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053