val dftpServer = new DftpServer()
  .setAuthHandler(new AuthenticatedProvider)
  .setServiceHandler(new DftpServiceHandler)
  .setProtocolSchema("dftp")  // Custom protocol schema

// Anonymous login
val dftpClient = DftpClient.connect("dftp://ip:3101", Credentials.ANONYMOUS)

// Username/password login
val dftpClient = DftpClient.connect(
"dftp://ip:3101",
UsernamePassword("user", "password")
)

// Get DataFrame from resource
val df = dftpClient.get("dftp://ip:3101/resourcePath")

// Transformations
val dfMap = df.map(row => row._1).limit(10)

val dfFilter = df.filter(row => row._1 > 100).limit(10)

val dfSelect = df.select("col0", "col1").limit(10)

// Actions
df.collect()  // Retrieve all data
df.foreach(row => process(row))  // Process each row