You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by buptljy <gi...@git.apache.org> on 2018/06/11 14:31:27 UTC
[GitHub] flink pull request #6148: [FLINK-7554][Tests] Add a testing RuntimeContext t...
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/6148
[FLINK-7554][Tests] Add a testing RuntimeContext to test utilities
## What is the purpose of the change
This pull request adds a TestingRuntimeContext to help developers test their own user-defined functions like CoprocessFunction instead of testing the whole pipeline.
## Brief change log
- TestingRuntimeContext can be directly used in unit testing of both dataset functions and datastream functions, including the support of broadcastVariable, state, accumulator and so on.
- Documents are written in udf_test, including examples of Java and Scala.
## Verifying this change
- This change has already been verified in new unit testing files in test directory, org.apache.flink.streaming.api.functions.test.TestingRuntimeContextTest and org.apache.flink.streaming.api.functions.test.TestingRuntimeContextTest.
## Documentation
- This pull request is a new feature.
- Related documents are written in docs directory.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/buptljy/flink 7554
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/6148.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #6148
----
commit 8535b22a7cf1545381bcd7b5febc0d4763f925aa
Author: wind <bu...@...>
Date: 2018-06-11T12:40:19Z
add TestingRuntimeContext
----
---