Package ai.pipestream.data.v1

Interface NodeProcessingConfigOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
NodeProcessingConfig, NodeProcessingConfig.Builder
@Generated public interface NodeProcessingConfigOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Details

    • getNodeId

      String getNodeId()
       Node identifier for this configuration.
      string node_id = 1 [json_name = "nodeId"];
      Returns:
      The nodeId.

    • getNodeIdBytes

      com.google.protobuf.ByteString getNodeIdBytes()
       Node identifier for this configuration.
      string node_id = 1 [json_name = "nodeId"];
      Returns:
      The bytes for nodeId.

    • getPreMappingsList

      List<ProcessingMapping> getPreMappingsList()
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • getPreMappings

      ProcessingMapping getPreMappings(int index)
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • getPreMappingsCount

      int getPreMappingsCount()
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • getPreMappingsOrBuilderList

      List<? extends ProcessingMappingOrBuilder> getPreMappingsOrBuilderList()
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • getPreMappingsOrBuilder

      ProcessingMappingOrBuilder getPreMappingsOrBuilder(int index)
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • getPostMappingsList

      List<ProcessingMapping> getPostMappingsList()
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • getPostMappings

      ProcessingMapping getPostMappings(int index)
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • getPostMappingsCount

      int getPostMappingsCount()
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • getPostMappingsOrBuilderList

      List<? extends ProcessingMappingOrBuilder> getPostMappingsOrBuilderList()
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • getPostMappingsOrBuilder

      ProcessingMappingOrBuilder getPostMappingsOrBuilder(int index)
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • getIntentValue

      int getIntentValue()
       Processing intent for this record.
      .ai.pipestream.data.v1.Intent intent = 4 [json_name = "intent"];
      Returns:
      The enum numeric value on the wire for intent.

    • getIntent

      Intent getIntent()
       Processing intent for this record.
      .ai.pipestream.data.v1.Intent intent = 4 [json_name = "intent"];
      Returns:
      The intent.

    • hasNodeConfig

      boolean hasNodeConfig()
       Node-specific custom configuration.
      .google.protobuf.Any node_config = 5 [json_name = "nodeConfig"];
      Returns:
      Whether the nodeConfig field is set.

    • getNodeConfig

      com.google.protobuf.Any getNodeConfig()
       Node-specific custom configuration.
      .google.protobuf.Any node_config = 5 [json_name = "nodeConfig"];
      Returns:
      The nodeConfig.

    • getNodeConfigOrBuilder

      com.google.protobuf.AnyOrBuilder getNodeConfigOrBuilder()
       Node-specific custom configuration.
      .google.protobuf.Any node_config = 5 [json_name = "nodeConfig"];

    • getFilterCondition

      String getFilterCondition()
       CEL expression to filter documents before node processing.

 When this expression evaluates to false, the document skips this node
 and proceeds to the next node in the pipeline without processing.

 Available context variables:
 - document: The PipeDoc being processed
 - stream: The PipeStream object (metadata, history, etc.)

 Example expressions:
 - "document.search_metadata.language == 'en'"
 - "stream.metadata.context_params['skip_ocr'] == 'true'"
 - "document.search_metadata.content_length > 100"
      string filter_condition = 6 [json_name = "filterCondition"];
      Returns:
      The filterCondition.

    • getFilterConditionBytes

      com.google.protobuf.ByteString getFilterConditionBytes()
       CEL expression to filter documents before node processing.

 When this expression evaluates to false, the document skips this node
 and proceeds to the next node in the pipeline without processing.

 Available context variables:
 - document: The PipeDoc being processed
 - stream: The PipeStream object (metadata, history, etc.)

 Example expressions:
 - "document.search_metadata.language == 'en'"
 - "stream.metadata.context_params['skip_ocr'] == 'true'"
 - "document.search_metadata.content_length > 100"
      string filter_condition = 6 [json_name = "filterCondition"];
      Returns:
      The bytes for filterCondition.

    • getSaveOnError

      boolean getSaveOnError()
       Whether to save the document to the repository even if processing fails.

 When true, the document is persisted to the repository (S3) even if the node
 processing encounters an error. This is useful for debugging and reprocessing
 failed documents later.
      bool save_on_error = 7 [json_name = "saveOnError"];
      Returns:
      The saveOnError.