Package com.rpl.rama.module

Interface ETLTopologyBase<T>

All Known Subinterfaces:
MicrobatchTopology, StreamTopology
public interface ETLTopologyBase<T>
Base interface for stream and microbatch topologies
See Also:

  • Method Details

    • pstate

      PState.Declaration pstate(String pstateVar, Class schema)
      Declares a PState owned by this topology. Only owning topology can write to a PState.
      Parameters:
      pstateVar - Var to reference PState within module code. Also name of PState for fetching clients with RamaClusterManager or InProcessCluster.
      schema - Schema of PState
      Returns:
      Builder-style object for adding options to the PState
      See Also:

    • pstate

      PState.Declaration pstate(String pstateVar, PState.Schema schema)
      Declares a PState owned by this topology. Only owning topology can write to a PState.
      Parameters:
      pstateVar - Var to reference PState within module code. Also name of PState for fetching clients with RamaClusterManager or InProcessCluster.
      schema - Schema of PState
      Returns:
      Builder-style object for adding options to the PState
      See Also:

    • source

      Block.OutImpl source(String depotVar)
      Add depot source to topology
      Parameters:
      depotVar - Depot to source data from
      Returns:
      Block to add implementation code for this ETL
      See Also:

    • source

      Block.OutImpl source(String depotVar, T options)
      Add depot source with specified options to topology
      Parameters:
      depotVar - Depot to source data from
      Returns:
      Block to add implementation code for this ETL
      See Also: