Package 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 Details

    • stream

      StreamTopology stream(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(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(String topologyName, 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