org.pentaho.di.cluster
Class PartitioningTest

java.lang.Object
  junit.framework.Assert
      junit.framework.TestCase
          org.pentaho.di.cluster.BaseCluster
              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