Class PipelineTopologyProperties


  • public final class PipelineTopologyProperties
    extends Object
    Pipeline topology properties.
    • Constructor Detail

      • PipelineTopologyProperties

        public PipelineTopologyProperties()
    • Method Detail

      • getDescription

        public String getDescription()
        Get the description property: An optional description of the pipeline topology. It is recommended that the expected use of the topology to be described here.
        Returns:
        the description value.
      • setDescription

        public PipelineTopologyProperties setDescription​(String description)
        Set the description property: An optional description of the pipeline topology. It is recommended that the expected use of the topology to be described here.
        Parameters:
        description - the description value to set.
        Returns:
        the PipelineTopologyProperties object itself.
      • getParameters

        public List<ParameterDeclaration> getParameters()
        Get the parameters property: List of the topology parameter declarations. Parameters declared here can be referenced throughout the topology nodes through the use of "${PARAMETER_NAME}" string pattern. Parameters can have optional default values and can later be defined in individual instances of the pipeline.
        Returns:
        the parameters value.
      • setParameters

        public PipelineTopologyProperties setParameters​(List<ParameterDeclaration> parameters)
        Set the parameters property: List of the topology parameter declarations. Parameters declared here can be referenced throughout the topology nodes through the use of "${PARAMETER_NAME}" string pattern. Parameters can have optional default values and can later be defined in individual instances of the pipeline.
        Parameters:
        parameters - the parameters value to set.
        Returns:
        the PipelineTopologyProperties object itself.
      • getSources

        public List<SourceNodeBase> getSources()
        Get the sources property: List of the topology source nodes. Source nodes enable external data to be ingested by the pipeline.
        Returns:
        the sources value.
      • setSources

        public PipelineTopologyProperties setSources​(List<SourceNodeBase> sources)
        Set the sources property: List of the topology source nodes. Source nodes enable external data to be ingested by the pipeline.
        Parameters:
        sources - the sources value to set.
        Returns:
        the PipelineTopologyProperties object itself.
      • getProcessors

        public List<ProcessorNodeBase> getProcessors()
        Get the processors property: List of the topology processor nodes. Processor nodes enable pipeline data to be analyzed, processed or transformed.
        Returns:
        the processors value.
      • setProcessors

        public PipelineTopologyProperties setProcessors​(List<ProcessorNodeBase> processors)
        Set the processors property: List of the topology processor nodes. Processor nodes enable pipeline data to be analyzed, processed or transformed.
        Parameters:
        processors - the processors value to set.
        Returns:
        the PipelineTopologyProperties object itself.
      • getSinks

        public List<SinkNodeBase> getSinks()
        Get the sinks property: List of the topology sink nodes. Sink nodes allow pipeline data to be stored or exported.
        Returns:
        the sinks value.
      • setSinks

        public PipelineTopologyProperties setSinks​(List<SinkNodeBase> sinks)
        Set the sinks property: List of the topology sink nodes. Sink nodes allow pipeline data to be stored or exported.
        Parameters:
        sinks - the sinks value to set.
        Returns:
        the PipelineTopologyProperties object itself.