A system and method, are provided for structuring batch activities for
simplified reconfiguration. A series of processing steps is prepared for
performing on input objects being streamed into a batch processing system.
Each of the processing steps is encapsulated within at least one of a
plurality of filters. The input objects are received and processed in the
filters. Results are delivered from the filters incrementally during the
processing of the input objects for reducing latency and enabling parallel
processing. Connectors are utilized for connecting at least two of the
plurality of filters each having a processing step for creating a process.
One of the two filters is an input filter of the process and the other of
the two filters is an output filter of the process. Connectors are also
used for connecting input and output filters of different processes for
forming a scalable system.
Um sistema e um método, são fornecidos para atividades estruturando do grupo para o reconfiguration simplificado. Uma série de etapas processando é preparada executando nos objetos da entrada que estão sendo fluídos em um sistema processando de grupo. Cada uma das etapas processando encapsulated dentro ao menos de um de um plurality dos filtros. Os objetos da entrada são recebidos e processados nos filtros. Os resultados são entregados dos filtros incremental durante processar dos objetos da entrada para reduzir a latência e permitir processar paralelo. Os conectores são utilizados conectando ao menos dois do plurality dos filtros cada um que tem uma etapa processando para criar um processo. Um dos dois filtros é um filtro da entrada do processo e os outros dos dois filtros são um filtro da saída do processo. Os conectores são usados também conectando filtros da entrada e da saída de processos diferentes para dar forma a um sistema scalable.
