File tree Expand file tree Collapse file tree 2 files changed +3
-0
lines changed
metafacture-mangling/src/main
java/org/metafacture/mangling Expand file tree Collapse file tree 2 files changed +3
-0
lines changed Original file line number Diff line number Diff line change 15
15
*/
16
16
package org .metafacture .mangling ;
17
17
18
+ import org .metafacture .framework .FluxCommand ;
18
19
import org .metafacture .framework .StreamReceiver ;
19
20
import org .metafacture .framework .annotations .Description ;
20
21
import org .metafacture .framework .annotations .In ;
31
32
@ Description ("Discards or replaces null values" )
32
33
@ In (StreamReceiver .class )
33
34
@ Out (StreamReceiver .class )
35
+ @ FluxCommand ("filter-null-values" )
34
36
public final class NullFilter extends ForwardingStreamPipe {
35
37
36
38
private String replacement = null ;
Original file line number Diff line number Diff line change 14
14
# limitations under the License.
15
15
#
16
16
filter-duplicate-objects org.metafacture.mangling.DuplicateObjectFilter
17
+ filter-null-values org.metafacture.mangling.NullFilter
17
18
literal-to-object org.metafacture.mangling.LiteralToObject
18
19
object-to-literal org.metafacture.mangling.ObjectToLiteral
19
20
change-id org.metafacture.mangling.RecordIdChanger
You can’t perform that action at this time.
0 commit comments