Skip to content

Commit 50402af

Browse files
cboehmecboehme
committed
Create plumbing package
The `plumbing` package contains modules for constructing Metafacture pipelines with branches.
1 parent 7f7ca7d commit 50402af

File tree

11 files changed

+16
-18
lines changed

11 files changed

+16
-18
lines changed

src/main/java/org/culturegraph/mf/stream/pipe/IdentityStreamPipe.java renamed to src/main/java/org/culturegraph/mf/plumbing/IdentityStreamPipe.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package org.culturegraph.mf.stream.pipe;
16+
package org.culturegraph.mf.plumbing;
1717

1818
import org.culturegraph.mf.framework.FluxCommand;
1919
import org.culturegraph.mf.framework.StreamReceiver;

src/main/java/org/culturegraph/mf/stream/pipe/ObjectTee.java renamed to src/main/java/org/culturegraph/mf/plumbing/ObjectTee.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package org.culturegraph.mf.stream.pipe;
16+
package org.culturegraph.mf.plumbing;
1717

1818
import org.culturegraph.mf.framework.FluxCommand;
1919
import org.culturegraph.mf.framework.ObjectPipe;

src/main/java/org/culturegraph/mf/stream/pipe/StreamBatchMerger.java renamed to src/main/java/org/culturegraph/mf/plumbing/StreamBatchMerger.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
/*
22
* Copyright 2016 Christoph Böhme
3-
* Copyright 2013, 2014 Deutsche Nationalbibliothek
43
*
54
* Licensed under the Apache License, Version 2.0 the "License";
65
* you may not use this file except in compliance with the License.
@@ -14,7 +13,7 @@
1413
* See the License for the specific language governing permissions and
1514
* limitations under the License.
1615
*/
17-
package org.culturegraph.mf.stream.pipe;
16+
package org.culturegraph.mf.plumbing;
1817

1918
import org.culturegraph.mf.framework.FluxCommand;
2019
import org.culturegraph.mf.framework.StreamReceiver;

src/main/java/org/culturegraph/mf/stream/pipe/StreamMerger.java renamed to src/main/java/org/culturegraph/mf/plumbing/StreamMerger.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package org.culturegraph.mf.stream.pipe;
16+
package org.culturegraph.mf.plumbing;
1717

1818
import org.culturegraph.mf.framework.FluxCommand;
1919
import org.culturegraph.mf.framework.StreamReceiver;

src/main/java/org/culturegraph/mf/stream/pipe/StreamTee.java renamed to src/main/java/org/culturegraph/mf/plumbing/StreamTee.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package org.culturegraph.mf.stream.pipe;
16+
package org.culturegraph.mf.plumbing;
1717

1818
import org.culturegraph.mf.framework.FluxCommand;
1919
import org.culturegraph.mf.framework.StreamPipe;

src/main/java/org/culturegraph/mf/stream/pipe/XmlTee.java renamed to src/main/java/org/culturegraph/mf/plumbing/XmlTee.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package org.culturegraph.mf.stream.pipe;
16+
package org.culturegraph.mf.plumbing;
1717

1818
import java.io.IOException;
1919

‎src/main/resources/flux-commands.properties‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -90,11 +90,11 @@ add-preamble-epilogue org.culturegraph.mf.stream.converter.PreambleEpilogueAdder
9090

9191
filter-duplicate-objects org.culturegraph.mf.stream.pipe.DuplicateObjectFilter
9292

93-
object-tee org.culturegraph.mf.stream.pipe.ObjectTee
94-
stream-tee org.culturegraph.mf.stream.pipe.StreamTee
93+
object-tee org.culturegraph.mf.plumbing.ObjectTee
94+
stream-tee org.culturegraph.mf.plumbing.StreamTee
9595
wait-for-inputs org.culturegraph.mf.stream.pipe.CloseSuppressor
9696
defer-stream org.culturegraph.mf.stream.pipe.StreamDeferrer
97-
xml-tee org.culturegraph.mf.stream.pipe.XmlTee
97+
xml-tee org.culturegraph.mf.plumbing.XmlTee
9898

9999
stream-to-xml org.culturegraph.mf.stream.converter.xml.SimpleXmlEncoder
100100
rdf-macros org.culturegraph.mf.stream.pipe.RdfMacroPipe
@@ -103,7 +103,7 @@ batch-log org.culturegraph.mf.stream.pipe.StreamBatchLogger
103103
object-batch-log org.culturegraph.mf.stream.pipe.ObjectBatchLogger
104104
batch-reset org.culturegraph.mf.stream.pipe.StreamBatchResetter
105105

106-
pass-through org.culturegraph.mf.stream.pipe.IdentityStreamPipe
106+
pass-through org.culturegraph.mf.plumbing.IdentityStreamPipe
107107

108108
match org.culturegraph.mf.stream.pipe.StringMatcher
109109

@@ -115,8 +115,8 @@ object-to-literal org.culturegraph.mf.stream.converter.ObjectToLiteral
115115
map-to-stream org.culturegraph.mf.stream.converter.MapToStream
116116
string-list-map-to-stream org.culturegraph.mf.stream.converter.StringListMapToStream
117117

118-
merge-batch-stream org.culturegraph.mf.stream.pipe.StreamBatchMerger
119-
merge-same-ids org.culturegraph.mf.stream.pipe.StreamMerger
118+
merge-batch-stream org.culturegraph.mf.plumbing.StreamBatchMerger
119+
merge-same-ids org.culturegraph.mf.plumbing.StreamMerger
120120

121121
filter-strings org.culturegraph.mf.stream.pipe.StringFilter
122122
discard-events org.culturegraph.mf.stream.pipe.StreamEventDiscarder

src/test/java/org/culturegraph/mf/stream/pipe/IdentityStreamPipeTest.java renamed to src/test/java/org/culturegraph/mf/plumbing/IdentityStreamPipeTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package org.culturegraph.mf.stream.pipe;
16+
package org.culturegraph.mf.plumbing;
1717

1818
import static org.mockito.Mockito.inOrder;
1919
import static org.mockito.Mockito.times;

src/test/java/org/culturegraph/mf/stream/pipe/StreamBatchMergerTest.java renamed to src/test/java/org/culturegraph/mf/plumbing/StreamBatchMergerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package org.culturegraph.mf.stream.pipe;
16+
package org.culturegraph.mf.plumbing;
1717

1818
import org.culturegraph.mf.framework.StreamReceiver;
1919
import org.junit.Before;

src/test/java/org/culturegraph/mf/stream/pipe/StreamMergerTest.java renamed to src/test/java/org/culturegraph/mf/plumbing/StreamMergerTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
/*
22
* Copyright 2016 Christoph Böhme
3-
* Copyright 2013, 2014 Deutsche Nationalbibliothek
43
*
54
* Licensed under the Apache License, Version 2.0 the "License";
65
* you may not use this file except in compliance with the License.
@@ -14,7 +13,7 @@
1413
* See the License for the specific language governing permissions and
1514
* limitations under the License.
1615
*/
17-
package org.culturegraph.mf.stream.pipe;
16+
package org.culturegraph.mf.plumbing;
1817

1918
import static org.mockito.Mockito.inOrder;
2019

0 commit comments

Comments
 (0)