A method (300, 400) for managing loading of data from a source onto a database, said method comprising: providing (302, 402) an interface through which a user is to define logic related to the loading of the data onto the database, wherein the user-defined logic pertains to a user-defined location identification of the source, a user-defined filter to be applied on the data, and a parsing operation to be performed on the data to convert the data into an appropriate format for the database; receiving (304, 404) the user-defined logic; and implementing (306, 412), by a processor, the user-defined logic to load the data onto the database, the method characterized in that: implementing the user-defined logic further comprises implementing the user-defined logic in a system that manages the database, wherein the system that manages the database comprises a distributed database system; implementing the user-defined logic further comprises implementing the user-defined logic on a plurality of database machines in the distributed database system; and in that the method comprises providing: an input buffer to process a portion of the data as the data is streamed from the source; and an output buffer to which the portion of the data processed by the input buffer is writable. providing (302, 402) an interface through which a user is to define logic related to the loading of the data onto the database, wherein the user-defined logic pertains to a user-defined location identification of the source, a user-defined filter to be applied on the data, and a parsing operation to be performed on the data to convert the data into an appropriate format for the database; receiving (304, 404) the user-defined logic; and implementing (306, 412), by a processor, the user-defined logic to load the data onto the database, the method characterized in that: implementing the user-defined logic further comprises implementing the user-defined logic in a system that manages the database, wherein the system that manages the database comprises a distributed database system; implementing the user-defined logic further comprises implementing the user-defined logic on a plurality of database machines in the distributed database system; and in that the method comprises providing: an input buffer to process a portion of the data as the data is streamed from the source; and an output buffer to which the portion of the data processed by the input buffer is writable. implementing the user-defined logic further comprises implementing the user-defined logic in a system that manages the database, wherein the system that manages the database comprises a distributed database system; implementing the user-defined logic further comprises implementing the user-defined logic on a plurality of database machines in the distributed database system; and in that the method comprises providing: an input buffer to process a portion of the data as the data is streamed from the source; and an output buffer to which the portion of the data processed by the input buffer is writable. an input buffer to process a portion of the data as the data is streamed from the source; and an output buffer to which the portion of the data processed by the input buffer is writable.