com.rpl.rama

Interface RamaModule.Topologies

Enclosing interface:

RamaModule

public static interface RamaModule.Topologies

Used to define ETL and query topologies in a module definition.

Method Summary

Modifier and Type	Method and Description
MicrobatchTopology	microbatch(java.lang.String topologyName) Defines a microbatch topology.
Block.Out	query(java.lang.String topologyName, java.lang.String... inputVars) Defines a query topology.
StreamTopology	stream(java.lang.String topologyName) Defines a stream topology.

Method Detail

stream

StreamTopology stream(java.lang.String topologyName)

Defines a stream topology. Each ETL topology defines PStates and dataflow code to source data from depots to update those PStates.

Parameters:

topologyName - The name of the topology. Must be unique to the module.

Returns:

Builder-style object for specifying the PStates and dataflow code for the topology

microbatch

MicrobatchTopology microbatch(java.lang.String topologyName)

Defines a microbatch topology. Each ETL topology defines PStates and dataflow code to source data from depots to update those PStates.

Parameters:

topologyName - The name of the topology. Must be unique to the module.

Returns:

Builder-style object for specifying the PStates and dataflow code for the topology

query

Block.Out query(java.lang.String topologyName,
                java.lang.String... inputVars)

Defines a query topology. Query topologies are implicitly batch blocks.

Parameters:

topologyName - The name of the topology. Must be unique to the module.

inputVars - Declaration of input arguments

Returns:

Block object for adding dataflow code that implements the query topology