You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/05/19 00:49:28 UTC
[pulsar] 13/26: improve data-generator source performance (#4058)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit ad1071a81e3e8eada4152dd84b3baeb47b92ed02
Author: Boyang Jerry Peng <je...@gmail.com>
AuthorDate: Wed Apr 17 22:31:54 2019 -0700
improve data-generator source performance (#4058)
### Motivation
Only initialize factory once in the beginning
---
.../org/apache/pulsar/io/datagenerator/DataGeneratorSource.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/pulsar-io/data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorSource.java b/pulsar-io/data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorSource.java
index 1a9f63f..118025a 100644
--- a/pulsar-io/data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorSource.java
+++ b/pulsar-io/data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorSource.java
@@ -29,9 +29,11 @@ import java.util.Optional;
public class DataGeneratorSource implements Source<Person> {
+ private Fairy fairy;
+
@Override
public void open(Map<String, Object> config, SourceContext sourceContext) throws Exception {
-
+ this.fairy = Fairy.create();
}
@Override
@@ -45,7 +47,7 @@ public class DataGeneratorSource implements Source<Person> {
@Override
public Person getValue() {
- return new Person(Fairy.create().person());
+ return new Person(fairy.person());
}
};
}