You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by pe...@apache.org on 2020/06/09 08:11:46 UTC

[pulsar] branch master updated (dbc0649 -> 2aff473)

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

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


    from dbc0649  Add broker interceptor for Intercepting all Pulsar command and REST API requests. (#7143)
     add 2aff473  [issue #6765]  Expose definition flags to function  (#6868)

No new revisions were added by this update.

Summary of changes:
 .../worker/PulsarFunctionLocalRunTest.java         | 126 +++++++++++++++++++++
 .../org/apache/pulsar/admin/cli/CmdFunctions.java  |   9 +-
 .../impl/schema/SchemaDefinitionBuilderImpl.java   |   6 +
 .../pulsar/common/functions/ConsumerConfig.java    |  11 ++
 .../pulsar/common/functions/FunctionConfig.java    |   1 +
 .../org/apache/pulsar/common/io/SinkConfig.java    |   2 +
 .../functions/instance/JavaInstanceRunnable.java   |   2 +
 .../apache/pulsar/functions/sink/PulsarSink.java   |  10 +-
 .../pulsar/functions/sink/PulsarSinkConfig.java    |   3 +
 .../pulsar/functions/source/PulsarSource.java      |   2 +-
 .../pulsar/functions/source/TopicSchema.java       |  37 +++++-
 .../api/examples/pojo/AvroTestObject.java          |   1 +
 .../proto/src/main/proto/Function.proto            |   3 +
 .../functions/utils/FunctionConfigUtils.java       |  58 +++++++---
 14 files changed, 248 insertions(+), 23 deletions(-)