Package ai.pipestream.data.v1

Class NodeProcessingConfig

java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
ai.pipestream.data.v1.NodeProcessingConfig
All Implemented Interfaces:
NodeProcessingConfigOrBuilder, com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable
@Generated public final class NodeProcessingConfig extends com.google.protobuf.GeneratedMessage 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
See Also:

  • Field Details

    • NODE_ID_FIELD_NUMBER

      public static final int NODE_ID_FIELD_NUMBER
      See Also:

    • PRE_MAPPINGS_FIELD_NUMBER

      public static final int PRE_MAPPINGS_FIELD_NUMBER
      See Also:

    • POST_MAPPINGS_FIELD_NUMBER

      public static final int POST_MAPPINGS_FIELD_NUMBER
      See Also:

    • INTENT_FIELD_NUMBER

      public static final int INTENT_FIELD_NUMBER
      See Also:

    • NODE_CONFIG_FIELD_NUMBER

      public static final int NODE_CONFIG_FIELD_NUMBER
      See Also:

    • FILTER_CONDITION_FIELD_NUMBER

      public static final int FILTER_CONDITION_FIELD_NUMBER
      See Also:

    • SAVE_ON_ERROR_FIELD_NUMBER

      public static final int SAVE_ON_ERROR_FIELD_NUMBER
      See Also:

  • 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

    • 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.

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • isInitialized

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

    • writeTo

      public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
      Specified by:
      writeTo in interface com.google.protobuf.MessageLite
      Overrides:
      writeTo in class com.google.protobuf.GeneratedMessage
      Throws:
      IOException

    • getSerializedSize

      public int getSerializedSize()
      Specified by:
      getSerializedSize in interface com.google.protobuf.MessageLite
      Overrides:
      getSerializedSize in class com.google.protobuf.GeneratedMessage

    • equals

      public boolean equals(Object obj)
      Specified by:
      equals in interface com.google.protobuf.Message
      Overrides:
      equals in class com.google.protobuf.AbstractMessage

    • hashCode

      public int hashCode()
      Specified by:
      hashCode in interface com.google.protobuf.Message
      Overrides:
      hashCode in class com.google.protobuf.AbstractMessage

    • parseFrom

      public static NodeProcessingConfig parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static NodeProcessingConfig parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static NodeProcessingConfig parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static NodeProcessingConfig parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static NodeProcessingConfig parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static NodeProcessingConfig parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static NodeProcessingConfig parseFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static NodeProcessingConfig parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static NodeProcessingConfig parseDelimitedFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static NodeProcessingConfig parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseFrom

      public static NodeProcessingConfig parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static NodeProcessingConfig parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • newBuilderForType

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

    • newBuilder

      public static NodeProcessingConfig.Builder newBuilder()

    • newBuilder

      public static NodeProcessingConfig.Builder newBuilder(NodeProcessingConfig prototype)

    • toBuilder

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

    • newBuilderForType

      protected NodeProcessingConfig.Builder newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)
      Overrides:
      newBuilderForType in class com.google.protobuf.AbstractMessage

    • getDefaultInstance

      public static NodeProcessingConfig getDefaultInstance()

    • parser

      public static com.google.protobuf.Parser<NodeProcessingConfig> parser()

    • getParserForType

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

    • getDefaultInstanceForType

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