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

网格计算

开发平台:

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.File;
  20. import java.io.FileInputStream;
  21. import java.io.IOException;
  22. import java.util.ArrayList;
  23. import java.util.TreeMap;
  24. import junit.framework.*;
  25. /**
  26.  */
  27. public class FromCpp extends TestCase {
  28.     
  29.   public FromCpp(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("/temp/hadooptmp.dat");
  41.       RecRecord1 r1 = new RecRecord1();
  42.       r1.setBoolVal(true);
  43.       r1.setByteVal((byte)0x66);
  44.       r1.setFloatVal(3.145F);
  45.       r1.setDoubleVal(1.5234);
  46.       r1.setIntVal(4567);
  47.       r1.setLongVal(0x5a5a5a5a5a5aL);
  48.       r1.setStringVal("random text");
  49.       r1.setBufferVal(new Buffer());
  50.       r1.setVectorVal(new ArrayList<String>());
  51.       r1.setMapVal(new TreeMap<String,String>());
  52.       FileInputStream istream = new FileInputStream(tmpfile);
  53.       BinaryRecordInput in = new BinaryRecordInput(istream);
  54.       RecRecord1 r2 = new RecRecord1();
  55.       r2.deserialize(in, "");
  56.       istream.close();
  57.       assertTrue(r1.equals(r2));
  58.     } catch (IOException ex) {
  59.       ex.printStackTrace();
  60.     } 
  61.   }
  62.     
  63.   public void testCsv() {
  64.     File tmpfile;
  65.     try {
  66.       tmpfile = new File("/temp/hadooptmp.txt");
  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.       FileInputStream istream = new FileInputStream(tmpfile);
  79.       CsvRecordInput in = new CsvRecordInput(istream);
  80.       RecRecord1 r2 = new RecRecord1();
  81.       r2.deserialize(in, "");
  82.       istream.close();
  83.       assertTrue(r1.equals(r2));
  84.     } catch (IOException ex) {
  85.       ex.printStackTrace();
  86.     } 
  87.   }
  88.   public void testXml() {
  89.     File tmpfile;
  90.     try {
  91.       tmpfile = new File("/temp/hadooptmp.xml");
  92.       RecRecord1 r1 = new RecRecord1();
  93.       r1.setBoolVal(true);
  94.       r1.setByteVal((byte)0x66);
  95.       r1.setFloatVal(3.145F);
  96.       r1.setDoubleVal(1.5234);
  97.       r1.setIntVal(4567);
  98.       r1.setLongVal(0x5a5a5a5a5a5aL);
  99.       r1.setStringVal("random text");
  100.       r1.setBufferVal(new Buffer());
  101.       r1.setVectorVal(new ArrayList<String>());
  102.       r1.setMapVal(new TreeMap<String,String>());
  103.       FileInputStream istream = new FileInputStream(tmpfile);
  104.       XmlRecordInput in = new XmlRecordInput(istream);
  105.       RecRecord1 r2 = new RecRecord1();
  106.       r2.deserialize(in, "");
  107.       istream.close();
  108.       assertTrue(r1.equals(r2));
  109.     } catch (IOException ex) {
  110.       ex.printStackTrace();
  111.     } 
  112.   }
  113. }