Skip to content

Instantly share code, notes, and snippets.

@jsvd
Created June 23, 2020 10:12
Show Gist options
  • Save jsvd/4d518dfcc99949cfa6e2b669f43881c4 to your computer and use it in GitHub Desktop.
Save jsvd/4d518dfcc99949cfa6e2b669f43881c4 to your computer and use it in GitHub Desktop.
package org.logstash.generated;
public final class CompiledDataset461 extends org.logstash.config.ir.compiler.BaseDataset
implements org.logstash.config.ir.compiler.Dataset {
private final java.util.ArrayList field0;
private final org.logstash.generated.CompiledDataset460 field1;
private final org.jruby.RubyArray field2;
private final org.logstash.config.ir.compiler.FilterDelegatorExt field3;
public CompiledDataset461(java.util.Map arguments) {
field0 = ((java.util.ArrayList) arguments.get("field0"));
field1 = ((org.logstash.generated.CompiledDataset460) arguments.get("field1"));
field2 = ((org.jruby.RubyArray) arguments.get("field2"));
field3 = ((org.logstash.config.ir.compiler.FilterDelegatorExt) arguments.get("field3"));
}
public java.util.Collection compute(
org.jruby.RubyArray batchArg, boolean flushArg, boolean shutdownArg) {
if (this.isDone()) {
return field0;
}
org.logstash.config.ir.compiler.Utils.copyNonCancelledEvents(
field1.compute(batchArg, flushArg, shutdownArg), field2);
org.apache.logging.log4j.ThreadContext.put("plugin.id", "hey");
field0.addAll(field3.multiFilter(field2));
field2.clear();
this.setDone();
return field0;
}
public void clear() {
if (this.isDone()) {
field1.clear();
field0.clear();
this.clearDone();
}
}
}
package org.logstash.generated;
public final class CompiledDataset5 extends org.logstash.config.ir.compiler.BaseDataset
implements org.logstash.config.ir.compiler.Dataset {
private final java.util.ArrayList field0;
private final org.logstash.generated.CompiledDataset4 field1;
private final org.jruby.RubyArray field2;
private final org.logstash.config.ir.compiler.FilterDelegatorExt field3;
public CompiledDataset5(java.util.Map arguments) {
field0 = ((java.util.ArrayList) arguments.get("field0"));
field1 = ((org.logstash.generated.CompiledDataset4) arguments.get("field1"));
field2 = ((org.jruby.RubyArray) arguments.get("field2"));
field3 = ((org.logstash.config.ir.compiler.FilterDelegatorExt) arguments.get("field3"));
}
public java.util.Collection compute(
org.jruby.RubyArray batchArg, boolean flushArg, boolean shutdownArg) {
if (this.isDone()) {
return field0;
}
org.logstash.config.ir.compiler.Utils.copyNonCancelledEvents(
field1.compute(batchArg, flushArg, shutdownArg), field2);
org.apache.logging.log4j.ThreadContext.put("plugin.id", "hey");
field0.addAll(field3.multiFilter(field2));
field2.clear();
this.setDone();
return field0;
}
public void clear() {
if (this.isDone()) {
field1.clear();
field0.clear();
this.clearDone();
}
}
}
3c3
< public final class CompiledDataset5 extends org.logstash.config.ir.compiler.BaseDataset
---
> public final class CompiledDataset461 extends org.logstash.config.ir.compiler.BaseDataset
6c6
< private final org.logstash.generated.CompiledDataset4 field1;
---
> private final org.logstash.generated.CompiledDataset460 field1;
10c10
< public CompiledDataset5(java.util.Map arguments) {
---
> public CompiledDataset461(java.util.Map arguments) {
12c12
< field1 = ((org.logstash.generated.CompiledDataset4) arguments.get("field1"));
---
> field1 = ((org.logstash.generated.CompiledDataset460) arguments.get("field1"));
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment