Package ai.pipestream.data.v1

Class IngestionConfig.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<IngestionConfig.Builder>
com.google.protobuf.GeneratedMessage.Builder<IngestionConfig.Builder>
ai.pipestream.data.v1.IngestionConfig.Builder
All Implemented Interfaces:
IngestionConfigOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
IngestionConfig
public static final class IngestionConfig.Builder extends com.google.protobuf.GeneratedMessage.Builder<IngestionConfig.Builder> implements IngestionConfigOrBuilder
 Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged) that
 controls how a document is processed through the pipeline. Built by
 connector-intake-service and passed to the engine via StreamMetadata.
Protobuf type ai.pipestream.data.v1.IngestionConfig

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

    • clear

      public IngestionConfig.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<IngestionConfig.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<IngestionConfig.Builder>

    • getDefaultInstanceForType

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

    • build

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

    • buildPartial

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

    • mergeFrom

      public IngestionConfig.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<IngestionConfig.Builder>

    • mergeFrom

      public IngestionConfig.Builder mergeFrom(IngestionConfig other)

    • isInitialized

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

    • mergeFrom

      public IngestionConfig.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<IngestionConfig.Builder>
      Throws:
      IOException

    • getIngressModeValue

      public int getIngressModeValue()
       How the document entered the pipeline.
      .ai.pipestream.data.v1.IngressMode ingress_mode = 1 [json_name = "ingressMode"];
      Specified by:
      getIngressModeValue in interface IngestionConfigOrBuilder
      Returns:
      The enum numeric value on the wire for ingressMode.

    • setIngressModeValue

      public IngestionConfig.Builder setIngressModeValue(int value)
       How the document entered the pipeline.
      .ai.pipestream.data.v1.IngressMode ingress_mode = 1 [json_name = "ingressMode"];
      Parameters:
      value - The enum numeric value on the wire for ingressMode to set.
      Returns:
      This builder for chaining.

    • getIngressMode

      public IngressMode getIngressMode()
       How the document entered the pipeline.
      .ai.pipestream.data.v1.IngressMode ingress_mode = 1 [json_name = "ingressMode"];
      Specified by:
      getIngressMode in interface IngestionConfigOrBuilder
      Returns:
      The ingressMode.

    • setIngressMode

      public IngestionConfig.Builder setIngressMode(IngressMode value)
       How the document entered the pipeline.
      .ai.pipestream.data.v1.IngressMode ingress_mode = 1 [json_name = "ingressMode"];
      Parameters:
      value - The ingressMode to set.
      Returns:
      This builder for chaining.

    • clearIngressMode

      public IngestionConfig.Builder clearIngressMode()
       How the document entered the pipeline.
      .ai.pipestream.data.v1.IngressMode ingress_mode = 1 [json_name = "ingressMode"];
      Returns:
      This builder for chaining.

    • hasHydrationConfig

      public boolean hasHydrationConfig()
       Hydration policy for blob handling during processing.

 Resolved from Tier 1 (DataSource) + Tier 2 (DatasourceInstance) config.
      .ai.pipestream.data.v1.HydrationConfig hydration_config = 2 [json_name = "hydrationConfig"];
      Specified by:
      hasHydrationConfig in interface IngestionConfigOrBuilder
      Returns:
      Whether the hydrationConfig field is set.

    • getHydrationConfig

      public HydrationConfig getHydrationConfig()
       Hydration policy for blob handling during processing.

 Resolved from Tier 1 (DataSource) + Tier 2 (DatasourceInstance) config.
      .ai.pipestream.data.v1.HydrationConfig hydration_config = 2 [json_name = "hydrationConfig"];
      Specified by:
      getHydrationConfig in interface IngestionConfigOrBuilder
      Returns:
      The hydrationConfig.

    • setHydrationConfig

      public IngestionConfig.Builder setHydrationConfig(HydrationConfig value)
       Hydration policy for blob handling during processing.

 Resolved from Tier 1 (DataSource) + Tier 2 (DatasourceInstance) config.
      .ai.pipestream.data.v1.HydrationConfig hydration_config = 2 [json_name = "hydrationConfig"];

    • setHydrationConfig

      public IngestionConfig.Builder setHydrationConfig(HydrationConfig.Builder builderForValue)
       Hydration policy for blob handling during processing.

 Resolved from Tier 1 (DataSource) + Tier 2 (DatasourceInstance) config.
      .ai.pipestream.data.v1.HydrationConfig hydration_config = 2 [json_name = "hydrationConfig"];

    • mergeHydrationConfig

      public IngestionConfig.Builder mergeHydrationConfig(HydrationConfig value)
       Hydration policy for blob handling during processing.

 Resolved from Tier 1 (DataSource) + Tier 2 (DatasourceInstance) config.
      .ai.pipestream.data.v1.HydrationConfig hydration_config = 2 [json_name = "hydrationConfig"];

    • clearHydrationConfig

      public IngestionConfig.Builder clearHydrationConfig()
       Hydration policy for blob handling during processing.

 Resolved from Tier 1 (DataSource) + Tier 2 (DatasourceInstance) config.
      .ai.pipestream.data.v1.HydrationConfig hydration_config = 2 [json_name = "hydrationConfig"];

    • getHydrationConfigBuilder

      public HydrationConfig.Builder getHydrationConfigBuilder()
       Hydration policy for blob handling during processing.

 Resolved from Tier 1 (DataSource) + Tier 2 (DatasourceInstance) config.
      .ai.pipestream.data.v1.HydrationConfig hydration_config = 2 [json_name = "hydrationConfig"];

    • getHydrationConfigOrBuilder

      public HydrationConfigOrBuilder getHydrationConfigOrBuilder()
       Hydration policy for blob handling during processing.

 Resolved from Tier 1 (DataSource) + Tier 2 (DatasourceInstance) config.
      .ai.pipestream.data.v1.HydrationConfig hydration_config = 2 [json_name = "hydrationConfig"];
      Specified by:
      getHydrationConfigOrBuilder in interface IngestionConfigOrBuilder

    • hasOutputHints

      public boolean hasOutputHints()
       Routing hints for downstream processing.

 From Tier 2 (DatasourceInstance) config - specifies target collection
 and other routing hints for modules.
      .ai.pipestream.data.v1.OutputHints output_hints = 3 [json_name = "outputHints"];
      Specified by:
      hasOutputHints in interface IngestionConfigOrBuilder
      Returns:
      Whether the outputHints field is set.

    • getOutputHints

      public OutputHints getOutputHints()
       Routing hints for downstream processing.

 From Tier 2 (DatasourceInstance) config - specifies target collection
 and other routing hints for modules.
      .ai.pipestream.data.v1.OutputHints output_hints = 3 [json_name = "outputHints"];
      Specified by:
      getOutputHints in interface IngestionConfigOrBuilder
      Returns:
      The outputHints.

    • setOutputHints

      public IngestionConfig.Builder setOutputHints(OutputHints value)
       Routing hints for downstream processing.

 From Tier 2 (DatasourceInstance) config - specifies target collection
 and other routing hints for modules.
      .ai.pipestream.data.v1.OutputHints output_hints = 3 [json_name = "outputHints"];

    • setOutputHints

      public IngestionConfig.Builder setOutputHints(OutputHints.Builder builderForValue)
       Routing hints for downstream processing.

 From Tier 2 (DatasourceInstance) config - specifies target collection
 and other routing hints for modules.
      .ai.pipestream.data.v1.OutputHints output_hints = 3 [json_name = "outputHints"];

    • mergeOutputHints

      public IngestionConfig.Builder mergeOutputHints(OutputHints value)
       Routing hints for downstream processing.

 From Tier 2 (DatasourceInstance) config - specifies target collection
 and other routing hints for modules.
      .ai.pipestream.data.v1.OutputHints output_hints = 3 [json_name = "outputHints"];

    • clearOutputHints

      public IngestionConfig.Builder clearOutputHints()
       Routing hints for downstream processing.

 From Tier 2 (DatasourceInstance) config - specifies target collection
 and other routing hints for modules.
      .ai.pipestream.data.v1.OutputHints output_hints = 3 [json_name = "outputHints"];

    • getOutputHintsBuilder

      public OutputHints.Builder getOutputHintsBuilder()
       Routing hints for downstream processing.

 From Tier 2 (DatasourceInstance) config - specifies target collection
 and other routing hints for modules.
      .ai.pipestream.data.v1.OutputHints output_hints = 3 [json_name = "outputHints"];

    • getOutputHintsOrBuilder

      public OutputHintsOrBuilder getOutputHintsOrBuilder()
       Routing hints for downstream processing.

 From Tier 2 (DatasourceInstance) config - specifies target collection
 and other routing hints for modules.
      .ai.pipestream.data.v1.OutputHints output_hints = 3 [json_name = "outputHints"];
      Specified by:
      getOutputHintsOrBuilder in interface IngestionConfigOrBuilder

    • hasCustomConfig

      public boolean hasCustomConfig()
       Connector-specific custom configuration.

 Merged from Tier 1 + Tier 2 custom_config fields. This is the only
 configuration that uses JSON Schema validation (connector-specific).
      .google.protobuf.Struct custom_config = 4 [json_name = "customConfig"];
      Specified by:
      hasCustomConfig in interface IngestionConfigOrBuilder
      Returns:
      Whether the customConfig field is set.

    • getCustomConfig

      public com.google.protobuf.Struct getCustomConfig()
       Connector-specific custom configuration.

 Merged from Tier 1 + Tier 2 custom_config fields. This is the only
 configuration that uses JSON Schema validation (connector-specific).
      .google.protobuf.Struct custom_config = 4 [json_name = "customConfig"];
      Specified by:
      getCustomConfig in interface IngestionConfigOrBuilder
      Returns:
      The customConfig.

    • setCustomConfig

      public IngestionConfig.Builder setCustomConfig(com.google.protobuf.Struct value)
       Connector-specific custom configuration.

 Merged from Tier 1 + Tier 2 custom_config fields. This is the only
 configuration that uses JSON Schema validation (connector-specific).
      .google.protobuf.Struct custom_config = 4 [json_name = "customConfig"];

    • setCustomConfig

      public IngestionConfig.Builder setCustomConfig(com.google.protobuf.Struct.Builder builderForValue)
       Connector-specific custom configuration.

 Merged from Tier 1 + Tier 2 custom_config fields. This is the only
 configuration that uses JSON Schema validation (connector-specific).
      .google.protobuf.Struct custom_config = 4 [json_name = "customConfig"];

    • mergeCustomConfig

      public IngestionConfig.Builder mergeCustomConfig(com.google.protobuf.Struct value)
       Connector-specific custom configuration.

 Merged from Tier 1 + Tier 2 custom_config fields. This is the only
 configuration that uses JSON Schema validation (connector-specific).
      .google.protobuf.Struct custom_config = 4 [json_name = "customConfig"];

    • clearCustomConfig

      public IngestionConfig.Builder clearCustomConfig()
       Connector-specific custom configuration.

 Merged from Tier 1 + Tier 2 custom_config fields. This is the only
 configuration that uses JSON Schema validation (connector-specific).
      .google.protobuf.Struct custom_config = 4 [json_name = "customConfig"];

    • getCustomConfigBuilder

      public com.google.protobuf.Struct.Builder getCustomConfigBuilder()
       Connector-specific custom configuration.

 Merged from Tier 1 + Tier 2 custom_config fields. This is the only
 configuration that uses JSON Schema validation (connector-specific).
      .google.protobuf.Struct custom_config = 4 [json_name = "customConfig"];

    • getCustomConfigOrBuilder

      public com.google.protobuf.StructOrBuilder getCustomConfigOrBuilder()
       Connector-specific custom configuration.

 Merged from Tier 1 + Tier 2 custom_config fields. This is the only
 configuration that uses JSON Schema validation (connector-specific).
      .google.protobuf.Struct custom_config = 4 [json_name = "customConfig"];
      Specified by:
      getCustomConfigOrBuilder in interface IngestionConfigOrBuilder