Skip to content

[Task]: Spark Runner GroupNonMergingWindowsFunctions#groupByKeyInGlobalWindow does not using partitioner #2122

[Task]: Spark Runner GroupNonMergingWindowsFunctions#groupByKeyInGlobalWindow does not using partitioner

[Task]: Spark Runner GroupNonMergingWindowsFunctions#groupByKeyInGlobalWindow does not using partitioner #2122

GitHub Actions / Test Results failed Oct 4, 2024 in 0s

4 parse errors, 4 skipped, 542 pass in 3m 1s

 96 files    4 errors  92 suites   3m 1s ⏱️
546 tests 542 ✅ 4 💤 0 ❌
547 runs  543 ✅ 4 💤 0 ❌

Results for commit a2710ed.

Annotations

Check failure on line 0 in runners/samza/build/test-results/validatesRunner/TEST-org.apache.beam.sdk.io.TextIOReadTest$CompressedReadTest.xml

See this annotation in the file changed.

@github-actions github-actions / Test Results

Error processing result file

Memory allocation failed : Huge input lookup, line 58032, column 126 (TEST-org.apache.beam.sdk.io.TextIOReadTest$CompressedReadTest.xml, line 58032)
Raw output
runners/samza/build/test-results/validatesRunner/TEST-org.apache.beam.sdk.io.TextIOReadTest$CompressedReadTest.xml

Check failure on line 0 in runners/samza/build/test-results/validatesRunner/TEST-org.apache.beam.sdk.io.TFRecordIOTest.xml

See this annotation in the file changed.

@github-actions github-actions / Test Results

Error processing result file

CData section too big found, line 1797, column 9688376 (TEST-org.apache.beam.sdk.io.TFRecordIOTest.xml, line 1797)
Raw output
runners/samza/build/test-results/validatesRunner/TEST-org.apache.beam.sdk.io.TFRecordIOTest.xml

Check failure on line 0 in runners/samza/build/test-results/validatesRunner/TEST-org.apache.beam.sdk.transforms.ViewTest.xml

See this annotation in the file changed.

@github-actions github-actions / Test Results

Error processing result file

Memory allocation failed : Huge input lookup, line 62630, column 743 (TEST-org.apache.beam.sdk.transforms.ViewTest.xml, line 62630)
Raw output
runners/samza/build/test-results/validatesRunner/TEST-org.apache.beam.sdk.transforms.ViewTest.xml

Check failure on line 0 in runners/samza/build/test-results/validatesRunner/TEST-org.apache.beam.sdk.testing.PAssertTest.xml

See this annotation in the file changed.

@github-actions github-actions / Test Results

Error processing result file

Memory allocation failed : Huge input lookup, line 97239, column 44 (TEST-org.apache.beam.sdk.testing.PAssertTest.xml, line 97239)
Raw output
runners/samza/build/test-results/validatesRunner/TEST-org.apache.beam.sdk.testing.PAssertTest.xml

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

4 skipped tests found

There are 4 skipped tests, see "Raw output" for the full list of skipped tests.
Raw output
org.apache.beam.sdk.coders.PCollectionCustomCoderTest ‑ testDeserializationIOException
org.apache.beam.sdk.coders.PCollectionCustomCoderTest ‑ testDeserializationNPException
org.apache.beam.sdk.transforms.SplittableDoFnTest ‑ testLateData
org.apache.beam.sdk.values.PDoneTest ‑ testEmptyTransform

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

546 tests found

