@@ -59,6 +59,8 @@ public DefaultNodeModule(final Context context, final ModuleInfo info,
5959 }
6060
6161 // FIXME: do we need them all?
62+ // FIXME add our own preprocessors, i.e. to call preprocess?
63+ // FIXME or move this to "preprocess"
6264 final List <PreprocessorPlugin > pre = ps
6365 .createInstancesOfType (PreprocessorPlugin .class );
6466
@@ -77,6 +79,7 @@ public DefaultNodeModule(final Context context, final ModuleInfo info,
7779 }
7880
7981 private void preProcess (final DataRow input ) throws Exception {
82+ // input can be null if source node
8083 if (input != null ) {
8184 for (final Entry <Integer , ModuleItem <?>> entry : inputMapping
8285 .entrySet ()) {
@@ -90,6 +93,7 @@ private void preProcess(final DataRow input) throws Exception {
9093
9194 private void postProcess (final CellOutput output ,
9295 final ExecutionContext ctx ) throws Exception {
96+ // output can be null if sink node
9397 if (output != null ) {
9498 final List <DataCell > cells = new ArrayList <DataCell >();
9599 for (final ModuleItem <?> entry : module .getInfo ().outputs ()) {
@@ -109,6 +113,8 @@ private void postProcess(final CellOutput output,
109113 @ Override
110114 public void run (final DataRow input , final CellOutput output ,
111115 final ExecutionContext ctx ) throws Exception {
116+
117+ // FIXME: Nicer logic possible here?
112118 preProcess (input );
113119
114120 if (outputListener != null ) {
0 commit comments