Skip to content

Commit 042c158

Browse files
committed
Create elasticsearch package
The `elasticsearch` package contains modules for working with elasticsearch.
1 parent fb9c254 commit 042c158

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

src/main/java/org/culturegraph/mf/stream/converter/JsonToElasticsearchBulk.java renamed to src/main/java/org/culturegraph/mf/elasticsearch/JsonToElasticsearchBulk.java

Lines changed: 2 additions & 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.converter;
16+
package org.culturegraph.mf.elasticsearch;
1717

1818
import java.io.IOException;
1919
import java.io.StringWriter;
@@ -29,6 +29,7 @@
2929
import org.culturegraph.mf.framework.annotations.In;
3030
import org.culturegraph.mf.framework.annotations.Out;
3131
import org.culturegraph.mf.framework.helpers.DefaultObjectPipe;
32+
import org.culturegraph.mf.stream.converter.JsonEncoder;
3233

3334
import com.fasterxml.jackson.databind.ObjectMapper;
3435

src/main/resources/flux-commands.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,7 @@ add-oreaggregation org.culturegraph.mf.stream.pipe.OreAggregationAdder
137137
digest-file org.culturegraph.mf.files.FileDigestCalculator
138138
reorder-triple org.culturegraph.mf.triples.TripleReorder
139139

140-
json-to-elasticsearch-bulk org.culturegraph.mf.stream.converter.JsonToElasticsearchBulk
140+
json-to-elasticsearch-bulk org.culturegraph.mf.elasticsearch.JsonToElasticsearchBulk
141141

142142
remodel-pica-multiscript org.culturegraph.mf.stream.pipe.PicaMultiscriptRemodeler
143143

src/test/java/org/culturegraph/mf/stream/converter/JsonToElasticsearchBulkTest.java renamed to src/test/java/org/culturegraph/mf/elasticsearch/JsonToElasticsearchBulkTest.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.converter;
16+
package org.culturegraph.mf.elasticsearch;
1717

1818
import static org.mockito.Mockito.verify;
1919
import static org.mockito.Mockito.verifyNoMoreInteractions;

0 commit comments

Comments
 (0)