FSFileSplitter & BlockReader are available in com.datatorrent.lib.io.fs package.
On Thu, May 5, 2016 at 10:47 AM, Chandni Singh <[email protected]> wrote: > Ok. What is specific about the fileSplitter and blockReader returned by > this implementation? > > > On May 4, 2016 9:43 PM, "Chaitanya Chebolu" <[email protected]> > wrote: > > > Hi Chandni, > > > > Properties wise nothing specific. FS Input Module is an abstract Module > and > > NFS Module implements the abstract methods - createFileSplitter() and > > createBlockReader(). > > > > Regards, > > Chaitanya > > > > On Wed, May 4, 2016 at 9:45 PM, Chandni Singh <[email protected]> > > wrote: > > > > > Hi Chaitanya, > > > > > > What will be specific in NFS Input Module that is not provided by FS > > Input > > > Module? > > > > > > Thanks, > > > Chandni > > > > > > On Wed, May 4, 2016 at 7:12 AM, Amol Kekre <[email protected]> > wrote: > > > > > > > +1 > > > > > > > > Thks > > > > Amol > > > > > > > > On Tue, May 3, 2016 at 10:06 PM, Sandeep Deshmukh < > > > [email protected] > > > > > > > > > wrote: > > > > > > > > > +1 > > > > > > > > > > Regards, > > > > > Sandeep > > > > > > > > > > On Fri, Apr 29, 2016 at 3:26 PM, Mohit Jotwani < > > [email protected]> > > > > > wrote: > > > > > > > > > > > +1 > > > > > > > > > > > > Regards, > > > > > > Mohit > > > > > > > > > > > > On Fri, Apr 29, 2016 at 2:09 PM, Chaitanya Chebolu < > > > > > > [email protected]> wrote: > > > > > > > > > > > > > Hi All, > > > > > > > > > > > > > > I am proposing NFS Input Module. Use case is to read large > > files > > > > from > > > > > > NFS > > > > > > > in parallel. > > > > > > > > > > > > > > Design of NFS input module: > > > > > > > > > > > > > > There is a common interface "FSInputModule" in Malhar for > the > > > > input > > > > > > > Modules. NFS input Module extends from FSInputModule and can be > > > > > achieved > > > > > > by > > > > > > > using FSFileSplitter and BlockReader operators. > > > > > > > > > > > > > > Please share your thoughts on this. > > > > > > > > > > > > > > Regards, > > > > > > > Chaitanya > > > > > > > > > > > > > > > > > > > > > > > > > > > >
