[pulsar] branch master updated (4d2d66d -> a161e75)

[je...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jerrypeng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from 4d2d66d  Update "sample" tenant on standalone to stop using old property/cluster/namespace naming convention. (#10486)
     add a161e75  [Issue-9889] [integration tests] Refactored Function integration tests (#10140)

No new revisions were added by this update.

Summary of changes:
 .gitignore                                         |    1 +
 .../integration/functions/PulsarFunctionsTest.java | 1222 +-------------------
 .../functions/PulsarFunctionsTestBase.java         |   99 +-
 .../PulsarFunctionsGoProcessTest.java}             |   15 +-
 .../PulsarFunctionsGoTest.java}                    |   21 +-
 .../PulsarFunctionsGoThreadTest.java}              |   14 +-
 .../PulsarFunctionsJavaProcessTest.java}           |   15 +-
 .../functions/java/PulsarFunctionsJavaTest.java    |  164 +++
 .../PulsarFunctionsJavaThreadTest.java}            |   14 +-
 .../PulsarFunctionsPythonProcessTest.java}         |   14 +-
 .../python/PulsarFunctionsPythonTest.java          |   67 ++
 .../PulsarFunctionsPythonThreadTest.java}          |   14 +-
 .../tests/integration/io/PulsarIOTestBase.java     |   69 ++
 .../tests/integration/io/PulsarIOTestRunner.java   |  109 ++
 .../tests/integration/io/RabbitMQSinkTester.java   |    4 +-
 .../tests/integration/io/RabbitMQSourceTester.java |    5 +-
 .../io/{ => sinks}/CassandraSinkTester.java        |    2 +-
 .../io/{ => sinks}/ElasticSearchSinkTester.java    |    2 +-
 .../integration/io/{ => sinks}/HdfsSinkTester.java |    2 +-
 .../io/{ => sinks}/JdbcPostgresSinkTester.java     |    2 +-
 .../io/{ => sinks}/KafkaSinkTester.java            |    3 +-
 .../integration/io/sinks/PulsarIOSinkRunner.java   |  447 +++++++
 .../integration/io/sinks/PulsarSinksTest.java      |   68 ++
 .../integration/io/{ => sinks}/SinkTester.java     |    2 +-
 .../io/{ => sources}/AvroKafkaSourceTest.java      |    2 +-
 .../io/{ => sources}/GenericRecordSourceTest.java  |    2 +-
 .../io/{ => sources}/KafkaSourceTester.java        |    2 +-
 .../io/sources/PulsarIOSourceRunner.java           |  296 +++++
 .../io/{ => sources}/PulsarSourcePropertyTest.java |    2 +-
 .../integration/io/{ => sources}/SourceTester.java |    2 +-
 .../debezium}/DebeziumMongoDbSourceTester.java     |    3 +-
 .../debezium}/DebeziumMySqlSourceTester.java       |    3 +-
 .../debezium}/DebeziumPostgreSqlSourceTester.java  |    3 +-
 .../debezium/PulsarDebeziumSourcesTest.java        |  220 ++++
 .../debezium/PulsarIODebeziumSourceRunner.java     |  117 ++
 .../src/test/resources/pulsar-function.xml         |    4 +-
 .../{pulsar-process.xml => pulsar-io-sinks.xml}    |    6 +-
 .../{pulsar-process.xml => pulsar-io-sources.xml}  |    6 +-
 .../{pulsar-process.xml => pulsar-io-suite.xml}    |   13 +-
 .../src/test/resources/pulsar-messaging.xml        |    2 +-
 .../src/test/resources/pulsar-process.xml          |    4 +-
 .../src/test/resources/pulsar-thread.xml           |    4 +-
 tests/integration/src/test/resources/pulsar.xml    |    2 +
 43 files changed, 1710 insertions(+), 1358 deletions(-)
 copy tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/{PulsarFunctionsThreadTest.java => go/PulsarFunctionsGoProcessTest.java} (78%)
 copy tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/{PulsarFunctionsProcessTest.java => go/PulsarFunctionsGoTest.java} (60%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/{PulsarFunctionsProcessTest.java => go/PulsarFunctionsGoThreadTest.java} (78%)
 copy tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/{PulsarFunctionsThreadTest.java => java/PulsarFunctionsJavaProcessTest.java} (78%)
 create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/java/PulsarFunctionsJavaTest.java
 copy tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/{PulsarFunctionsThreadTest.java => java/PulsarFunctionsJavaThreadTest.java} (78%)
 copy tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/{PulsarFunctionsThreadTest.java => python/PulsarFunctionsPythonProcessTest.java} (78%)
 create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/python/PulsarFunctionsPythonTest.java
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/{PulsarFunctionsThreadTest.java => python/PulsarFunctionsPythonThreadTest.java} (78%)
 create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/PulsarIOTestBase.java
 create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/PulsarIOTestRunner.java
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sinks}/CassandraSinkTester.java (98%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sinks}/ElasticSearchSinkTester.java (98%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sinks}/HdfsSinkTester.java (97%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sinks}/JdbcPostgresSinkTester.java (98%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sinks}/KafkaSinkTester.java (97%)
 create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/PulsarIOSinkRunner.java
 create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/PulsarSinksTest.java
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sinks}/SinkTester.java (98%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sources}/AvroKafkaSourceTest.java (99%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sources}/GenericRecordSourceTest.java (99%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sources}/KafkaSourceTester.java (98%)
 create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/PulsarIOSourceRunner.java
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sources}/PulsarSourcePropertyTest.java (99%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sources}/SourceTester.java (99%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sources/debezium}/DebeziumMongoDbSourceTester.java (97%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sources/debezium}/DebeziumMySqlSourceTester.java (97%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/{ => sources/debezium}/DebeziumPostgreSqlSourceTester.java (97%)
 create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/PulsarDebeziumSourcesTest.java
 create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/PulsarIODebeziumSourceRunner.java
 copy tests/integration/src/test/resources/{pulsar-process.xml => pulsar-io-sinks.xml} (83%)
 copy tests/integration/src/test/resources/{pulsar-process.xml => pulsar-io-sources.xml} (83%)
 copy tests/integration/src/test/resources/{pulsar-process.xml => pulsar-io-suite.xml} (69%)