/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/ |
H A D | StreamingListenerSuite.scala | 224 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 D | StreamingListenerBus.scala | 30 extends SparkListener with ListenerBus[StreamingListener, StreamingListenerEvent] { 49 listener: StreamingListener,
|
H A D | StreamingListener.scala | 67 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__.py | 20 from pyspark.streaming.listener import StreamingListener
|
H A D | listener.py | 21 class StreamingListener(object): class
|
/dports/devel/llvm-cheri/llvm-project-37c49ff00e3eadce5d8703fdc4497f28458c64a8/llvm/utils/unittest/googletest/src/ |
H A D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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 D | gtest-internal-inl.h | 1035 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);
|