apache / beam / 14080
70%
master: 100%

LAST BUILD BRANCH: delete-KeyedCombineFn
DEFAULT BRANCH: master
Ran
Jobs 1
Files 490
Run time 43min
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
14080

Pull #1729

jenkins

jbonofre 
[BEAM-1240] Create RabbitMqIO
Pull Request #1729: [BEAM-1240] Create RabbitMqIO

20250 of 29181 relevant lines covered (69.39%)

0.69 hits per line

Uncovered Existing Lines

Lines Coverage ∆ File
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/metrics/MetricName.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/transforms/windowing/Repeatedly.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/values/POutputValueBase.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/WindowEvaluatorFactory.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/testing/GatherAllPanes.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/coders/CollectionCoder.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteStringCoder.java
1
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/GcsStager.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/Structs.java
1
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/TupleTagList.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/transforms/windowing/AfterWatermark.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/OrFinallyTrigger.java
2
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/PaneInfoTracker.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/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/complete/game/utils/WriteToBigQuery.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/AggregatorRetriever.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/SimpleFunction.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/SetCoder.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/TableRowJsonCoder.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/util/FileIOChannelFactory.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/ValueWithRecordId.java
2
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/GcsIOChannelFactory.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/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
 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/options/ProxyInvocationHandler.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StringDelegateCoder.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/coders/VoidCoder.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/StringUtils.java
3
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/values/TimestampedValue.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedSource.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingInput.java
4
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.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/StatefulParDoEvaluatorFactory.java
4
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluatorFactory.java
4
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/EvaluationContext.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/options/GcpOptions.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/transforms/Max.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/coders/VarIntCoder.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/transforms/Min.java
5
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/UnboundedSource.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/transforms/windowing/AfterPane.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
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/DoFnLifecycleManagerRemovingTransformEvaluator.java
5
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluatorRegistry.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/StringUtf8Coder.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/InstantCoder.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/transforms/windowing/Trigger.java
6
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/WatermarkHold.java
6
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java
6
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutorServices.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/transforms/Mean.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/SerializableCoder.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/TextualIntegerCoder.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/coders/DelegateCoder.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/MapCoder.java
6
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/NullableCoder.java
6
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/IdentityWindowFn.java
7
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/Pipeline.java
7
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterProcessingTime.java
7
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/AssignWindowsDoFn.java
7
100.0
 examples/java/src/main/java/org/apache/beam/examples/complete/TfIdf.java
7
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java
7
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ToString.java
7
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianLongCoder.java
7
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarLongCoder.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java
8
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryTimerInternals.java
8
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java
8
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PackageUtil.java
8
100.0
 examples/java/src/main/java/org/apache/beam/examples/cookbook/FilterExamples.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/StaticWindows.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Flatten.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvoker.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StandardCoder.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/JAXBCoder.java
8
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/PubsubClient.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/PaneInfo.java
9
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java
9
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteCoder.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
 runners/core-java/src/main/java/org/apache/beam/runners/core/UnboundedReadFromBoundedSource.java
11
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/CopyOnAccessInMemoryStateInternals.java
11
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoMultiOverrideFactory.java
11
100.0
 examples/java/src/main/java/org/apache/beam/examples/complete/TopWikipediaSessions.java
11
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/KvCoder.java
11
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DoFnInfo.java
12
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/testing/TestDataflowRunner.java
13
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectMetrics.java
13
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java
13
100.0
 examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java
13
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/FlatMapElements.java
14
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java
14
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java
14
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/PubsubTestClient.java
15
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/GroupAlsoByWindowViaWindowSetDoFn.java
15
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java
15
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/state/StateContexts.java
15
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/CombineContextFactory.java
16
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnRunner.java
16
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java
16
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/CoderUtils.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/io/FileBasedSink.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/testing/CoderProperties.java
17
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestStream.java
17
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sample.java
18
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachines.java
18
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
19
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/state/StateSpecs.java
19
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AvroCoder.java
20
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/BaseExecutionContext.java
20
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Count.java
20
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java
20
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java
21
100.0
 examples/java8/src/main/java/org/apache/beam/examples/complete/game/LeaderBoard.java
22
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingSource.java
22
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java
23
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java
24
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java
24
100.0
 examples/java8/src/main/java/org/apache/beam/examples/complete/game/GameStats.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/reflect/ByteBuddyDoFnInvokerFactory.java
24
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/PubsubJsonClient.java
27
100.0
 runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java
27
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/DoFnInvokers.java
30
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/CompressedSource.java
30
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java
31
100.0
 examples/java/src/main/java/org/apache/beam/examples/WindowedWordCount.java
31
100.0
 examples/java8/src/main/java/org/apache/beam/examples/complete/game/injector/Injector.java
31
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategy.java
32
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/transforms/Top.java
34
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/ApiSurface.java
41
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowedValue.java
42
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnContextFactory.java
42
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/PubsubGrpcClient.java
45
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java
45
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java
45
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/PCollectionViews.java
54
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java
55
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/PubsubUnboundedSource.java
61
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextIO.java
61
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/PerKeyCombineFnRunners.java
63
100.0
 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java
65
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/Write.java
65
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDo.java
76
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/PubsubUnboundedSink.java
76
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/util/GcsUtil.java
81
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Regex.java
83
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java
84
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleOldDoFnRunner.java
116
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/io/PubsubIO.java
143
100.0
 runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java
182
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java
229
100.0
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java
428
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 14080.1 0
69.39
Source Files on build 14080
Detailed source file information is not available for this build.