Uses of Class
org.apache.flume.shared.kafka.test.PartitionTestScenario

Packages that use PartitionTestScenario

Package	Description
org.apache.flume.shared.kafka.test

Uses of PartitionTestScenario in org.apache.flume.shared.kafka.test

Methods in org.apache.flume.shared.kafka.test that return PartitionTestScenario

Modifier and Type	Method and Description
static PartitionTestScenario	PartitionTestScenario.valueOf(String name) Returns the enum constant of this type with the specified name.
static PartitionTestScenario[]	PartitionTestScenario.values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.flume.shared.kafka.test with parameters of type PartitionTestScenario

Modifier and Type	Method and Description
static void	KafkaPartitionTestUtil.checkResultsAgainstSkew(PartitionTestScenario scenario, Map<Integer,List<Event>> partitionMap, Map<Integer,List<byte[]>> resultsMap, int staticPtn, int numMsgs) This method checks the retrieved messages (passed as resultsMap) against the expected results (passed as partitionMap).
static List<Event>	KafkaPartitionTestUtil.generateSkewedMessageList(PartitionTestScenario scenario, int numMsgs, Map<Integer,List<Event>> partitionMap, int numPtns, int staticPtn) This method is can be used to create a list of events for use in Kafka partition tests.