Class HdfsSpoutTopology


  • public class HdfsSpoutTopology
    extends Object
    • Constructor Detail

      • HdfsSpoutTopology

        public HdfsSpoutTopology()
    • Method Detail

      • main

        public static void main​(String[] args)
                         throws Exception
        Copies text file content from sourceDir to destinationDir. Moves source files into sourceDir after its done consuming
        Throws:
        Exception