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:

Stream topologies documentation, Microbatch topologies documentation

Method Summary

Modifier and Type	Method and Description
PState.Declaration	pstate(java.lang.String pstateVar, java.lang.Class schema) Declares a PState owned by this topology.
PState.Declaration	pstate(java.lang.String pstateVar, PState.Schema schema) Declares a PState owned by this topology.
Block.OutImpl	source(java.lang.String depotVar) Add depot source to topology
Block.OutImpl	source(java.lang.String depotVar, T options) Add depot source with specified options to topology

Method Detail

pstate

PState.Declaration pstate(java.lang.String pstateVar,
                          java.lang.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:

PStates documentation

pstate

PState.Declaration pstate(java.lang.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:

PStates documentation

source

Block.OutImpl source(java.lang.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:

Depots documentation

source

Block.OutImpl source(java.lang.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:

Depots documentation