Skip to content

Commit 23a9aa4

Browse files
committed
Add filter-null-values Flux command for NullFilter
1 parent 28ded4e commit 23a9aa4

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

metafacture-mangling/src/main/java/org/metafacture/mangling/NullFilter.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
*/
1616
package org.metafacture.mangling;
1717

18+
import org.metafacture.framework.FluxCommand;
1819
import org.metafacture.framework.StreamReceiver;
1920
import org.metafacture.framework.annotations.Description;
2021
import org.metafacture.framework.annotations.In;
@@ -31,6 +32,7 @@
3132
@Description("Discards or replaces null values")
3233
@In(StreamReceiver.class)
3334
@Out(StreamReceiver.class)
35+
@FluxCommand("filter-null-values")
3436
public final class NullFilter extends ForwardingStreamPipe {
3537

3638
private String replacement = null;

metafacture-mangling/src/main/resources/flux-commands.properties

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414
# limitations under the License.
1515
#
1616
filter-duplicate-objects org.metafacture.mangling.DuplicateObjectFilter
17+
filter-null-values org.metafacture.mangling.NullFilter
1718
literal-to-object org.metafacture.mangling.LiteralToObject
1819
object-to-literal org.metafacture.mangling.ObjectToLiteral
1920
change-id org.metafacture.mangling.RecordIdChanger

0 commit comments

Comments
 (0)