Module datarush.library

Package com.pervasive.datarush.ports.record

Class RecordMetadataTest

java.lang.Object

com.pervasive.datarush.ports.record.RecordMetadataTest

public class RecordMetadataTest
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RecordMetadataTest.Expectation
static class	RecordMetadataTest.GenericInputDefinition
static interface	RecordMetadataTest.InputDefinition
static class	RecordMetadataTest.OutputExpectation
static class	RecordMetadataTest.RecordInputDefinition
static class	RecordMetadataTest.RequiredExpectation

Constructor Summary

Constructors

Constructor	Description
RecordMetadataTest()

Method Summary

Modifier and Type	Method	Description
RecordMetadataTest	expect(RecordMetadataTest.Expectation... outputs)
static RecordMetadataTest.GenericInputDefinition	input(String name, PortMetadata type)
static RecordMetadataTest.RecordInputDefinition	input(String name, RecordTokenType type)
static RecordMetadataTest.OutputExpectation	output(String name)
RecordMetadataTest	provide(RecordMetadataTest.InputDefinition... inputs)
static RecordMetadataTest.RequiredExpectation	required(String name)
void	run(StreamingOperator plan)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RecordMetadataTest

public RecordMetadataTest()

Method Detail

output

public static RecordMetadataTest.OutputExpectation output(String name)

required

public static RecordMetadataTest.RequiredExpectation required(String name)

input

public static RecordMetadataTest.RecordInputDefinition input(String name,
                                                             RecordTokenType type)

input

public static RecordMetadataTest.GenericInputDefinition input(String name,
                                                              PortMetadata type)

provide

public RecordMetadataTest provide(RecordMetadataTest.InputDefinition... inputs)

expect

public RecordMetadataTest expect(RecordMetadataTest.Expectation... outputs)

run

public void run(StreamingOperator plan)