1. import java.io.File;
  2. import java.io.IOException;
  3. import java.util.ArrayList;
  4. import java.util.List;
  5. import java.util.concurrent.atomic.AtomicInteger;
  7. public class DirectoryDataFilter {
  9. private final File rootDir;
  10. private final int maxRetries;
  11. private final AtomicInteger retryCount = new AtomicInteger(0);
  13. public DirectoryDataFilter(File rootDir, int maxRetries) {
  14. this.rootDir = rootDir;
  15. this.maxRetries = maxRetries;
  16. }
  18. public List<String> filterData() throws IOException {
  19. List<String> filteredData = new ArrayList<>();
  20. File[] files = rootDir.listFiles();
  22. if (files != null) {
  23. for (File file : files) {
  24. try {
  25. String data = processFile(file); // Process each file
  26. if (data != null && !data.isEmpty()) {
  27. filteredData.add(file.getAbsolutePath() + ": " + data);
  28. }
  29. } catch (IOException e) {
  30. if (retryCount.get() < maxRetries) {
  31. retryCount.incrementAndGet();
  32. try {
  33. System.err.println("Retry processing " + file.getName() + " (attempt " + retryCount.get() + ")");
  34. processFile(file); // Retry processing
  35. } catch (IOException retryException) {
  36. System.err.println("Failed to process " + file.getName() + " after " + maxRetries + " retries.");
  37. // Handle failure - e.g., log, skip, or throw an exception
  38. }
  39. } else {
  40. System.err.println("Failed to process " + file.getName() + " after " + maxRetries + " retries.");
  41. // Handle failure - e.g., log, skip, or throw an exception
  42. }
  43. }
  44. }
  45. }
  46. return filteredData;
  47. }
  49. private String processFile(File file) throws IOException {
  50. // Simulate data processing - replace with your actual logic
  51. if (file.getName().endsWith(".txt")) {
  52. return "Data from " + file.getName();
  53. } else if (file.getName().endsWith(".log")) {
  54. return "Log data from " + file.getName();
  55. } else {
  56. return null; // Return null if file type is not supported
  57. }
  58. }
  61. public static void main(String[] args) throws IOException {
  62. // Example usage:
  63. File rootDirectory = new File("test_dir"); // Replace with your directory
  64. File[] files = new File[] { rootDirectory, rootDirectory.mkdir() };
  66. // Create some dummy files
  67. File file1 = new File(rootDirectory, "file1.txt");
  68. File file2 = new File(rootDirectory, "file2.log");
  69. File file3 = new File(rootDirectory, "file3.csv");
  71. file1.writeText("This is file1 data.");
  72. file2.writeText("This is log data.");
  73. file3.writeText("This is csv data.");
  76. DirectoryDataFilter filter = new DirectoryDataFilter(rootDirectory, 3); // Retry 3 times
  77. List<String> data = filter.filterData();
  79. for (String item : data) {
  80. System.out.println(item);
  81. }
  82. }
  83. }

Add your comment