Package org.apache.nifi.processors.standard

Class GetFTP

java.lang.Object
org.apache.nifi.components.AbstractConfigurableComponent
org.apache.nifi.processor.AbstractSessionFactoryProcessor
org.apache.nifi.processor.AbstractProcessor
org.apache.nifi.processor.util.file.transfer.GetFileTransfer
org.apache.nifi.processors.standard.GetFTP
All Implemented Interfaces:
org.apache.nifi.components.ConfigurableComponent, org.apache.nifi.processor.Processor
@InputRequirement(INPUT_FORBIDDEN) @Tags({"FTP","get","retrieve","files","fetch","remote","ingest","source","input"}) @CapabilityDescription("Fetches files from an FTP Server and creates FlowFiles from them") @WritesAttribute(attribute="filename",description="The filename is set to the name of the file on the remote server") @WritesAttribute(attribute="path",description="The path is set to the path of the file\'s directory on the remote server. For example, if the <Remote Path> property is set to /tmp, files picked up from /tmp will have the path attribute set to /tmp. If the <Search Recursively> property is set to true and a file is picked up from /tmp/abc/1/2/3, then the path attribute will be set to /tmp/abc/1/2/3") @WritesAttribute(attribute="file.lastModifiedTime",description="The date and time that the source file was last modified") @WritesAttribute(attribute="file.lastAccessTime",description="The date and time that the file was last accessed. May not work on all file systems") @WritesAttribute(attribute="file.owner",description="The numeric owner id of the source file") @WritesAttribute(attribute="file.group",description="The numeric group id of the source file") @WritesAttribute(attribute="file.permissions",description="The read/write/execute permissions of the source file") @WritesAttribute(attribute="absolute.path",description="The full/absolute path from where a file was picked up. The current \'path\' attribute is still populated, but may be a relative path") @SeeAlso(PutFTP.class) public class GetFTP extends GetFileTransfer

  • Field Details

    • PROPERTY_DESCRIPTORS

      private static final List<org.apache.nifi.components.PropertyDescriptor> PROPERTY_DESCRIPTORS

  • Constructor Details

    • GetFTP

      public GetFTP()

  • Method Details

    • getSupportedPropertyDescriptors

      protected List<org.apache.nifi.components.PropertyDescriptor> getSupportedPropertyDescriptors()
      Overrides:
      getSupportedPropertyDescriptors in class org.apache.nifi.components.AbstractConfigurableComponent

    • migrateProperties

      public void migrateProperties(PropertyConfiguration config)

    • getFileTransfer

      protected FileTransfer getFileTransfer(org.apache.nifi.processor.ProcessContext context)
      Specified by:
      getFileTransfer in class GetFileTransfer

    • customValidate

      protected Collection<org.apache.nifi.components.ValidationResult> customValidate(org.apache.nifi.components.ValidationContext validationContext)
      Overrides:
      customValidate in class org.apache.nifi.components.AbstractConfigurableComponent