Skip to content

Commit 87c4b66

Browse files
authored
Revert "[Backport master] Implement URI parts ingest processor (#5328)"
This reverts commit 045a53b.
1 parent 045a53b commit 87c4b66

File tree

4 files changed

+0
-122
lines changed

4 files changed

+0
-122
lines changed

src/Nest/Ingest/ProcessorFormatter.cs

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@ internal class ProcessorFormatter : IJsonFormatter<IProcessor>
4242
{ "circle", 30 },
4343
{ "enrich", 31 },
4444
{ "csv", 32 },
45-
{ "uri_parts", 33 }
4645
};
4746

4847
public IProcessor Deserialize(ref JsonReader reader, IJsonFormatterResolver formatterResolver)
@@ -162,9 +161,6 @@ public IProcessor Deserialize(ref JsonReader reader, IJsonFormatterResolver form
162161
case 32:
163162
processor = Deserialize<CsvProcessor>(ref reader, formatterResolver);
164163
break;
165-
case 33:
166-
processor = Deserialize<UriPartsProcessor>(ref reader, formatterResolver);
167-
break;
168164
}
169165
}
170166
else
@@ -285,9 +281,6 @@ public void Serialize(ref JsonWriter writer, IProcessor value, IJsonFormatterRes
285281
case "circle":
286282
Serialize<ICircleProcessor>(ref writer, value, formatterResolver);
287283
break;
288-
case "uri_parts":
289-
Serialize<IUriPartsProcessor>(ref writer, value, formatterResolver);
290-
break;
291284
default:
292285
var formatter = DynamicObjectResolver.ExcludeNullCamelCase.GetFormatter<IProcessor>();
293286
formatter.Serialize(ref writer, value, formatterResolver);

src/Nest/Ingest/Processors/UriPartsProcessor.cs

Lines changed: 0 additions & 97 deletions
This file was deleted.

src/Nest/Ingest/ProcessorsDescriptor.cs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -177,9 +177,5 @@ public ProcessorsDescriptor Pipeline(Func<PipelineProcessorDescriptor, IPipeline
177177
/// <inheritdoc cref="IPipelineProcessor" />
178178
public ProcessorsDescriptor Circle<T>(Func<CircleProcessorDescriptor<T>, ICircleProcessor> selector) where T : class =>
179179
Assign(selector, (a, v) => a.AddIfNotNull(v?.Invoke(new CircleProcessorDescriptor<T>())));
180-
181-
/// <inheritdoc cref="IUriPartsProcessor"/>
182-
public ProcessorsDescriptor UriParts<T>(Func<UriPartsProcessorDescriptor<T>, IUriPartsProcessor> selector) where T : class =>
183-
Assign(selector, (a, v) => a.AddIfNotNull(v?.Invoke(new UriPartsProcessorDescriptor<T>())));
184180
}
185181
}

tests/Tests/Ingest/ProcessorAssertions.cs

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -702,19 +702,5 @@ public class Pipeline : ProcessorAssertion
702702

703703
public override string Key => "pipeline";
704704
}
705-
706-
[SkipVersion("<7.11.0", "Uses URI parts which was introduced in 7.11.0")]
707-
public class UriParts : ProcessorAssertion
708-
{
709-
public override Func<ProcessorsDescriptor, IPromise<IList<IProcessor>>> Fluent => d => d
710-
.UriParts<Project>(ud => ud
711-
.Field(p => p.Description)
712-
.KeepOriginal()
713-
.RemoveIfSuccessful());
714-
715-
public override IProcessor Initializer => new UriPartsProcessor { Field = "description", KeepOriginal = true, RemoveIfSuccessful = true };
716-
public override object Json => new { field = "description", keep_original = true, remove_if_successful = true };
717-
public override string Key => "uri_parts";
718-
}
719705
}
720706
}

0 commit comments

Comments
 (0)