Home
last modified time | relevance | path

Searched refs:blockInfos1 (Results 1 – 2 of 2) sorted by relevance

/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/
H A DReceivedBlockTrackerSuite.scala130 val blockInfos1 = addBlockInfos(tracker1) constant
131 tracker1.getUnallocatedBlocks(streamId).toList shouldEqual blockInfos1
134 val expectedWrittenData1 = blockInfos1.map(BlockAdditionEvent)
148 unallocatedBlocks shouldEqual blockInfos1
157 tracker2.getBlocksOfBatchAndStream(batchTime1, streamId) shouldEqual blockInfos1
158 tracker2.getBlocksOfBatch(batchTime1) shouldEqual Map(streamId -> blockInfos1)
169 Seq(createBatchAllocation(batchTime1, blockInfos1)) ++
177 tracker3.getBlocksOfBatchAndStream(batchTime1, streamId) shouldEqual blockInfos1
H A DReceiverInputDStreamSuite.scala102 val blockInfos1 = Seq.fill(2) { createBlockInfo(withWALInfo = true) } constant
104 val blockInfos = blockInfos1 ++ blockInfos2