There are 546 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.PipelineTest ‑ testIdentityTransform
org.apache.beam.sdk.PipelineTest ‑ testMultipleApply
org.apache.beam.sdk.PipelineTest ‑ testTupleInjectionTransform
org.apache.beam.sdk.PipelineTest ‑ testTupleProjectionTransform
org.apache.beam.sdk.coders.CoderRegistryTest ‑ testIgnoredGenericInPipeline
org.apache.beam.sdk.coders.CoderRegistryTest ‑ testSpecializedButIgnoredGenericInPipeline
org.apache.beam.sdk.coders.PCollectionCustomCoderTest ‑ testDeserializationIOException
org.apache.beam.sdk.coders.PCollectionCustomCoderTest ‑ testDeserializationNPException
org.apache.beam.sdk.coders.PCollectionCustomCoderTest ‑ testNoException
org.apache.beam.sdk.coders.PCollectionCustomCoderTest ‑ testSerializationIOException
org.apache.beam.sdk.coders.PCollectionCustomCoderTest ‑ testSerializationNPException
org.apache.beam.sdk.coders.SerializableCoderTest ‑ testDefaultCoder
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest ‑ testDedup
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest ‑ testNoDedup
org.apache.beam.sdk.io.CountingSourceTest ‑ testBoundedSource
org.apache.beam.sdk.io.CountingSourceTest ‑ testBoundedSourceSplits
org.apache.beam.sdk.io.CountingSourceTest ‑ testEmptyBoundedSource
org.apache.beam.sdk.io.CountingSourceTest ‑ testUnboundedSource
org.apache.beam.sdk.io.CountingSourceTest ‑ testUnboundedSourceRateSplits
org.apache.beam.sdk.io.CountingSourceTest ‑ testUnboundedSourceSplits
org.apache.beam.sdk.io.CountingSourceTest ‑ testUnboundedSourceTimestamps
org.apache.beam.sdk.io.CountingSourceTest ‑ testUnboundedSourceWithRate
org.apache.beam.sdk.io.FileBasedSourceTest ‑ testDataflowFile
org.apache.beam.sdk.io.FileBasedSourceTest ‑ testDataflowFilePattern
org.apache.beam.sdk.io.GenerateSequenceTest ‑ testBoundedInput
org.apache.beam.sdk.io.GenerateSequenceTest ‑ testBoundedInputSubrange
org.apache.beam.sdk.io.GenerateSequenceTest ‑ testEmptyBoundedInput
org.apache.beam.sdk.io.GenerateSequenceTest ‑ testEmptyBoundedInputSubrange
org.apache.beam.sdk.io.GenerateSequenceTest ‑ testUnboundedInputRate
org.apache.beam.sdk.io.GenerateSequenceTest ‑ testUnboundedInputTimestamps
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testReadAll
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testReadEmptyStrings
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testReadFiles
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testReadFilesWithFilename
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testReadStrings
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testReadStringsWithCustomDelimiter
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testReadStringsWithCustomDelimiter_NestedDelimiter
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testReadStringsWithCustomDelimiter_PartialDelimiterMatchedAtBoundary
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testSmallCompressedAutoReadActuallyUncompressed
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testSmallCompressedGzipReadActuallyUncompressed
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testZipCompressedReadWithComplexEmptyAndPresentEntries
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testZipCompressedReadWithMultiEntriesFile
org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest ‑ testZipCompressedReadWithNoEntries
org.apache.beam.sdk.io.TextIOReadTest$TextSourceTest ‑ testPreserveNonBOMBytes
org.apache.beam.sdk.io.TextIOReadTest$TextSourceTest ‑ testRemoveUtf8BOM
org.apache.beam.sdk.io.TextIOWriteTest ‑ testDynamicDefaultFilenamePolicy
org.apache.beam.sdk.io.TextIOWriteTest ‑ testDynamicDestinations
org.apache.beam.sdk.io.TextIOWriteTest ‑ testDynamicDestinationsWithCustomType
org.apache.beam.sdk.io.TextIOWriteTest ‑ testShardedWrite
org.apache.beam.sdk.io.TextIOWriteTest ‑ testWindowedWritesWithOnceTrigger
org.apache.beam.sdk.io.TextIOWriteTest ‑ testWriteEmptyStrings
org.apache.beam.sdk.io.TextIOWriteTest ‑ testWriteEmptyStringsNoSharding
org.apache.beam.sdk.io.TextIOWriteTest ‑ testWriteEmptyStringsSkipIfEmpty
org.apache.beam.sdk.io.TextIOWriteTest ‑ testWriteStrings
org.apache.beam.sdk.io.TextIOWriteTest ‑ testWriteViaSink
org.apache.beam.sdk.io.TextIOWriteTest ‑ testWriteWithFooter
org.apache.beam.sdk.io.TextIOWriteTest ‑ testWriteWithHeader
org.apache.beam.sdk.io.TextIOWriteTest ‑ testWriteWithHeaderAndFooter
org.apache.beam.sdk.io.TextIOWriteTest ‑ testWriteWithWritableByteChannelFactory
org.apache.beam.sdk.io.WriteFilesTest ‑ testCustomShardedWrite
org.apache.beam.sdk.io.WriteFilesTest ‑ testCustomShardingFunctionWrite
org.apache.beam.sdk.io.WriteFilesTest ‑ testDynamicDestinationsBounded
org.apache.beam.sdk.io.WriteFilesTest ‑ testDynamicDestinationsFillEmptyShards
org.apache.beam.sdk.io.WriteFilesTest ‑ testDynamicDestinationsUnbounded
org.apache.beam.sdk.io.WriteFilesTest ‑ testEmptyWrite
org.apache.beam.sdk.io.WriteFilesTest ‑ testExpandShardedWrite
org.apache.beam.sdk.io.WriteFilesTest ‑ testFailingDynamicDestinationsAutosharding
org.apache.beam.sdk.io.WriteFilesTest ‑ testFailingDynamicDestinationsBounded
org.apache.beam.sdk.io.WriteFilesTest ‑ testFailingDynamicDestinationsUnbounded
org.apache.beam.sdk.io.WriteFilesTest ‑ testShardedWrite
org.apache.beam.sdk.io.WriteFilesTest ‑ testUnboundedNeedsWindowed
org.apache.beam.sdk.io.WriteFilesTest ‑ testUnboundedWritesWithMergingWindowNeedSharding
org.apache.beam.sdk.io.WriteFilesTest ‑ testWithRunnerDeterminedShardingUnbounded
org.apache.beam.sdk.io.WriteFilesTest ‑ testWithShardingUnbounded
org.apache.beam.sdk.io.WriteFilesTest ‑ testWrite
org.apache.beam.sdk.io.WriteFilesTest ‑ testWriteNoSpilling
org.apache.beam.sdk.io.WriteFilesTest ‑ testWriteSpilling
org.apache.beam.sdk.io.WriteFilesTest ‑ testWriteUnboundedWithCustomBatchParameters
org.apache.beam.sdk.io.WriteFilesTest ‑ testWriteWindowed
org.apache.beam.sdk.io.WriteFilesTest ‑ testWriteWithEmptyPCollection
org.apache.beam.sdk.io.WriteFilesTest ‑ testWriteWithSessions
org.apache.beam.sdk.options.ProxyInvocationHandlerTest ‑ pipelineOptionsDisplayDataExceptionShouldFail
org.apache.beam.sdk.providers.GenerateSequenceSchemaTransformProviderTest ‑ testGenerateSequence
org.apache.beam.sdk.runners.TransformTreeTest ‑ testMultiGraphSetup
org.apache.beam.sdk.schemas.io.DeadLetteredTransformTest ‑ testDeadLettersOnlyFailures
org.apache.beam.sdk.schemas.io.GenericDlqTest ‑ testDlq
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ addDuplicateField
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ addNestedCollectionField
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ addNestedField
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ addNestedFieldDefaultValue
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ addNestedMapField
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ addNonNullableField
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ addSimpleAndNestedField
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ addSimpleFields
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ addSimpleFieldsDefaultValue
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ recursivelyAddNestedArrayField
org.apache.beam.sdk.schemas.transforms.AddFieldsTest ‑ recursivelyAddNestedFields
org.apache.beam.sdk.schemas.transforms.DropFieldsTest ‑ testDropNestedArrayField
org.apache.beam.sdk.schemas.transforms.DropFieldsTest ‑ testDropNestedField
org.apache.beam.sdk.schemas.transforms.DropFieldsTest ‑ testDropNestedFieldKeepingOnlyNested
org.apache.beam.sdk.schemas.transforms.DropFieldsTest ‑ testDropTopLevelField
org.apache.beam.sdk.schemas.transforms.DropFieldsTest ‑ testMaintainsOriginalSchemaOrder
org.apache.beam.sdk.schemas.transforms.RenameFieldsTest ‑ renameNestedFields
org.apache.beam.sdk.schemas.transforms.RenameFieldsTest ‑ renameNestedInArrayFields
org.apache.beam.sdk.schemas.transforms.RenameFieldsTest ‑ renameNestedInMapFields
org.apache.beam.sdk.schemas.transforms.RenameFieldsTest ‑ renameTopLevelAndNestedFields
org.apache.beam.sdk.schemas.transforms.RenameFieldsTest ‑ renameTopLevelFields
org.apache.beam.sdk.schemas.transforms.providers.JavaExplodeTransformProviderTest ‑ testCrossProduct
org.apache.beam.sdk.schemas.transforms.providers.JavaExplodeTransformProviderTest ‑ testZipProduct
org.apache.beam.sdk.schemas.transforms.providers.JavaFilterTransformProviderTest ‑ testErrorHandling
org.apache.beam.sdk.schemas.transforms.providers.JavaFilterTransformProviderTest ‑ testFilter
org.apache.beam.sdk.schemas.transforms.providers.JavaMapToFieldsTransformProviderTest ‑ testAppendAndDropFields
org.apache.beam.sdk.schemas.transforms.providers.JavaMapToFieldsTransformProviderTest ‑ testErrorHandling
org.apache.beam.sdk.schemas.transforms.providers.JavaMapToFieldsTransformProviderTest ‑ testRenameFields
org.apache.beam.sdk.testing.GatherAllPanesTest ‑ multiplePanesMultipleReifiedPane
org.apache.beam.sdk.testing.GatherAllPanesTest ‑ singlePaneSingleReifiedPane
org.apache.beam.sdk.testing.TestPipelineTest$NewProviderTest ‑ testNewProvider
org.apache.beam.sdk.testing.TestPipelineTest$TestPipelineEnforcementsTest$WithRealPipelineRunner ‑ testDanglingPAssertValidatesRunner
org.apache.beam.sdk.testing.TestPipelineTest$TestPipelineEnforcementsTest$WithRealPipelineRunner ‑ testDanglingPTransformNeedsRunner
org.apache.beam.sdk.testing.TestPipelineTest$TestPipelineEnforcementsTest$WithRealPipelineRunner ‑ testDanglingPTransformValidatesRunner
org.apache.beam.sdk.testing.TestPipelineTest$TestPipelineEnforcementsTest$WithRealPipelineRunner ‑ testMissingRun
org.apache.beam.sdk.testing.TestPipelineTest$TestPipelineEnforcementsTest$WithRealPipelineRunner ‑ testMissingRunAutoAdd
org.apache.beam.sdk.testing.TestPipelineTest$TestPipelineEnforcementsTest$WithRealPipelineRunner ‑ testMissingRunWithDisabledEnforcement
org.apache.beam.sdk.testing.TestPipelineTest$TestPipelineEnforcementsTest$WithRealPipelineRunner ‑ testNoTestPipelineUsedValidatesRunner
org.apache.beam.sdk.testing.TestPipelineTest$TestPipelineEnforcementsTest$WithRealPipelineRunner ‑ testNormalFlow
org.apache.beam.sdk.testing.TestPipelineTest$TestPipelineEnforcementsTest$WithRealPipelineRunner ‑ testRunWithAdditionalArgsEffective
org.apache.beam.sdk.testing.TestStreamTest ‑ testDiscardingMode
org.apache.beam.sdk.testing.TestStreamTest ‑ testElementsAtAlmostPositiveInfinity
org.apache.beam.sdk.testing.TestStreamTest ‑ testMultiStage
org.apache.beam.sdk.testing.TestStreamTest ‑ testMultipleStreams
org.apache.beam.sdk.transforms.ApproximateQuantilesTest$CombinerTests ‑ testQuantilesGlobally
org.apache.beam.sdk.transforms.ApproximateQuantilesTest$CombinerTests ‑ testQuantilesGobally_comparable
org.apache.beam.sdk.transforms.ApproximateQuantilesTest$CombinerTests ‑ testQuantilesPerKey
org.apache.beam.sdk.transforms.ApproximateQuantilesTest$CombinerTests ‑ testQuantilesPerKey_reversed
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueMiscTest ‑ testApproximateUniquePerKey
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueMiscTest ‑ testApproximateUniqueWithSkewedDistributionsAndLargeSampleSize
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueMiscTest ‑ testApproximateUniqueWithSmallInput
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueVariationsTest ‑ testApproximateUniqueWithDifferentSampleSizes[sampleSize_1,000]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueVariationsTest ‑ testApproximateUniqueWithDifferentSampleSizes[sampleSize_128]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueVariationsTest ‑ testApproximateUniqueWithDifferentSampleSizes[sampleSize_15]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueVariationsTest ‑ testApproximateUniqueWithDifferentSampleSizes[sampleSize_16]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueVariationsTest ‑ testApproximateUniqueWithDifferentSampleSizes[sampleSize_2,014]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueVariationsTest ‑ testApproximateUniqueWithDifferentSampleSizes[sampleSize_256]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueVariationsTest ‑ testApproximateUniqueWithDifferentSampleSizes[sampleSize_512]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueVariationsTest ‑ testApproximateUniqueWithDifferentSampleSizes[sampleSize_64]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueWithDuplicatesTest ‑ testApproximateUniqueWithDuplicates[total_1,000_unique_1,000_sample_100]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueWithDuplicatesTest ‑ testApproximateUniqueWithDuplicates[total_1,500_unique_1,000_sample_100]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueWithDuplicatesTest ‑ testApproximateUniqueWithDuplicates[total_10,000_unique_1,000_sample_100]
org.apache.beam.sdk.transforms.ApproximateUniqueTest$ApproximateUniqueWithDuplicatesTest ‑ testApproximateUniqueWithDuplicates[total_100_unique_100_sample_100]
org.apache.beam.sdk.transforms.CombineFnsTest ‑ testComposedCombine
org.apache.beam.sdk.transforms.CombineFnsTest ‑ testComposedCombineNullValues
org.apache.beam.sdk.transforms.CombineFnsTest ‑ testComposedCombineWithContext
org.apache.beam.sdk.transforms.CombineTest$AccumulationTests ‑ testAccumulatingCombine
org.apache.beam.sdk.transforms.CombineTest$AccumulationTests ‑ testAccumulatingCombineEmpty
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testBasicCombine
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testBasicCombineEmpty
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testBinaryCombineFn
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testBinaryCombinePerKeyInstanceMethodReference
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testBinaryCombinePerKeyLambda
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testCombinePerKeyInstanceMethodReference
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testCombinePerKeyLambda
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testCombinePerKeyPrimitiveDisplayData
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testCombinePerKeyWithHotKeyFanoutPrimitiveDisplayData
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testHotKeyCombining
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testHotKeyCombiningWithAccumulationMode
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testSimpleCombine
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testSimpleCombineEmpty
org.apache.beam.sdk.transforms.CombineTest$CombineWithContextTests ‑ testHotKeyCombineWithSideInputs
org.apache.beam.sdk.transforms.CombineTest$CombineWithContextTests ‑ testSimpleCombineWithContext
org.apache.beam.sdk.transforms.CombineTest$CombineWithContextTests ‑ testSimpleCombineWithContextEmpty
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testCombineGloballyAsSingletonView
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testCombineGloballyInstanceMethodReference
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testCombineGloballyLambda
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testFixedWindowsCombine
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testFixedWindowsCombineWithContext
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testGlobalCombineWithDefaultsAndTriggers
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testSessionsCombine
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testSessionsCombineWithContext
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testSlidingWindowsCombine
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testSlidingWindowsCombineWithContext
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testWindowedCombineEmpty
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testWindowedCombineGloballyAsSingletonView
org.apache.beam.sdk.transforms.CountTest ‑ testCountGloballyBasic
org.apache.beam.sdk.transforms.CountTest ‑ testCountGloballyEmpty
org.apache.beam.sdk.transforms.CountTest ‑ testCountPerElementBasic
org.apache.beam.sdk.transforms.CountTest ‑ testCountPerElementEmpty
org.apache.beam.sdk.transforms.CreateTest ‑ testCreate
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateEmpty
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateEmptyIterableWithCoder
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateOfProvider
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateParameterizedType
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateTimestamped
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateTimestampedEmpty
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateWindowedValues
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateWindowedValuesEmpty
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateWithKVVoidType
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateWithNullsAndValues
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateWithUnserializableElements
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateWithVoidType
org.apache.beam.sdk.transforms.DeduplicateTest ‑ testEventTime
org.apache.beam.sdk.transforms.DeduplicateTest ‑ testInDifferentWindows
org.apache.beam.sdk.transforms.DistinctTest ‑ testDistinct
org.apache.beam.sdk.transforms.DistinctTest ‑ testDistinctEmpty
org.apache.beam.sdk.transforms.DistinctTest ‑ testDistinctWithRepresentativeValue
org.apache.beam.sdk.transforms.DistinctTest ‑ testWindowedDistinct
org.apache.beam.sdk.transforms.DistinctTest ‑ withLambdaRepresentativeValuesFnAndTypeDescriptorShouldApplyFn
org.apache.beam.sdk.transforms.FilterTest ‑ testFilterByMethodReferenceWithLambda
org.apache.beam.sdk.transforms.FilterTest ‑ testFilterByPredicate
org.apache.beam.sdk.transforms.FilterTest ‑ testFilterByPredicateWithLambda
org.apache.beam.sdk.transforms.FilterTest ‑ testFilterByProcessFunction
org.apache.beam.sdk.transforms.FilterTest ‑ testFilterEqual
org.apache.beam.sdk.transforms.FilterTest ‑ testFilterGreaterThan
org.apache.beam.sdk.transforms.FilterTest ‑ testFilterGreaterThanEq
org.apache.beam.sdk.transforms.FilterTest ‑ testFilterLessThan
org.apache.beam.sdk.transforms.FilterTest ‑ testFilterLessThanEq
org.apache.beam.sdk.transforms.FilterTest ‑ testIdentityFilterByPredicate
org.apache.beam.sdk.transforms.FilterTest ‑ testIdentityFilterByPredicateWithLambda
org.apache.beam.sdk.transforms.FilterTest ‑ testNoFilterByPredicate
org.apache.beam.sdk.transforms.FilterTest ‑ testNoFilterByPredicateWithLambda
org.apache.beam.sdk.transforms.FlatMapElementsTest ‑ testExceptionAsMap
org.apache.beam.sdk.transforms.FlatMapElementsTest ‑ testFlatMapBasicWithLambda
org.apache.beam.sdk.transforms.FlatMapElementsTest ‑ testFlatMapBasicWithSideInput
org.apache.beam.sdk.transforms.FlatMapElementsTest ‑ testFlatMapFnOutputTypeDescriptor
org.apache.beam.sdk.transforms.FlatMapElementsTest ‑ testFlatMapInferableFunction
org.apache.beam.sdk.transforms.FlatMapElementsTest ‑ testFlatMapMethodReference
org.apache.beam.sdk.transforms.FlatMapElementsTest ‑ testFlatMapSimpleFunction
org.apache.beam.sdk.transforms.FlatMapElementsTest ‑ testFlatMapWithFailuresLambda
org.apache.beam.sdk.transforms.FlatMapElementsTest ‑ testFlatMapWithFailuresSimpleFunction
org.apache.beam.sdk.transforms.FlatMapElementsTest ‑ testVoidValues
org.apache.beam.sdk.transforms.FlattenTest ‑ testCompatibleWindowFnPropagation
org.apache.beam.sdk.transforms.FlattenTest ‑ testEmptyFlattenAsSideInput
org.apache.beam.sdk.transforms.FlattenTest ‑ testEqualWindowFnPropagation
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenInputMultipleCopies
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenIterables
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenIterablesCollections
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenIterablesEmpty
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenIterablesLists
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenIterablesSets
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenMultipleCoders
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenMultiplePCollectionsHavingMultipleConsumers
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenNoListsNoCoder
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenPCollections
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenPCollectionsEmpty
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenPCollectionsEmptyThenParDo
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenPCollectionsSingletonList
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenPCollectionsThenParDo
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenWithDifferentInputAndOutputCoders
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenWithDifferentInputAndOutputCoders2
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testGroupByKey
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testGroupByKeyEmpty
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testGroupByKeyWithBadEqualsHashCode
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testLargeKeys100KB
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testLargeKeys10KB
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testLargeKeys10MB
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testLargeKeys1MB
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testRemerge
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testTimestampCombinerEarliest
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testTimestampCombinerLatest
org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests ‑ testGroupByKeyAndWindows
org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests ‑ testGroupByKeyMergingWindows
org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests ‑ testGroupByKeyMultipleWindows
org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests ‑ testIdentityWindowFnPropagation
org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests ‑ testRewindowWithTimestampCombiner
org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests ‑ testWindowFnPostMerging
org.apache.beam.sdk.transforms.ImpulseTest ‑ testImpulse
org.apache.beam.sdk.transforms.KeysTest ‑ testKeys
org.apache.beam.sdk.transforms.KeysTest ‑ testKeysEmpty
org.apache.beam.sdk.transforms.KvSwapTest ‑ testKvSwap
org.apache.beam.sdk.transforms.KvSwapTest ‑ testKvSwapEmpty
org.apache.beam.sdk.transforms.LatestTest ‑ testGloballyEmptyCollection
org.apache.beam.sdk.transforms.LatestTest ‑ testGloballyEventTimestamp
org.apache.beam.sdk.transforms.LatestTest ‑ testPerKeyEmptyCollection
org.apache.beam.sdk.transforms.LatestTest ‑ testPerKeyEventTimestamp
org.apache.beam.sdk.transforms.MapElementsTest ‑ testExceptionAsMap
org.apache.beam.sdk.transforms.MapElementsTest ‑ testInferableFunctionOutputTypeDescriptor
org.apache.beam.sdk.transforms.MapElementsTest ‑ testMapBasicProcessFunction
org.apache.beam.sdk.transforms.MapElementsTest ‑ testMapBasicWithSideInput
org.apache.beam.sdk.transforms.MapElementsTest ‑ testMapInferableFunction
org.apache.beam.sdk.transforms.MapElementsTest ‑ testMapLambda
org.apache.beam.sdk.transforms.MapElementsTest ‑ testMapMethodReference
org.apache.beam.sdk.transforms.MapElementsTest ‑ testMapWithFailuresLambda
org.apache.beam.sdk.transforms.MapElementsTest ‑ testMapWithFailuresSimpleFunction
org.apache.beam.sdk.transforms.MapElementsTest ‑ testMapWrappedLambda
org.apache.beam.sdk.transforms.MapElementsTest ‑ testPrimitiveDisplayData
org.apache.beam.sdk.transforms.MapElementsTest ‑ testSimpleFunctionOutputTypeDescriptor
org.apache.beam.sdk.transforms.MapElementsTest ‑ testVoidValues
org.apache.beam.sdk.transforms.MapKeysTest ‑ testMapKeysEmpty
org.apache.beam.sdk.transforms.MapKeysTest ‑ testMapKeysInto
org.apache.beam.sdk.transforms.MapKeysTest ‑ testMapKeysWithFailures
org.apache.beam.sdk.transforms.MapValuesTest ‑ testMapValuesEmpty
org.apache.beam.sdk.transforms.MapValuesTest ‑ testMapValuesInto
org.apache.beam.sdk.transforms.MapValuesTest ‑ testMapValuesWithFailures
org.apache.beam.sdk.transforms.PTransformTest ‑ testComposeBasicSerializableFunction
org.apache.beam.sdk.transforms.ParDoTest$BasicTests ‑ testParDo
org.apache.beam.sdk.transforms.ParDoTest$BasicTests ‑ testParDoEmpty
org.apache.beam.sdk.transforms.ParDoTest$BasicTests ‑ testParDoEmptyOutputs
org.apache.beam.sdk.transforms.ParDoTest$BasicTests ‑ testParDoInCustomTransform
org.apache.beam.sdk.transforms.ParDoTest$BasicTests ‑ testPipelineOptionsParameter
org.apache.beam.sdk.transforms.ParDoTest$BundleInvariantsTests ‑ testWatermarkUpdateMidBundle
org.apache.beam.sdk.transforms.ParDoTest$KeyTests ‑ testKeyInOnTimer
org.apache.beam.sdk.transforms.ParDoTest$KeyTests ‑ testKeyInOnTimerWithGenericKey
org.apache.beam.sdk.transforms.ParDoTest$KeyTests ‑ testKeyInOnTimerWithWrongKeyType
org.apache.beam.sdk.transforms.ParDoTest$KeyTests ‑ testKeyInOnTimerWithoutKV
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests ‑ testParDoWithErrorInFinishBatch
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests ‑ testParDoWithErrorInProcessElement
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests ‑ testParDoWithErrorInStartBatch
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests ‑ testWindowingInStartAndFinishBundle
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testMainOutputApplyTaggedOutputNoCoder
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testMainOutputUnregisteredExplicitCoder
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testMultiOutputChaining
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testMultiOutputParDoWithSideInputs
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testMultiOutputParDoWithSideInputsIsCumulative
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoEmptyWithTaggedOutput
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoReadingFromUnknownSideInput
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWithEmptyTaggedOutput
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWithOnlyTaggedOutput
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWithSideInputs
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWithSideInputsIsCumulative
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWithTaggedOutput
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWritingToUndeclaredTag
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSameSideInputReadTwice
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputAnnotation
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputAnnotationFailedValidationIterableType
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputAnnotationFailedValidationListType
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputAnnotationFailedValidationMapType
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputAnnotationFailedValidationMissing
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputAnnotationFailedValidationMultiMapType
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputAnnotationFailedValidationSingletonType
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputAnnotationWithMultipleSideInputs
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputsWithMultipleWindows
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testTaggedOutputUnknownCoder
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testBagStateCoderInference
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testBagStateCoderInferenceFailure
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testCombiningStateCoderInference
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testCombiningStateCoderInferenceFailure
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testMapStateCoderInference
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testMapStateCoderInferenceFailure
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testSetStateCoderInference
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testSetStateCoderInferenceFailure
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testBagState
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testBagStateSideInput
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testCoderInferenceOfList
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testCombiningState
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testCombiningStateParameterSuperclass
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testMapState
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testMapStateNoReadOnComputeIfAbsentAndPutIfAbsentInsertsElement
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testSetState
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testSetStateNoReadOnAddIfAbsentInsertsElement
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testValueStateDedup
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testValueStateFixedWindows
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testValueStateSameId
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testValueStateSimple
org.apache.beam.sdk.transforms.ParDoTest$StateTests ‑ testValueStateTaggedOutput
org.apache.beam.sdk.transforms.ParDoTest$TimerCoderInferenceTests ‑ testValueStateCoderInference
org.apache.beam.sdk.transforms.ParDoTest$TimerCoderInferenceTests ‑ testValueStateCoderInferenceFailure
org.apache.beam.sdk.transforms.ParDoTest$TimerCoderInferenceTests ‑ testValueStateCoderInferenceFromInputCoder
org.apache.beam.sdk.transforms.ParDoTest$TimerFamilyTests ‑ testTimerFamilyAndTimerBounded
org.apache.beam.sdk.transforms.ParDoTest$TimerFamilyTests ‑ testTimerFamilyAndTimerUnbounded
org.apache.beam.sdk.transforms.ParDoTest$TimerFamilyTests ‑ testTimerFamilyEventTimeBounded
org.apache.beam.sdk.transforms.ParDoTest$TimerFamilyTests ‑ testTimerFamilyEventTimeUnbounded
org.apache.beam.sdk.transforms.ParDoTest$TimerFamilyTests ‑ testTimerWithMultipleTimerFamilyBounded
org.apache.beam.sdk.transforms.ParDoTest$TimerFamilyTests ‑ testTimerWithMultipleTimerFamilyUnbounded
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ duplicateTimerSetting
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testClearEventTimeTimer
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testClearUnsetEventTimeTimer
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testEventTimeTimerAbsolute
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testEventTimeTimerAlignAfterGcTimeUnbounded
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testEventTimeTimerAlignBounded
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testEventTimeTimerAlignUnbounded
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testEventTimeTimerBounded
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testEventTimeTimerCanBeReset
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testEventTimeTimerMultipleKeys
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testEventTimeTimerSetWithinAllowedLateness
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testEventTimeTimerUnbounded
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testGbkFollowedByUserTimers
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testNoOutputTimestampDefaultBounded
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testNoOutputTimestampDefaultStreaming
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testOutOfBoundsEventTimeTimer
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testOutOfBoundsEventTimeTimerHold
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testOutputTimestampDefaultBounded
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testPipelineOptionsParameterOnTimer
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testSetAndClearEventTimeTimer
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testSetEventTimerAfterClear
org.apache.beam.sdk.transforms.ParDoTest$TimerTests ‑ testTimerReceivedInOriginalWindow
org.apache.beam.sdk.transforms.ParDoTest$TimestampTests ‑ testOnTimerTimestampSkew
org.apache.beam.sdk.transforms.ParDoTest$TimestampTests ‑ testParDoOutputWithTimestamp
org.apache.beam.sdk.transforms.ParDoTest$TimestampTests ‑ testParDoShiftTimestamp
org.apache.beam.sdk.transforms.ParDoTest$TimestampTests ‑ testParDoShiftTimestampInvalid
org.apache.beam.sdk.transforms.ParDoTest$TimestampTests ‑ testParDoShiftTimestampInvalidZeroAllowed
org.apache.beam.sdk.transforms.ParDoTest$TimestampTests ‑ testParDoShiftTimestampUnlimited
org.apache.beam.sdk.transforms.ParDoTest$TimestampTests ‑ testParDoTaggedOutputWithTimestamp
org.apache.beam.sdk.transforms.PartitionTest ‑ testDroppedPartition
org.apache.beam.sdk.transforms.PartitionTest ‑ testEvenOddPartition
org.apache.beam.sdk.transforms.PartitionTest ‑ testModPartition
org.apache.beam.sdk.transforms.PartitionTest ‑ testModPartitionWithLambda
org.apache.beam.sdk.transforms.PartitionTest ‑ testOutOfBoundsPartitions
org.apache.beam.sdk.transforms.PartitionTest ‑ testPartitionFnOutputTypeDescriptorRaw
org.apache.beam.sdk.transforms.PartitionTest ‑ testPartitionWithSideInputs
org.apache.beam.sdk.transforms.PerKeyOrderingTest ‑ testMultipleStatefulOrderingWithShuffle
org.apache.beam.sdk.transforms.PerKeyOrderingTest ‑ testMultipleStatefulOrderingWithoutShuffle
org.apache.beam.sdk.transforms.PerKeyOrderingTest ‑ testSingleCallOrderingWithShuffle
org.apache.beam.sdk.transforms.PerKeyOrderingTest ‑ testSingleCallOrderingWithoutShuffle
org.apache.beam.sdk.transforms.RedistributeTest ‑ testAssignShardFn
org.apache.beam.sdk.transforms.RedistributeTest ‑ testJustRedistribute
org.apache.beam.sdk.transforms.RedistributeTest ‑ testRedistributeAfterFixedWindows
org.apache.beam.sdk.transforms.RedistributeTest ‑ testRedistributeAfterFixedWindowsAndGroupByKey
org.apache.beam.sdk.transforms.RedistributeTest ‑ testRedistributeAfterSessionsAndGroupByKey
org.apache.beam.sdk.transforms.RedistributeTest ‑ testRedistributeAfterSlidingWindows
org.apache.beam.sdk.transforms.RedistributeTest ‑ testRedistributeAfterSlidingWindowsAndGroupByKey
org.apache.beam.sdk.transforms.RedistributeTest ‑ testRedistributePreservesMetadata
org.apache.beam.sdk.transforms.RedistributeTest ‑ testRedistributePreservesTimestamps
org.apache.beam.sdk.transforms.RedistributeTest ‑ testRedistributeWithTimestampsStreaming
org.apache.beam.sdk.transforms.RegexTest ‑ testAllMatches
org.apache.beam.sdk.transforms.RegexTest ‑ testFind
org.apache.beam.sdk.transforms.RegexTest ‑ testFindAllGroups
org.apache.beam.sdk.transforms.RegexTest ‑ testFindGroup
org.apache.beam.sdk.transforms.RegexTest ‑ testFindNameGroup
org.apache.beam.sdk.transforms.RegexTest ‑ testFindNameNone
org.apache.beam.sdk.transforms.RegexTest ‑ testFindNone
org.apache.beam.sdk.transforms.RegexTest ‑ testKVFind
org.apache.beam.sdk.transforms.RegexTest ‑ testKVFindName
org.apache.beam.sdk.transforms.RegexTest ‑ testKVFindNameNone
org.apache.beam.sdk.transforms.RegexTest ‑ testKVFindNone
org.apache.beam.sdk.transforms.RegexTest ‑ testKVMatches
org.apache.beam.sdk.transforms.RegexTest ‑ testKVMatchesName
org.apache.beam.sdk.transforms.RegexTest ‑ testKVMatchesNameNone
org.apache.beam.sdk.transforms.RegexTest ‑ testKVMatchesNone
org.apache.beam.sdk.transforms.RegexTest ‑ testMatches
org.apache.beam.sdk.transforms.RegexTest ‑ testMatchesGroup
org.apache.beam.sdk.transforms.RegexTest ‑ testMatchesName
org.apache.beam.sdk.transforms.RegexTest ‑ testMatchesNameNone
org.apache.beam.sdk.transforms.RegexTest ‑ testMatchesNone
org.apache.beam.sdk.transforms.RegexTest ‑ testReplaceAll
org.apache.beam.sdk.transforms.RegexTest ‑ testReplaceAllMixed
org.apache.beam.sdk.transforms.RegexTest ‑ testReplaceFirst
org.apache.beam.sdk.transforms.RegexTest ‑ testReplaceFirstMixed
org.apache.beam.sdk.transforms.RegexTest ‑ testSplits
org.apache.beam.sdk.transforms.RegexTest ‑ testSplitsWithEmpty
org.apache.beam.sdk.transforms.RegexTest ‑ testSplitsWithoutEmpty
org.apache.beam.sdk.transforms.ReifyTest ‑ extractFromValuesSucceeds
org.apache.beam.sdk.transforms.ReifyTest ‑ extractFromValuesWhenValueTimestampedLaterSucceeds
org.apache.beam.sdk.transforms.ReifyTest ‑ globalWindowNoKeys
org.apache.beam.sdk.transforms.ReifyTest ‑ timestampedValuesSucceeds
org.apache.beam.sdk.transforms.ReifyTest ‑ timestampsSucceeds
org.apache.beam.sdk.transforms.ReifyTest ‑ windowsInValueSucceeds
org.apache.beam.sdk.transforms.ReifyTimestampsTest ‑ extractFromValuesSucceeds
org.apache.beam.sdk.transforms.ReifyTimestampsTest ‑ extractFromValuesWhenValueTimestampedLaterSucceeds
org.apache.beam.sdk.transforms.ReifyTimestampsTest ‑ inValuesSucceeds
org.apache.beam.sdk.transforms.ReshuffleTest ‑ testAssignShardFn
org.apache.beam.sdk.transforms.ReshuffleTest ‑ testJustReshuffle
org.apache.beam.sdk.transforms.ReshuffleTest ‑ testReshuffleAfterFixedWindows
org.apache.beam.sdk.transforms.ReshuffleTest ‑ testReshuffleAfterFixedWindowsAndGroupByKey
org.apache.beam.sdk.transforms.ReshuffleTest ‑ testReshuffleAfterSessionsAndGroupByKey
org.apache.beam.sdk.transforms.ReshuffleTest ‑ testReshuffleAfterSlidingWindows
org.apache.beam.sdk.transforms.ReshuffleTest ‑ testReshuffleAfterSlidingWindowsAndGroupByKey
org.apache.beam.sdk.transforms.ReshuffleTest ‑ testReshufflePreservesMetadata
org.apache.beam.sdk.transforms.ReshuffleTest ‑ testReshufflePreservesTimestamps
org.apache.beam.sdk.transforms.ReshuffleTest ‑ testReshuffleWithTimestampsStreaming
org.apache.beam.sdk.transforms.SampleTest$MiscTest ‑ testSample
org.apache.beam.sdk.transforms.SampleTest$MiscTest ‑ testSampleAny
org.apache.beam.sdk.transforms.SampleTest$MiscTest ‑ testSampleAnyEmpty
org.apache.beam.sdk.transforms.SampleTest$MiscTest ‑ testSampleAnyInsufficientElements
org.apache.beam.sdk.transforms.SampleTest$MiscTest ‑ testSampleAnyZero
org.apache.beam.sdk.transforms.SampleTest$MiscTest ‑ testSampleEmpty
org.apache.beam.sdk.transforms.SampleTest$MiscTest ‑ testSampleInsufficientElements
org.apache.beam.sdk.transforms.SampleTest$MiscTest ‑ testSampleMultiplicity
org.apache.beam.sdk.transforms.SampleTest$MiscTest ‑ testSampleZero
org.apache.beam.sdk.transforms.SampleTest$PickAnyTest ‑ testPickAny[limit_0]
org.apache.beam.sdk.transforms.SampleTest$PickAnyTest ‑ testPickAny[limit_17]
org.apache.beam.sdk.transforms.SampleTest$PickAnyTest ‑ testPickAny[limit_1]
org.apache.beam.sdk.transforms.SampleTest$PickAnyTest ‑ testPickAny[limit_34]
org.apache.beam.sdk.transforms.SampleTest$PickAnyTest ‑ testPickAny[limit_35]
org.apache.beam.sdk.transforms.SampleTest$PickAnyTest ‑ testPickAny[limit_36]
org.apache.beam.sdk.transforms.SampleTest$PickAnyTest ‑ testPickAny[limit_70]
org.apache.beam.sdk.transforms.SetsTest ‑ testExcept
org.apache.beam.sdk.transforms.SetsTest ‑ testExceptAll
org.apache.beam.sdk.transforms.SetsTest ‑ testExceptAllCollectionList
org.apache.beam.sdk.transforms.SetsTest ‑ testExceptCollectionList
org.apache.beam.sdk.transforms.SetsTest ‑ testIntersection
org.apache.beam.sdk.transforms.SetsTest ‑ testIntersectionAll
org.apache.beam.sdk.transforms.SetsTest ‑ testIntersectionAllCollectionList
org.apache.beam.sdk.transforms.SetsTest ‑ testIntersectionCollectionList
org.apache.beam.sdk.transforms.SetsTest ‑ testUnion
org.apache.beam.sdk.transforms.SetsTest ‑ testUnionAll
org.apache.beam.sdk.transforms.SetsTest ‑ testUnionAllCollections
org.apache.beam.sdk.transforms.SetsTest ‑ testUnionCollectionList
org.apache.beam.sdk.transforms.SplittableDoFnTest ‑ testAdditionalOutputBounded
org.apache.beam.sdk.transforms.SplittableDoFnTest ‑ testBoundedness
org.apache.beam.sdk.transforms.SplittableDoFnTest ‑ testLateData
org.apache.beam.sdk.transforms.SplittableDoFnTest ‑ testOutputAfterCheckpointBounded
org.apache.beam.sdk.transforms.SplittableDoFnTest ‑ testPairWithIndexBasicBounded
org.apache.beam.sdk.transforms.SplittableDoFnTest ‑ testPairWithIndexWindowedTimestampedBounded
org.apache.beam.sdk.transforms.SplittableDoFnTest ‑ testSideInputBounded
org.apache.beam.sdk.transforms.SplittableDoFnTest ‑ testWindowedSideInputBounded
org.apache.beam.sdk.transforms.SplittableDoFnTest ‑ testWindowedSideInputWithCheckpointsBounded
org.apache.beam.sdk.transforms.ToStringTest ‑ testToStringIterable
org.apache.beam.sdk.transforms.ToStringTest ‑ testToStringIterableWithDelimiter
org.apache.beam.sdk.transforms.ToStringTest ‑ testToStringKV
org.apache.beam.sdk.transforms.ToStringTest ‑ testToStringKVWithDelimiter
org.apache.beam.sdk.transforms.ToStringTest ‑ testToStringOf
org.apache.beam.sdk.transforms.TopTest ‑ testTop
org.apache.beam.sdk.transforms.TopTest ‑ testTopEmpty
org.apache.beam.sdk.transforms.TopTest ‑ testTopZero
org.apache.beam.sdk.transforms.ValuesTest ‑ testValues
org.apache.beam.sdk.transforms.ValuesTest ‑ testValuesEmpty
org.apache.beam.sdk.transforms.WithFailuresTest ‑ testDirectException
org.apache.beam.sdk.transforms.WithFailuresTest ‑ testExceptionAsMap
org.apache.beam.sdk.transforms.WithKeysTest ‑ testConstantKeys
org.apache.beam.sdk.transforms.WithKeysTest ‑ testConstantVoidKeys
org.apache.beam.sdk.transforms.WithKeysTest ‑ testExtractKeys
org.apache.beam.sdk.transforms.WithKeysTest ‑ testKeySchemaCoderSet
org.apache.beam.sdk.transforms.WithKeysTest ‑ testWithKeysWithUnneededWithKeyTypeSucceeds
org.apache.beam.sdk.transforms.WithKeysTest ‑ withLambdaAndNoTypeDescriptorShouldThrow
org.apache.beam.sdk.transforms.WithKeysTest ‑ withLambdaAndParameterizedTypeDescriptorShouldSucceed
org.apache.beam.sdk.transforms.WithKeysTest ‑ withLambdaAndTypeDescriptorShouldSucceed
org.apache.beam.sdk.transforms.WithTimestampsTest ‑ withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed
org.apache.beam.sdk.transforms.WithTimestampsTest ‑ withTimestampsLambdaShouldApplyTimestamps
org.apache.beam.sdk.transforms.WithTimestampsTest ‑ withTimestampsShouldApplyTimestamps
org.apache.beam.sdk.transforms.WithTimestampsTest ‑ withTimestampsWithNullFnShouldThrowOnConstruction
org.apache.beam.sdk.transforms.errorhandling.ErrorHandlerTest ‑ testErrorHandlerWithBRHTransform
org.apache.beam.sdk.transforms.errorhandling.ErrorHandlerTest ‑ testNoUsageErrorHandlerUsage
org.apache.beam.sdk.transforms.join.CoGroupByKeyTest ‑ testCoGroupByKey
org.apache.beam.sdk.transforms.join.CoGroupByKeyTest ‑ testCoGroupByKeyGetOnly
org.apache.beam.sdk.transforms.join.CoGroupByKeyTest ‑ testCoGroupByKeyHandleResults
org.apache.beam.sdk.transforms.join.CoGroupByKeyTest ‑ testCoGroupByKeyWithWindowing
org.apache.beam.sdk.transforms.join.CoGroupByKeyTest ‑ testConsumingDoFn
org.apache.beam.sdk.transforms.windowing.WindowTest ‑ testMergingCustomWindows
org.apache.beam.sdk.transforms.windowing.WindowTest ‑ testMergingCustomWindowsKeyedCollection
org.apache.beam.sdk.transforms.windowing.WindowTest ‑ testMergingCustomWindowsWithoutCustomWindowTypes
org.apache.beam.sdk.transforms.windowing.WindowTest ‑ testNoWindowFnDoesNotReassignWindows
org.apache.beam.sdk.transforms.windowing.WindowTest ‑ testPrimitiveDisplayData
org.apache.beam.sdk.transforms.windowing.WindowTest ‑ testTimestampCombinerDefault
org.apache.beam.sdk.transforms.windowing.WindowTest ‑ testTimestampCombinerEndOfWindow
org.apache.beam.sdk.transforms.windowing.WindowingTest ‑ testEmptyInput
org.apache.beam.sdk.transforms.windowing.WindowingTest ‑ testMergingWindowing
org.apache.beam.sdk.transforms.windowing.WindowingTest ‑ testNonPartitioningWindowing
org.apache.beam.sdk.transforms.windowing.WindowingTest ‑ testPartitioningWindowing
org.apache.beam.sdk.transforms.windowing.WindowingTest ‑ testTextIoInput
org.apache.beam.sdk.transforms.windowing.WindowingTest ‑ testWindowPreservation
org.apache.beam.sdk.util.construction.DeduplicatedFlattenFactoryTest ‑ testOverride
org.apache.beam.sdk.util.construction.EmptyFlattenAsCreateFactoryTest ‑ testOverride
org.apache.beam.sdk.util.construction.UnboundedReadFromBoundedSourceTest ‑ testBoundedToUnboundedSourceAdapter
org.apache.beam.sdk.values.PCollectionRowTupleTest ‑ testComposePCollectionRowTuple
org.apache.beam.sdk.values.PCollectionTupleTest ‑ testComposePCollectionTuple
org.apache.beam.sdk.values.PDoneTest ‑ testEmptyTransform
org.apache.beam.sdk.values.PDoneTest ‑ testSimpleTransform