List of addAttributeFromKVRecord() Examples

Examples of addAttributeFromKVRecord()

eu.stratosphere.test.recordJobs.util.Tuple.addAttributeFromKVRecord()
Appends an attribute by copying it from another tuple. @param other The other tuple to copy from. @param column The index of the attribute to copy within the other tuple.
org.apache.flink.test.recordJobs.util.Tuple.addAttributeFromKVRecord()
Appends an attribute by copying it from another tuple. @param other The other tuple to copy from. @param column The index of the attribute to copy within the other tuple.

Examples of eu.stratosphere.test.recordJobs.util.Tuple.addAttributeFromKVRecord()

    
    Tuple t2 = new Tuple();
    
    Assert.assertTrue(t2.getNumberOfColumns() == 0);
    
    t2.addAttributeFromKVRecord(t1, 1);
    Assert.assertTrue(t2.getNumberOfColumns() == 1);
    Assert.assertTrue(t2.getLongValueAt(0) == 123345);
    Assert.assertTrue(t2.getBytes().length == 256);
    
    t2.compact();

View Full Code Here

Examples of eu.stratosphere.test.recordJobs.util.Tuple.addAttributeFromKVRecord()

    Assert.assertTrue(t2.getLongValueAt(0) == 123345);
    Assert.assertTrue(t2.getBytes().length == 256);
    
    t2.compact();


    t2.addAttributeFromKVRecord(t1, 2);
    Assert.assertTrue(t2.getNumberOfColumns() == 2);
    byte[] ret = t2.getByteArrayValueAt(1);
    Assert.assertTrue(ret.length == "adfasdfg".getBytes().length);
    for(int i=0;i<ret.length;i++) {
      Assert.assertTrue(ret[i] == "adfasdfg".getBytes()[i]);

View Full Code Here

Examples of eu.stratosphere.test.recordJobs.util.Tuple.addAttributeFromKVRecord()

    for(int i=0;i<ret.length;i++) {
      Assert.assertTrue(ret[i] == "adfasdfg".getBytes()[i]);
    }
    Assert.assertTrue(t2.getBytes().length == 16);
    
    t2.addAttributeFromKVRecord(t1, 0);
    Assert.assertTrue(t2.getNumberOfColumns() == 3);
    Assert.assertTrue(t2.getStringValueAt(2).equals("a"));
    Assert.assertTrue(t2.getBytes().length == 18);
    
  }

View Full Code Here

Examples of org.apache.flink.test.recordJobs.util.Tuple.addAttributeFromKVRecord()

    
    Tuple t2 = new Tuple();
    
    Assert.assertTrue(t2.getNumberOfColumns() == 0);
    
    t2.addAttributeFromKVRecord(t1, 1);
    Assert.assertTrue(t2.getNumberOfColumns() == 1);
    Assert.assertTrue(t2.getLongValueAt(0) == 123345);
    Assert.assertTrue(t2.getBytes().length == 256);
    
    t2.compact();

View Full Code Here

Examples of org.apache.flink.test.recordJobs.util.Tuple.addAttributeFromKVRecord()

    Assert.assertTrue(t2.getLongValueAt(0) == 123345);
    Assert.assertTrue(t2.getBytes().length == 256);
    
    t2.compact();


    t2.addAttributeFromKVRecord(t1, 2);
    Assert.assertTrue(t2.getNumberOfColumns() == 2);
    byte[] ret = t2.getByteArrayValueAt(1);
    Assert.assertTrue(ret.length == "adfasdfg".getBytes().length);
    for(int i=0;i<ret.length;i++) {
      Assert.assertTrue(ret[i] == "adfasdfg".getBytes()[i]);

View Full Code Here

Examples of org.apache.flink.test.recordJobs.util.Tuple.addAttributeFromKVRecord()

    for(int i=0;i<ret.length;i++) {
      Assert.assertTrue(ret[i] == "adfasdfg".getBytes()[i]);
    }
    Assert.assertTrue(t2.getBytes().length == 16);
    
    t2.addAttributeFromKVRecord(t1, 0);
    Assert.assertTrue(t2.getNumberOfColumns() == 3);
    Assert.assertTrue(t2.getStringValueAt(2).equals("a"));
    Assert.assertTrue(t2.getBytes().length == 18);
    
  }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.