@@ -75,7 +75,7 @@ private static String buildPipelinePath(String name) {
75
75
return String .join (URL_DELIMITER , "_ingest" , "pipeline" , name );
76
76
}
77
77
78
- protected static void createPipeline (String name , Optional <String > description , List <Map <String , Object >> processorConfigs )
78
+ protected static Response createPipeline (String name , Optional <String > description , List <Map <String , Object >> processorConfigs )
79
79
throws IOException {
80
80
XContentBuilder builder = XContentFactory .jsonBuilder ().startObject ();
81
81
if (description .isPresent ()) {
@@ -88,7 +88,7 @@ protected static void createPipeline(String name, Optional<String> description,
88
88
89
89
Request request = new Request ("PUT" , buildPipelinePath (name ));
90
90
request .setJsonEntity (Strings .toString (builder ));
91
- client ().performRequest (request );
91
+ return client ().performRequest (request );
92
92
}
93
93
94
94
protected static void deletePipeline (String name ) throws IOException {
@@ -137,9 +137,9 @@ public static String indexDocument(String indexName, String docID, String body,
137
137
return docID ;
138
138
}
139
139
140
- protected Map <String , Object > buildGeoJSONFeatureProcessorConfig ( Map <String , String > properties ) {
140
+ protected Map <String , Object > buildProcessorConfig ( final String processorType , final Map <String , String > properties ) {
141
141
Map <String , Object > featureProcessor = new HashMap <>();
142
- featureProcessor .put (FeatureProcessor . TYPE , properties );
142
+ featureProcessor .put (processorType , properties );
143
143
return featureProcessor ;
144
144
}
145
145
0 commit comments