ToCpp.java
上传用户:quxuerui
上传日期:2018-01-08
资源大小:41811k
文件大小:3k
源码类别:

网格计算

开发平台:

Java

  1. /**
  2.  * Licensed to the Apache Software Foundation (ASF) under one
  3.  * or more contributor license agreements.  See the NOTICE file
  4.  * distributed with this work for additional information
  5.  * regarding copyright ownership.  The ASF licenses this file
  6.  * to you under the Apache License, Version 2.0 (the
  7.  * "License"); you may not use this file except in compliance
  8.  * with the License.  You may obtain a copy of the License at
  9.  *
  10.  *     http://www.apache.org/licenses/LICENSE-2.0
  11.  *
  12.  * Unless required by applicable law or agreed to in writing, software
  13.  * distributed under the License is distributed on an "AS IS" BASIS,
  14.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15.  * See the License for the specific language governing permissions and
  16.  * limitations under the License.
  17.  */
  18. package org.apache.hadoop.record;
  19. import java.io.IOException;
  20. import junit.framework.*;
  21. import java.io.File;
  22. import java.io.FileOutputStream;
  23. import java.util.ArrayList;
  24. import java.util.TreeMap;
  25. /**
  26.  */
  27. public class ToCpp extends TestCase {
  28.     
  29.   public ToCpp(String testName) {
  30.     super(testName);
  31.   }
  32.   protected void setUp() throws Exception {
  33.   }
  34.   protected void tearDown() throws Exception {
  35.   }
  36.     
  37.   public void testBinary() {
  38.     File tmpfile;
  39.     try {
  40.       tmpfile = new File("/tmp/hadooptemp.dat");
  41.       FileOutputStream ostream = new FileOutputStream(tmpfile);
  42.       BinaryRecordOutput out = new BinaryRecordOutput(ostream);
  43.       RecRecord1 r1 = new RecRecord1();
  44.       r1.setBoolVal(true);
  45.       r1.setByteVal((byte)0x66);
  46.       r1.setFloatVal(3.145F);
  47.       r1.setDoubleVal(1.5234);
  48.       r1.setIntVal(4567);
  49.       r1.setLongVal(0x5a5a5a5a5a5aL);
  50.       r1.setStringVal("random text");
  51.       r1.setBufferVal(new Buffer());
  52.       r1.setVectorVal(new ArrayList<String>());
  53.       r1.setMapVal(new TreeMap<String,String>());
  54.       r1.serialize(out, "");
  55.       ostream.close();
  56.     } catch (IOException ex) {
  57.       ex.printStackTrace();
  58.     } 
  59.   }
  60.     
  61.   public void testCsv() {
  62.     File tmpfile;
  63.     try {
  64.       tmpfile = new File("/tmp/hadooptemp.txt");
  65.       FileOutputStream ostream = new FileOutputStream(tmpfile);
  66.       CsvRecordOutput out = new CsvRecordOutput(ostream);
  67.       RecRecord1 r1 = new RecRecord1();
  68.       r1.setBoolVal(true);
  69.       r1.setByteVal((byte)0x66);
  70.       r1.setFloatVal(3.145F);
  71.       r1.setDoubleVal(1.5234);
  72.       r1.setIntVal(4567);
  73.       r1.setLongVal(0x5a5a5a5a5a5aL);
  74.       r1.setStringVal("random text");
  75.       r1.setBufferVal(new Buffer());
  76.       r1.setVectorVal(new ArrayList<String>());
  77.       r1.setMapVal(new TreeMap<String,String>());
  78.       r1.serialize(out, "");
  79.       ostream.close();
  80.     } catch (IOException ex) {
  81.       ex.printStackTrace();
  82.     } 
  83.   }
  84.   public void testXml() {
  85.     File tmpfile;
  86.     try {
  87.       tmpfile = new File("/tmp/hadooptemp.xml");
  88.       FileOutputStream ostream = new FileOutputStream(tmpfile);
  89.       XmlRecordOutput out = new XmlRecordOutput(ostream);
  90.       RecRecord1 r1 = new RecRecord1();
  91.       r1.setBoolVal(true);
  92.       r1.setByteVal((byte)0x66);
  93.       r1.setFloatVal(3.145F);
  94.       r1.setDoubleVal(1.5234);
  95.       r1.setIntVal(4567);
  96.       r1.setLongVal(0x5a5a5a5a5a5aL);
  97.       r1.setStringVal("random text");
  98.       r1.setBufferVal(new Buffer());
  99.       r1.setVectorVal(new ArrayList<String>());
  100.       r1.setMapVal(new TreeMap<String,String>());
  101.       r1.serialize(out, "");
  102.       ostream.close();
  103.     } catch (IOException ex) {
  104.       ex.printStackTrace();
  105.     } 
  106.   }
  107. }