Home
last modified time | relevance | path

Searched refs:StreamingListener (Results 1 – 25 of 454) sorted by relevance

12345678910>>...19

/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/
H A DStreamingListenerSuite.scala224 val streamingListener = mock(classOf[StreamingListener])
286 class BatchInfoCollector extends StreamingListener {
305 class ReceiverInfoCollector extends StreamingListener {
325 class OutputOperationInfoCollector extends StreamingListener {
358 class FailureReasonsCollector extends StreamingListener {
375 class StreamingContextStoppingCollector(val ssc: StreamingContext) extends StreamingListener {
/dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/scheduler/
H A DStreamingListenerBus.scala30 extends SparkListener with ListenerBus[StreamingListener, StreamingListenerEvent] {
49 listener: StreamingListener,
H A DStreamingListener.scala67 trait StreamingListener { trait
103 class StatsReportListener(numBatchInfos: Int = 10) extends StreamingListener {
/dports/devel/spark/spark-2.1.1/python/pyspark/streaming/
H A D__init__.py20 from pyspark.streaming.listener import StreamingListener
H A Dlistener.py21 class StreamingListener(object): class
/dports/devel/llvm-cheri/llvm-project-37c49ff00e3eadce5d8703fdc4497f28458c64a8/llvm/utils/unittest/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/biology/vcflib/vcflib-1.0.2/googletest/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/net/flower/flower-0.10/contrib/googletest-release-1.8.0/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/devel/llvm11/llvm-11.0.1.src/utils/unittest/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/devel/apitrace/apitrace-9.0/thirdparty/gtest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/www/firefox-esr/firefox-91.8.0/third_party/aom/third_party/googletest/src/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/multimedia/libva-intel-media-driver/media-driver-intel-media-22.1.1/media_driver/linux/ult/ult_app/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/multimedia/libva-utils/libva-utils-2.13.0/test/gtest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/multimedia/libva-intel-media-driver/media-driver-intel-media-22.1.1/media_driver/linux/ult/ult_app/googletest/include/gtest/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/multimedia/libva-intel-driver/intel-vaapi-driver-2.4.1/test/gtest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/devel/llvm90/llvm-9.0.1.src/utils/unittest/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/lang/spidermonkey60/firefox-60.9.0/third_party/aom/third_party/googletest/src/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/lang/spidermonkey60/firefox-60.9.0/testing/gtest/gtest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/devel/llbuild/swift-llbuild-swift-DEVELOPMENT-SNAPSHOT-2017-12-10-a/utils/unittest/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/devel/llvm12/llvm-project-12.0.1.src/llvm/utils/unittest/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/devel/llvm10/llvm-10.0.1.src/utils/unittest/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/multimedia/cmrtlib/media-driver-intel-media-20.1.1/media_driver/linux/ult/ult_app/googletest/include/gtest/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/multimedia/cmrtlib/media-driver-intel-media-20.1.1/media_driver/linux/ult/ult_app/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/math/curv/curv-0.5/extern/googletest/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
/dports/devel/arpc/arpc-0.7/contrib/googletest-release-1.8.0/googletest/src/
H A Dgtest-internal-inl.h1035 class GTEST_API_ StreamingListener : public EmptyTestEventListener {
1103 StreamingListener(const string& host, const string& port) in StreamingListener() function
1106 explicit StreamingListener(AbstractSocketWriter* socket_writer) in StreamingListener() function
1175 GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);

12345678910>>...19