Fixed kotlin join.

This commit is contained in:
Alexander Nozik 2017-10-03 16:18:31 +03:00
parent 5a27f8bac4
commit d886163be4

View File

@ -8,6 +8,7 @@ package inr.numass.tasks;
import hep.dataforge.actions.GenericAction; import hep.dataforge.actions.GenericAction;
import hep.dataforge.cache.CachePlugin; import hep.dataforge.cache.CachePlugin;
import hep.dataforge.context.Context; import hep.dataforge.context.Context;
import hep.dataforge.data.CustomDataFilter;
import hep.dataforge.data.DataFilter; import hep.dataforge.data.DataFilter;
import hep.dataforge.data.DataNode; import hep.dataforge.data.DataNode;
import hep.dataforge.data.DataTree; import hep.dataforge.data.DataTree;
@ -42,7 +43,7 @@ public class NumassPrepareTask extends AbstractTask<Table> {
//acquiring initial data. Data node could not be empty //acquiring initial data. Data node could not be empty
DataFilter filter = new DataFilter(config.getMeta("data")); DataFilter filter = new CustomDataFilter(config.getMeta("data"));
DataNode<NumassSet> data = filter.filter(input.checked(NumassSet.class)); DataNode<NumassSet> data = filter.filter(input.checked(NumassSet.class));
@ -105,7 +106,7 @@ public class NumassPrepareTask extends AbstractTask<Table> {
// private DataSet.Builder<NumassData> readData(Work callback, Context context, URI numassRoot, Meta meta) { // private DataSet.Builder<NumassData> readData(Work callback, Context context, URI numassRoot, Meta meta) {
// //
// NumassStorage storage = NumassStorage.buildNumassRoot(numassRoot, true, false); // NumassStorage storage = NumassStorage.buildNumassRoot(numassRoot, true, false);
// DataFilter filter = new DataFilter().configure(meta); // CustomDataFilter filter = new CustomDataFilter().configure(meta);
// //
// boolean forwardOnly = meta.getBoolean("forwardOnly", false); // boolean forwardOnly = meta.getBoolean("forwardOnly", false);
// boolean reverseOnly = meta.getBoolean("reverseOnly", false); // boolean reverseOnly = meta.getBoolean("reverseOnly", false);