apache / beam / 2366
100%

DEFAULT BRANCH: master
Ran
Jobs 1
Files 491
Run time 31s
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
2366

push

jenkins

dhalperi 
This closes #1697

20335 of 29091 relevant lines covered (69.9%)

0.7 hits per line

Uncovered Existing Lines

Lines Coverage ∆ File
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/DistributionCell.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/DistributionData.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/GatherAllPanes.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/TupleTagList.java
1
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/WindowEvaluatorFactory.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/display/DisplayData.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/TupleTag.java
1
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java
1
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/BoundedReadEvaluatorFactory.java
1
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectGBKIntoKeyedWorkItemsOverrideFactory.java
1
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/GcsStager.java
1
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineWorkerPoolOptions.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PTransform.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/GlobalWindows.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricName.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKeyRange.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKey.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricUpdates.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SerializableMatchers.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/SimpleFunction.java
2
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineOptions.java
2
100.0
 examples/java8/src/main/java/org/apache/beam/examples/MinimalWordCountJava8.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigDecimalCoder.java
2
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/SystemReduceFn.java
2
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/NonEmptyPanes.java
2
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFn.java
2
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ReshuffleTriggerStateMachine.java
2
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/PaneInfoTracker.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/PValueBase.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/FileIOChannelFactory.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigIntegerCoder.java
2
100.0
 examples/java8/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToBigQuery.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupByKey.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/MapElements.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/SlidingWindows.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/PartitioningWindowFn.java
3
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunnerInfo.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StringDelegateCoder.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StandardCoder.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VoidCoder.java
3
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterSynchronizedProcessingTimeStateMachine.java
3
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupByKeyOnlyEvaluatorFactory.java
3
100.0
 examples/java/src/main/java/org/apache/beam/examples/WordCount.java
3
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/CustomSources.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ToString.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SourceTestUtils.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/UnboundedSource.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipelineOptions.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/ReflectHelpers.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvoker.java
4
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/MergingActiveWindowSet.java
4
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/EvaluationContext.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/DurationCoder.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/InstantCoder.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarIntCoder.java
4
100.0
 examples/java8/src/main/java/org/apache/beam/examples/complete/game/utils/WriteWindowedToBigQuery.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/OutputTimeFns.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterProcessingTime.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResultSchema.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedSource.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/IntervalWindow.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/OutputTimeFn.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PaneExtractors.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianLongCoder.java
5
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java
5
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java
5
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/WindowingInternalsAdapters.java
5
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterProcessingTimeStateMachine.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/TimestampedValue.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/DoubleCoder.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StringUtf8Coder.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Filter.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterPane.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/CounterCell.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianIntegerCoder.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteArrayCoder.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/IdentityWindowFn.java
6
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/WatermarkHold.java
6
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutorServices.java
6
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/StatefulParDoEvaluatorFactory.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/util/IOChannelUtils.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/BitSetCoder.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarLongCoder.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/TextualIntegerCoder.java
6
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java
6
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowClient.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Latest.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricNameFilter.java
6
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/coders/SerializableCoder.java
7
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/DelegateCoder.java
7
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/AssignWindowsDoFn.java
7
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/KeyedWorkItemCoder.java
7
100.0
 examples/java/src/main/java/org/apache/beam/examples/complete/TfIdf.java
7
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluatorRegistry.java
7
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluatorFactory.java
7
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptions.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/StaticWindows.java
8
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PackageUtil.java
8
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryTimerInternals.java
8
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionList.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteCoder.java
8
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java
8
100.0
 examples/java/src/main/java/org/apache/beam/examples/cookbook/FilterExamples.java
8
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DoFnInfo.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/PipelineResult.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/Pipeline.java
9
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsFilter.java
9
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java
9
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/PaneInfo.java
9
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoMultiOverrideFactory.java
9
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/NullableCoder.java
9
100.0
 examples/java8/src/main/java/org/apache/beam/examples/complete/game/UserScore.java
9
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Top.java
10
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java
10
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java
10
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/Reshuffle.java
11
100.0
 examples/java/src/main/java/org/apache/beam/examples/complete/TopWikipediaSessions.java
11
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/CopyOnAccessInMemoryStateInternals.java
12
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderFactories.java
12
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/CoderUtils.java
12
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/MapCoder.java
12
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/testing/TestDataflowRunner.java
12
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Flatten.java
13
100.0
 examples/java/src/main/java/org/apache/beam/examples/cookbook/CombinePerKeyExamples.java
13
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectMetrics.java
13
100.0
 examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java
14
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java
14
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java
15
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/state/StateContexts.java
16
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnRunner.java
16
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/GroupAlsoByWindowViaWindowSetDoFn.java
16
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithTimestamps.java
17
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java
17
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sample.java
17
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AvroCoder.java
17
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java
18
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
18
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachines.java
19
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/state/StateSpecs.java
20
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/CoderProperties.java
20
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java
20
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java
20
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/BaseExecutionContext.java
20
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java
20
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java
20
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java
21
100.0
 examples/java8/src/main/java/org/apache/beam/examples/complete/game/LeaderBoard.java
21
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/UnionCoder.java
22
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java
22
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/ValueWithRecordId.java
22
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingSource.java
23
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestStream.java
23
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowedValue.java
23
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategy.java
24
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java
24
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/FlatMapElements.java
24
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java
24
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Count.java
24
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
25
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java
26
100.0
 examples/java8/src/main/java/org/apache/beam/examples/complete/game/GameStats.java
26
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java
28
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/io/CompressedSource.java
31
100.0
 examples/java8/src/main/java/org/apache/beam/examples/complete/game/injector/Injector.java
31
100.0
 examples/java/src/main/java/org/apache/beam/examples/WindowedWordCount.java
31
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/KeyedPCollectionTuple.java
33
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineJob.java
34
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/ApiSurface.java
34
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java
36
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java
42
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnContextFactory.java
43
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/Structs.java
44
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/PCollectionViews.java
44
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java
46
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java
48
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnAdapters.java
52
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java
61
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDo.java
65
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextIO.java
67
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Regex.java
68
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleOldDoFnRunner.java
79
100.0
 examples/java/src/main/java/org/apache/beam/examples/common/ExampleUtils.java
86
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java
88
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java
118
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java
134
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java
167
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java
171
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java
416
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 2366.1 0
69.9
Source Files on build 2366
Detailed source file information is not available for this build.