Package ai.pipestream.data.v1

Class NodeProcessingConfig.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<NodeProcessingConfig.Builder>
com.google.protobuf.GeneratedMessage.Builder<NodeProcessingConfig.Builder>
ai.pipestream.data.v1.NodeProcessingConfig.Builder
All Implemented Interfaces:
NodeProcessingConfigOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
NodeProcessingConfig
public static final class NodeProcessingConfig.Builder extends com.google.protobuf.GeneratedMessage.Builder<NodeProcessingConfig.Builder> implements NodeProcessingConfigOrBuilder
 Node-specific processing configuration.

 Defines pre/post mappings, filtering, and custom configuration for a processing node.
Protobuf type ai.pipestream.data.v1.NodeProcessingConfig

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<NodeProcessingConfig.Builder>

    • clear

      public NodeProcessingConfig.Builder clear()
      Specified by:
      clear in interface com.google.protobuf.Message.Builder
      Specified by:
      clear in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      clear in class com.google.protobuf.GeneratedMessage.Builder<NodeProcessingConfig.Builder>

    • getDescriptorForType

      public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
      Specified by:
      getDescriptorForType in interface com.google.protobuf.Message.Builder
      Specified by:
      getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
      Overrides:
      getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<NodeProcessingConfig.Builder>

    • getDefaultInstanceForType

      public NodeProcessingConfig getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

    • build

      public NodeProcessingConfig build()
      Specified by:
      build in interface com.google.protobuf.Message.Builder
      Specified by:
      build in interface com.google.protobuf.MessageLite.Builder

    • buildPartial

      public NodeProcessingConfig buildPartial()
      Specified by:
      buildPartial in interface com.google.protobuf.Message.Builder
      Specified by:
      buildPartial in interface com.google.protobuf.MessageLite.Builder

    • mergeFrom

      public NodeProcessingConfig.Builder mergeFrom(com.google.protobuf.Message other)
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<NodeProcessingConfig.Builder>

    • mergeFrom

      public NodeProcessingConfig.Builder mergeFrom(NodeProcessingConfig other)

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage.Builder<NodeProcessingConfig.Builder>

    • mergeFrom

      public NodeProcessingConfig.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Specified by:
      mergeFrom in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<NodeProcessingConfig.Builder>
      Throws:
      IOException

    • getNodeId

      public String getNodeId()
       Node identifier for this configuration.
      string node_id = 1 [json_name = "nodeId"];
      Specified by:
      getNodeId in interface NodeProcessingConfigOrBuilder
      Returns:
      The nodeId.

    • getNodeIdBytes

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

    • setNodeId

      public NodeProcessingConfig.Builder setNodeId(String value)
       Node identifier for this configuration.
      string node_id = 1 [json_name = "nodeId"];
      Parameters:
      value - The nodeId to set.
      Returns:
      This builder for chaining.

    • clearNodeId

      public NodeProcessingConfig.Builder clearNodeId()
       Node identifier for this configuration.
      string node_id = 1 [json_name = "nodeId"];
      Returns:
      This builder for chaining.

    • setNodeIdBytes

      public NodeProcessingConfig.Builder setNodeIdBytes(com.google.protobuf.ByteString value)
       Node identifier for this configuration.
      string node_id = 1 [json_name = "nodeId"];
      Parameters:
      value - The bytes for nodeId to set.
      Returns:
      This builder for chaining.

    • getPreMappingsList

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

    • getPreMappingsCount

      public int getPreMappingsCount()
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];
      Specified by:
      getPreMappingsCount in interface NodeProcessingConfigOrBuilder

    • getPreMappings

      public ProcessingMapping getPreMappings(int index)
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];
      Specified by:
      getPreMappings in interface NodeProcessingConfigOrBuilder

    • setPreMappings

      public NodeProcessingConfig.Builder setPreMappings(int index, ProcessingMapping value)
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • setPreMappings

      public NodeProcessingConfig.Builder setPreMappings(int index, ProcessingMapping.Builder builderForValue)
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • addPreMappings

      public NodeProcessingConfig.Builder addPreMappings(ProcessingMapping value)
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • addPreMappings

      public NodeProcessingConfig.Builder addPreMappings(int index, ProcessingMapping value)
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • addPreMappings

      public NodeProcessingConfig.Builder addPreMappings(ProcessingMapping.Builder builderForValue)
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • addPreMappings

      public NodeProcessingConfig.Builder addPreMappings(int index, ProcessingMapping.Builder builderForValue)
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • addAllPreMappings

      public NodeProcessingConfig.Builder addAllPreMappings(Iterable<? extends ProcessingMapping> values)
       Field mappings applied before node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping pre_mappings = 2 [json_name = "preMappings"];

    • clearPreMappings

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

    • removePreMappings

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

    • getPreMappingsBuilder

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

    • getPreMappingsOrBuilder

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

    • getPreMappingsOrBuilderList

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

    • addPreMappingsBuilder

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

    • addPreMappingsBuilder

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

    • getPreMappingsBuilderList

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

    • getPostMappingsList

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

    • getPostMappingsCount

      public int getPostMappingsCount()
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];
      Specified by:
      getPostMappingsCount in interface NodeProcessingConfigOrBuilder

    • getPostMappings

      public ProcessingMapping getPostMappings(int index)
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];
      Specified by:
      getPostMappings in interface NodeProcessingConfigOrBuilder

    • setPostMappings

      public NodeProcessingConfig.Builder setPostMappings(int index, ProcessingMapping value)
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • setPostMappings

      public NodeProcessingConfig.Builder setPostMappings(int index, ProcessingMapping.Builder builderForValue)
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • addPostMappings

      public NodeProcessingConfig.Builder addPostMappings(ProcessingMapping value)
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • addPostMappings

      public NodeProcessingConfig.Builder addPostMappings(int index, ProcessingMapping value)
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • addPostMappings

      public NodeProcessingConfig.Builder addPostMappings(ProcessingMapping.Builder builderForValue)
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • addPostMappings

      public NodeProcessingConfig.Builder addPostMappings(int index, ProcessingMapping.Builder builderForValue)
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • addAllPostMappings

      public NodeProcessingConfig.Builder addAllPostMappings(Iterable<? extends ProcessingMapping> values)
       Field mappings applied after node processing.
      repeated .ai.pipestream.data.v1.ProcessingMapping post_mappings = 3 [json_name = "postMappings"];

    • clearPostMappings

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

    • removePostMappings

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

    • getPostMappingsBuilder

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

    • getPostMappingsOrBuilder

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

    • getPostMappingsOrBuilderList

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

    • addPostMappingsBuilder

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

    • addPostMappingsBuilder

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

    • getPostMappingsBuilderList

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

    • getIntentValue

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

    • setIntentValue

      public NodeProcessingConfig.Builder setIntentValue(int value)
       Processing intent for this record.
      .ai.pipestream.data.v1.Intent intent = 4 [json_name = "intent"];
      Parameters:
      value - The enum numeric value on the wire for intent to set.
      Returns:
      This builder for chaining.

    • getIntent

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

    • setIntent

      public NodeProcessingConfig.Builder setIntent(Intent value)
       Processing intent for this record.
      .ai.pipestream.data.v1.Intent intent = 4 [json_name = "intent"];
      Parameters:
      value - The intent to set.
      Returns:
      This builder for chaining.

    • clearIntent

      public NodeProcessingConfig.Builder clearIntent()
       Processing intent for this record.
      .ai.pipestream.data.v1.Intent intent = 4 [json_name = "intent"];
      Returns:
      This builder for chaining.

    • hasNodeConfig

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

    • getNodeConfig

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

    • setNodeConfig

      public NodeProcessingConfig.Builder setNodeConfig(com.google.protobuf.Any value)
       Node-specific custom configuration.
      .google.protobuf.Any node_config = 5 [json_name = "nodeConfig"];

    • setNodeConfig

      public NodeProcessingConfig.Builder setNodeConfig(com.google.protobuf.Any.Builder builderForValue)
       Node-specific custom configuration.
      .google.protobuf.Any node_config = 5 [json_name = "nodeConfig"];

    • mergeNodeConfig

      public NodeProcessingConfig.Builder mergeNodeConfig(com.google.protobuf.Any value)
       Node-specific custom configuration.
      .google.protobuf.Any node_config = 5 [json_name = "nodeConfig"];

    • clearNodeConfig

      public NodeProcessingConfig.Builder clearNodeConfig()
       Node-specific custom configuration.
      .google.protobuf.Any node_config = 5 [json_name = "nodeConfig"];

    • getNodeConfigBuilder

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

    • getNodeConfigOrBuilder

      public com.google.protobuf.AnyOrBuilder getNodeConfigOrBuilder()
       Node-specific custom configuration.
      .google.protobuf.Any node_config = 5 [json_name = "nodeConfig"];
      Specified by:
      getNodeConfigOrBuilder in interface NodeProcessingConfigOrBuilder

    • getFilterCondition

      public 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"];
      Specified by:
      getFilterCondition in interface NodeProcessingConfigOrBuilder
      Returns:
      The filterCondition.

    • getFilterConditionBytes

      public 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"];
      Specified by:
      getFilterConditionBytes in interface NodeProcessingConfigOrBuilder
      Returns:
      The bytes for filterCondition.

    • setFilterCondition

      public NodeProcessingConfig.Builder setFilterCondition(String value)
       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"];
      Parameters:
      value - The filterCondition to set.
      Returns:
      This builder for chaining.

    • clearFilterCondition

      public NodeProcessingConfig.Builder clearFilterCondition()
       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:
      This builder for chaining.

    • setFilterConditionBytes

      public NodeProcessingConfig.Builder setFilterConditionBytes(com.google.protobuf.ByteString value)
       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"];
      Parameters:
      value - The bytes for filterCondition to set.
      Returns:
      This builder for chaining.

    • getSaveOnError

      public 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"];
      Specified by:
      getSaveOnError in interface NodeProcessingConfigOrBuilder
      Returns:
      The saveOnError.

    • setSaveOnError

      public NodeProcessingConfig.Builder setSaveOnError(boolean value)
       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"];
      Parameters:
      value - The saveOnError to set.
      Returns:
      This builder for chaining.

    • clearSaveOnError

      public NodeProcessingConfig.Builder clearSaveOnError()
       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:
      This builder for chaining.