org.pentaho.di.cluster
Class PartitioningTest

java.lang.Object
  extended by junit.framework.Assert
      extended by junit.framework.TestCase
          extended by org.pentaho.di.cluster.BaseCluster
              extended by org.pentaho.di.cluster.PartitioningTest
All Implemented Interfaces:
junit.framework.Test

public class PartitioningTest
extends BaseCluster


Constructor Summary
PartitioningTest()
           
 
Method Summary
 void testPartitioningRepartitioningOnCluster()
          This test reads a CSV file in parallel on the cluster, one copy per slave.
It then partitions the data on id in 12 partitions (4 per slave).
After that it re-partitions the data in 9 partitions (3 per slave).
As such we expect 9 result files on disk.
File: "partitioning-repartitioning-on-cluster.ktr"
 void testPartitioningSwimmingLanesOnCluster()
          This test reads a CSV file in parallel on the cluster, one copy per slave.
It then partitions the data on id in 12 partitions (4 per slave) and keeps the data partitioned until written to file.
As such we expect 12 files on disk.
File: "partitioning-swimming-lanes-on-cluster.ktr"
 
Methods inherited from class org.pentaho.di.cluster.BaseCluster
createClusteredTransExecutionConfiguration, loadAndModifyTestTransformation, loadFileContent
 
Methods inherited from class junit.framework.TestCase
countTestCases, getName, run, run, runBare, setName, toString
 
Methods inherited from class junit.framework.Assert
assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, fail, fail, failNotEquals, failNotSame, failSame, format
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

PartitioningTest

public PartitioningTest()
Method Detail

testPartitioningSwimmingLanesOnCluster

public void testPartitioningSwimmingLanesOnCluster()
                                            throws Exception
This test reads a CSV file in parallel on the cluster, one copy per slave.
It then partitions the data on id in 12 partitions (4 per slave) and keeps the data partitioned until written to file.
As such we expect 12 files on disk.
File: "partitioning-swimming-lanes-on-cluster.ktr"

Throws:
Exception

testPartitioningRepartitioningOnCluster

public void testPartitioningRepartitioningOnCluster()
                                             throws Exception
This test reads a CSV file in parallel on the cluster, one copy per slave.
It then partitions the data on id in 12 partitions (4 per slave).
After that it re-partitions the data in 9 partitions (3 per slave).
As such we expect 9 result files on disk.
File: "partitioning-repartitioning-on-cluster.ktr"

Throws:
Exception