apache / beam / 14005
70%
master: 100%

LAST BUILD BRANCH: delete-KeyedCombineFn
DEFAULT BRANCH: master
Ran
Jobs 1
Files 526
Run time 30s
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst
14005

Pull #3551

jenkins

web-flow 
<a href="https://github.com/apache/beam/commit/<a class=hub.com/apache/beam/commit/47e3caf454f3c29744e6e96feed0d61b7c616c65">47e3caf45<a href="https://github.com/apache/beam/commit/47e3caf454f3c29744e6e96feed0d61b7c616c65">">Merge </a><a class="double-link" href="https://github.com/apache/beam/commit/<a class="double-link" href="https://github.com/apache/beam/commit/dd328a3bddbbaae6be357e31ee5d04481e7ab1ba">dd328a3bd</a>">dd328a3bd</a><a href="https://github.com/apache/beam/commit/47e3caf454f3c29744e6e96feed0d61b7c616c65"> into f4b66f3a0">f4b66f3a0</a>
Pull Request #3551: [BEAM-2455] Backlog size retrieval for Kinesis source

21214 of 30318 relevant lines covered (69.97%)

0.7 hits per line

Uncovered Existing Lines

Lines Coverage ∆ File
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/MatchResult.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvokers.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollection.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/TypeDescriptor.java
1
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupByKey.java
1
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/IdentityWindowFn.java
2
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java
2
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java
2
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectTimerInternals.java
2
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/WindowEvaluatorFactory.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/options/ProxyInvocationHandler.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PTransform.java
3
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/StateTags.java
3
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/WriteWithShardingFactory.java
3
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextSource.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/OffsetRangeTracker.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/options/ValueProvider.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Flatten.java
5
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluatorFactory.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/options/ValueProviders.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/DefaultCoder.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionTuple.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/annotations/Experimental.java
7
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/LocalFileSystem.java
7
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/BlockBasedSource.java
7
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestStream.java
7
100.0
 examples/java/src/main/java/org/apache/beam/examples/WordCount.java
7
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/AssignWindows.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/Source.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/SerializableCoder.java
9
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java
9
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java
10
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptions.java
10
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryTimerInternals.java
11
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/Pipeline.java
11
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Filter.java
12
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java
12
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluatorRegistry.java
12
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchViewOverrides.java
13
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java
13
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java
13
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowMetrics.java
14
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/DynamicFileDestinations.java
14
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/TypeDescriptors.java
14
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoMultiOverrideFactory.java
15
100.0
 examples/java/src/main/java/org/apache/beam/examples/common/WriteOneFilePerWindow.java
15
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java
16
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
16
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java
16
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/OutputAndTimeBoundedSplittableProcessElementInvoker.java
18
100.0
 examples/java/src/main/java/org/apache/beam/examples/complete/TfIdf.java
20
100.0
 examples/java8/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToText.java
21
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java
21
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSink.java
21
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java
22
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineJob.java
23
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java
27
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/ByteBuddyDoFnInvokerFactory.java
29
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java
32
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/GroupByKeyViaGroupByKeyOnly.java
34
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java
35
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java
42
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/DefaultFilenamePolicy.java
42
100.0
 examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java
44
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDoViaKeyedWorkItems.java
49
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java
53
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java
68
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java
77
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java
82
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/TFRecordIO.java
89
100.0
 examples/java/src/main/java/org/apache/beam/examples/complete/TrafficRoutes.java
97
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextIO.java
109
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java
143
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java
157
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java
166
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
Jobs
ID Job ID Ran Files Coverage
1 14005.1 0
69.97
Source Files on build 14005
Detailed source file information is not available for this build.