| /dports/devel/spark/spark-2.1.1/streaming/src/test/java/org/apache/spark/streaming/api/java/ |
| H A D | JavaStreamingListenerWrapperSuite.scala | 100 val batchStarted = StreamingListenerBatchStarted(BatchInfo( constant
132 listenerWrapper.onBatchStarted(batchStarted)
133 assertBatchInfo(listener.batchStarted.batchInfo, batchStarted.batchInfo)
256 var batchStarted: JavaStreamingListenerBatchStarted = null variable
277 override def onBatchStarted(batchStarted: JavaStreamingListenerBatchStarted): Unit = {
278 this.batchStarted = batchStarted
|
| /dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/api/java/ |
| H A D | JavaStreamingListener.scala | 37 def onBatchStarted(batchStarted: JavaStreamingListenerBatchStarted) { }
75 override def onBatchStarted(batchStarted: JavaStreamingListenerBatchStarted): Unit = {
76 listener.onBatchStarted(batchStarted)
115 def onBatchStarted(batchStarted: JavaStreamingListenerBatchStarted): Unit = { }
|
| H A D | JavaStreamingListenerWrapper.scala | 100 override def onBatchStarted(batchStarted: StreamingListenerBatchStarted): Unit = {
102 new JavaStreamingListenerBatchStarted(toJavaBatchInfo(batchStarted.batchInfo)))
|
| /dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ |
| H A D | StreamingListener.scala | 82 def onBatchStarted(batchStarted: StreamingListenerBatchStarted) { }
107 override def onBatchCompleted(batchStarted: StreamingListenerBatchCompleted) {
108 batchInfos.enqueue(batchStarted.batchInfo)
|
| H A D | StreamingListenerBus.scala | 60 case batchStarted: StreamingListenerBatchStarted =>
61 listener.onBatchStarted(batchStarted)
|
| /dports/devel/spark/spark-2.1.1/streaming/src/test/java/org/apache/spark/streaming/ |
| H A D | JavaStreamingListenerAPISuite.java | 70 public void onBatchStarted(JavaStreamingListenerBatchStarted batchStarted) { in onBatchStarted() argument
71 super.onBatchStarted(batchStarted); in onBatchStarted()
|
| /dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/ui/ |
| H A D | StreamingJobProgressListener.scala | 94 override def onBatchStarted(batchStarted: StreamingListenerBatchStarted): Unit = synchronized {
95 val batchUIData = BatchUIData(batchStarted.batchInfo)
96 runningBatchUIData(batchStarted.batchInfo.batchTime) = batchUIData
97 waitingBatchUIData.remove(batchStarted.batchInfo.batchTime)
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/ |
| H A D | HashTable.java | 469 private boolean batchStarted = false; field in HashTable.ResultHasher
484 if (batchStarted) { in startBatch()
487 batchStarted = true; in startBatch()
494 if (!batchStarted) { in hashResult()
517 if (!batchStarted) { in finishBatch()
520 batchStarted = false; in finishBatch()
525 return batchStarted; in isBatchStarted()
|
| /dports/devel/spark/spark-2.1.1/python/pyspark/streaming/ |
| H A D | listener.py | 50 def onBatchStarted(self, batchStarted): argument
|
| H A D | tests.py | 514 def onBatchStarted(self, batchStarted): argument
515 self.batchInfosStarted.append(batchStarted.batchInfo())
|
| /dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/ |
| H A D | StreamingListenerSuite.scala | 295 override def onBatchStarted(batchStarted: StreamingListenerBatchStarted) {
296 batchInfosStarted.add(batchStarted.batchInfo)
|
| H A D | TestSuiteBase.scala | 149 override def onBatchStarted(batchStarted: StreamingListenerBatchStarted): Unit =
|
| /dports/devel/spark/spark-2.1.1/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/ |
| H A D | DirectKafkaStreamSuite.scala | 502 override def onBatchStarted(batchStarted: StreamingListenerBatchStarted): Unit = {
503 numRecordsStarted.addAndGet(batchStarted.batchInfo.numRecords)
|
| /dports/devel/spark/spark-2.1.1/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/ |
| H A D | DirectKafkaStreamSuite.scala | 684 override def onBatchStarted(batchStarted: StreamingListenerBatchStarted): Unit = {
685 numRecordsStarted.addAndGet(batchStarted.batchInfo.numRecords)
|