Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Default SchemaTransform configs to snake_case #31374

Merged
merged 6 commits into from
Jun 4, 2024

make more yaml snake_case changes

4c32a1a
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Merged

Default SchemaTransform configs to snake_case #31374

make more yaml snake_case changes
4c32a1a
Select commit
Loading
Failed to load commit list.
GitHub Actions / Test Results failed May 30, 2024 in 0s

1 parse errors, 1 fail, 15 skipped, 834 pass in 39m 24s

116 files  + 81    1 errors  115 suites  +80   39m 24s ⏱️ - 24m 18s
850 tests +714  834 ✅ +699  15 💤 +14  1 ❌ +1 
850 runs  +239  834 ✅ +233  15 💤 + 5  1 ❌ +1 

Results for commit 4c32a1a. ± Comparison against earlier commit 8ea294d.

Annotations

Check failure on line 0 in sdks/java/io/cdap/build/test-results/test/TEST-org.apache.beam.sdk.io.cdap.CdapIOTest.xml

See this annotation in the file changed.

@github-actions github-actions / Test Results

Error processing result file

CData section too big found, line 26744, column 172832 (TEST-org.apache.beam.sdk.io.cdap.CdapIOTest.xml, line 26744)
Raw output
sdks/java/io/cdap/build/test-results/test/TEST-org.apache.beam.sdk.io.cdap.CdapIOTest.xml

Check warning on line 0 in org.apache.beam.sdk.io.jms.JmsIOTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

testCheckpointMark[with client class class org.apache.qpid.jms.JmsConnectionFactory] (org.apache.beam.sdk.io.jms.JmsIOTest) failed

sdks/java/io/jms/build/test-results/test/TEST-org.apache.beam.sdk.io.jms.JmsIOTest.xml [took 0s]
Raw output
java.lang.AssertionError: Failed at 1-th message
	at org.junit.Assert.fail(Assert.java:89)
	at org.junit.Assert.assertTrue(Assert.java:42)
	at org.apache.beam.sdk.io.jms.JmsIOTest.testCheckpointMark(JmsIOTest.java:489)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:331)
	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
	at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
	at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
	at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
	at org.junit.runners.Suite.runChild(Suite.java:128)
	at org.junit.runners.Suite.runChild(Suite.java:27)
	at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
	at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:112)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:40)
	at org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:60)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:52)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
	at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker$2.run(TestWorker.java:176)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
	at org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
	at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:113)
	at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:65)
	at worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
	at worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

15 skipped tests found

There are 15 skipped tests, see "Raw output" for the full list of skipped tests.
Raw output
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenWithCache_thenRequestsResponsesCachedUsingCustom
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testByteType
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ byteTypes
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ byteSequenceTypes
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ byteTypes
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testByteSequenceType
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testTimeContaining
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ byteSequenceTypes
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testByteType
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ byteTypes
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ byteSequenceTypes
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithoutBoundedWrapper
org.apache.beam.sdk.io.kudu.KuduIOTest ‑ testWrite
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testRead
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadNoClientId

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

850 tests found (test 1 to 670)

There are 850 tests, see "Raw output" for the list of tests 1 to 670.
Raw output
org.apache.beam.io.debezium.DebeziumIOTest ‑ testSourceConnectorNullPassword
org.apache.beam.io.debezium.DebeziumIOTest ‑ testSourceConnectorNullUsernameAndPassword
org.apache.beam.io.debezium.DebeziumIOTest ‑ testSourceConnectorUsernamePassword
org.apache.beam.io.debezium.DebeziumIOTest ‑ testSourceMySqlConnectorValidConfiguration
org.apache.beam.io.debezium.DebeziumReadSchemaTransformTest ‑ testNoProblem[0]
org.apache.beam.io.debezium.DebeziumReadSchemaTransformTest ‑ testNoProblem[1]
org.apache.beam.io.debezium.DebeziumReadSchemaTransformTest ‑ testWrongHost[0]
org.apache.beam.io.debezium.DebeziumReadSchemaTransformTest ‑ testWrongHost[1]
org.apache.beam.io.debezium.DebeziumReadSchemaTransformTest ‑ testWrongPassword[0]
org.apache.beam.io.debezium.DebeziumReadSchemaTransformTest ‑ testWrongPassword[1]
org.apache.beam.io.debezium.DebeziumReadSchemaTransformTest ‑ testWrongPort[0]
org.apache.beam.io.debezium.DebeziumReadSchemaTransformTest ‑ testWrongPort[1]
org.apache.beam.io.debezium.DebeziumReadSchemaTransformTest ‑ testWrongUser[0]
org.apache.beam.io.debezium.DebeziumReadSchemaTransformTest ‑ testWrongUser[1]
org.apache.beam.io.debezium.KafkaConnectSchemaTest ‑ testSimpleSourceRecordSchemaConversion
org.apache.beam.io.debezium.KafkaConnectSchemaTest ‑ testTimestampRequired
org.apache.beam.io.debezium.KafkaSourceConsumerFnTest ‑ testKafkaSourceConsumerFn
org.apache.beam.io.debezium.KafkaSourceConsumerFnTest ‑ testStoppableKafkaSourceConsumerFn
org.apache.beam.io.debezium.OffsetTrackerTest ‑ testRestrictByAmountOfTime
org.apache.beam.io.debezium.OffsetTrackerTest ‑ testRestrictByNumberOfRecords
org.apache.beam.io.debezium.SourceRecordJsonTest ‑ testSourceRecordJson
org.apache.beam.io.debezium.SourceRecordJsonTest ‑ testSourceRecordJsonWhenSourceRecordIsNull
org.apache.beam.io.requestresponse.CacheTest ‑ givenNonDeterministicCoder_readUsingRedis_throwsError
org.apache.beam.io.requestresponse.CacheTest ‑ givenNonDeterministicCoder_writeUsingRedis_throwsError
org.apache.beam.io.requestresponse.CacheTest ‑ givenWrongRedisURI_throwsError
org.apache.beam.io.requestresponse.CallShouldBackoffBasedOnRejectionProbabilityTest ‑ testValue
org.apache.beam.io.requestresponse.CallTest ‑ givenCallerNotSerializable_throwsError
org.apache.beam.io.requestresponse.CallTest ‑ givenCallerThrowsQuotaException_emitsIntoFailurePCollection
org.apache.beam.io.requestresponse.CallTest ‑ givenCallerThrowsTimeoutException_emitsFailurePCollection
org.apache.beam.io.requestresponse.CallTest ‑ givenCallerThrowsUserCodeExecutionException_emitsIntoFailurePCollection
org.apache.beam.io.requestresponse.CallTest ‑ givenCallerTimeout_emitsFailurePCollection
org.apache.beam.io.requestresponse.CallTest ‑ givenSetupTeardownNotSerializable_throwsError
org.apache.beam.io.requestresponse.CallTest ‑ givenSetupThrowsQuotaException_throwsError
org.apache.beam.io.requestresponse.CallTest ‑ givenSetupThrowsTimeoutException_throwsError
org.apache.beam.io.requestresponse.CallTest ‑ givenSetupThrowsUserCodeExecutionException_throwsError
org.apache.beam.io.requestresponse.CallTest ‑ givenSetupTimeout_throwsError
org.apache.beam.io.requestresponse.CallTest ‑ givenTeardownThrowsQuotaException_throwsError
org.apache.beam.io.requestresponse.CallTest ‑ givenTeardownThrowsTimeoutException_throwsError
org.apache.beam.io.requestresponse.CallTest ‑ givenTeardownThrowsUserCodeExecutionException_throwsError
org.apache.beam.io.requestresponse.CallTest ‑ givenTeardownTimeout_throwsError
org.apache.beam.io.requestresponse.CallTest ‑ givenValidCaller_emitValidResponse
org.apache.beam.io.requestresponse.CallerTest ‑ canSerializeImplementingClasses
org.apache.beam.io.requestresponse.CallerTest ‑ canSerializeWhenUsedInDoFn
org.apache.beam.io.requestresponse.CallerTest ‑ canSignalQuotaException
org.apache.beam.io.requestresponse.CallerTest ‑ canSignalTimeoutException
org.apache.beam.io.requestresponse.RepeaterTest ‑ givenCallerNonRepeatableError_emitsIntoFailurePCollection
org.apache.beam.io.requestresponse.RepeaterTest ‑ givenCallerQuotaErrorsExceedsLimit_emitsIntoFailurePCollection
org.apache.beam.io.requestresponse.RepeaterTest ‑ givenCallerRemoteSystemExceptionExceedsLimit_emitsIntoFailurePCollection
org.apache.beam.io.requestresponse.RepeaterTest ‑ givenCallerTimeoutErrorsExceedsLimit_emitsIntoFailurePCollection
org.apache.beam.io.requestresponse.RepeaterTest ‑ givenRepeatableErrorBelowLimit_emitsIntoOutputPCollection
org.apache.beam.io.requestresponse.RepeaterTest ‑ givenSetupNonRepeatableError_throws
org.apache.beam.io.requestresponse.RepeaterTest ‑ givenSetupQuotaErrorsExceedsLimit_throws
org.apache.beam.io.requestresponse.RepeaterTest ‑ givenSetupRemoteSystemErrorsExceedsLimit_throws
org.apache.beam.io.requestresponse.RepeaterTest ‑ givenSetupTimeoutErrorsExceedsLimit_throws
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenCallerAndSetupTeardown_thenCallerInvokesSetupTeardown
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenCallerOnly_thenProcessesRequestsWithDefaultFeatures
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenCustomBackoff_thenBackoffBehaviorCustom
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenCustomCallShouldBackoff_thenComputeUsingCustom
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenCustomSleeper_thenSleepBehaviorCustom
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenDefaultConfiguration_shouldRepeatFailedRequests
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenDefaultConfiguration_usesDefaultBackoffSupplier
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenDefaultConfiguration_usesDefaultCallShouldBackoff
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenDefaultConfiguration_usesDefaultSleeper
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenWithCache_thenRequestsResponsesCachedUsingCustom
org.apache.beam.io.requestresponse.RequestResponseIOTest ‑ givenWithoutRepeater_shouldNotRepeatRequests
org.apache.beam.io.requestresponse.SetupTeardownTest ‑ canSerializeImplementingClasses
org.apache.beam.io.requestresponse.SetupTeardownTest ‑ canSerializeWhenUsedInDoFn
org.apache.beam.io.requestresponse.SetupTeardownTest ‑ canSignalQuotaException
org.apache.beam.io.requestresponse.SetupTeardownTest ‑ canSignalTimeoutException
org.apache.beam.io.requestresponse.WindowedCallShouldBackoffTest ‑ resetsComputationPerWindow
org.apache.beam.sdk.io.amqp.AmqpIOTest ‑ testRead
org.apache.beam.sdk.io.amqp.AmqpIOTest ‑ testWrite
org.apache.beam.sdk.io.amqp.AmqpMessageCoderTest ‑ encodeDecode
org.apache.beam.sdk.io.amqp.AmqpMessageCoderTest ‑ encodeDecodeLargeMessage
org.apache.beam.sdk.io.amqp.AmqpMessageCoderTest ‑ encodeDecodeTooMuchLargerMessage
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testCustomMapperImplDelete
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testCustomMapperImplWrite
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testDelete
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testRead
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testReadAllQuery
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testReadAllRingRange
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testReadWithMapper
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testReadWithQuery
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testReadWithUnfilteredQuery
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testWrapAroundRingRanges
org.apache.beam.sdk.io.cassandra.CassandraIOTest ‑ testWrite
org.apache.beam.sdk.io.cassandra.SplitGeneratorTest ‑ testDisorderedRing
org.apache.beam.sdk.io.cassandra.SplitGeneratorTest ‑ testGenerateSegments
org.apache.beam.sdk.io.cassandra.SplitGeneratorTest ‑ testRotatedRing
org.apache.beam.sdk.io.cassandra.SplitGeneratorTest ‑ testZeroSizeRange
org.apache.beam.sdk.io.cdap.ConfigWrapperTest ‑ testBuildingPluginConfigFromJsonFile
org.apache.beam.sdk.io.cdap.ConfigWrapperTest ‑ testBuildingPluginConfigFromJsonString
org.apache.beam.sdk.io.cdap.ConfigWrapperTest ‑ testBuildingPluginConfigFromParamsMap
org.apache.beam.sdk.io.cdap.PluginConfigInstantiationUtilsTest ‑ testBuildingPluginConfigFromEmptyParamsMap
org.apache.beam.sdk.io.cdap.PluginConfigInstantiationUtilsTest ‑ testBuildingPluginConfigFromNullClassFail
org.apache.beam.sdk.io.cdap.PluginConfigInstantiationUtilsTest ‑ testBuildingPluginConfigFromParamsMap
org.apache.beam.sdk.io.cdap.PluginTest ‑ testBuildingSourcePluginWithCDAPClasses
org.apache.beam.sdk.io.cdap.PluginTest ‑ testSettingPluginType
org.apache.beam.sdk.io.cdap.PluginTest ‑ testSettingPluginTypeFailed
org.apache.beam.sdk.io.cdap.context.BatchContextImplTest ‑ getFailureCollector
org.apache.beam.sdk.io.cdap.context.BatchContextImplTest ‑ getLogicalStartTime
org.apache.beam.sdk.io.cdap.context.BatchSinkContextImplTest ‑ getFailureCollector
org.apache.beam.sdk.io.cdap.context.BatchSinkContextImplTest ‑ getLogicalStartTime
org.apache.beam.sdk.io.cdap.context.BatchSourceContextImplTest ‑ getFailureCollector
org.apache.beam.sdk.io.cdap.context.BatchSourceContextImplTest ‑ getLogicalStartTime
org.apache.beam.sdk.io.cdap.context.FailureCollectorWrapperTest ‑ addFailure
org.apache.beam.sdk.io.cdap.context.FailureCollectorWrapperTest ‑ getOrThrowException
org.apache.beam.sdk.io.cdap.context.FailureCollectorWrapperTest ‑ getValidationFailures
org.apache.beam.sdk.io.cdap.context.FailureCollectorWrapperTest ‑ shouldNotThrowForSchemaFieldValidation
org.apache.beam.sdk.io.cdap.context.StreamingSourceContextImplTest ‑ getLogicalStartTime
org.apache.beam.sdk.io.clickhouse.AtomicInsertTest ‑ testAtomicInsert
org.apache.beam.sdk.io.clickhouse.AtomicInsertTest ‑ testIdempotentInsert
org.apache.beam.sdk.io.clickhouse.ClickHouseIOTest ‑ testArrayOfArrayOfInt64
org.apache.beam.sdk.io.clickhouse.ClickHouseIOTest ‑ testArrayOfPrimitiveTypes
org.apache.beam.sdk.io.clickhouse.ClickHouseIOTest ‑ testComplexTupleType
org.apache.beam.sdk.io.clickhouse.ClickHouseIOTest ‑ testInsertSql
org.apache.beam.sdk.io.clickhouse.ClickHouseIOTest ‑ testInt64
org.apache.beam.sdk.io.clickhouse.ClickHouseIOTest ‑ testInt64WithDefault
org.apache.beam.sdk.io.clickhouse.ClickHouseIOTest ‑ testNullableInt64
org.apache.beam.sdk.io.clickhouse.ClickHouseIOTest ‑ testPrimitiveTypes
org.apache.beam.sdk.io.clickhouse.ClickHouseIOTest ‑ testTupleType
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testEquivalentSchema
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseArray
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseArrayOfArrays
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseArrayOfNullable
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseBool
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseDate
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseDateTime
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseDefaultExpressionInt64
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseDefaultExpressionString
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseEnum16
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseEnum8
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseFixedString
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseFloat32
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseFloat64
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseInt16
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseInt32
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseInt64
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseInt8
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseNullableEnum16
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseNullableFixedString
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseNullableInt32
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseString
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseTupleDouble
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseTupleSingle
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseUInt16
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseUInt32
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseUInt64
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testParseUInt8
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testTupleComplex
org.apache.beam.sdk.io.clickhouse.TableSchemaTest ‑ testTupleNested
org.apache.beam.sdk.io.csv.CsvIOWriteDisplayDataTest ‑ csvFormatNotPredefined
org.apache.beam.sdk.io.csv.CsvIOWriteDisplayDataTest ‑ defaultPredefinedCsvFormat
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ headersWithCommentsWrittenFirstOnEachShard
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ headersWrittenFirstOnEachShard
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ nonNullCSVFormatHeaderWritesSelectedSchemaFields
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ nonNullHeaderCommentsRequiresHeaderMarker
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ nullCSVFormatHeaderWritesAllSchemaFields
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ withSkipHeaderRecordOnlyWritesRows
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ writesUserDefinedTypes
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ invalidCSVFormatHeader
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ invalidSchema
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withAllowDuplicateHeaderNamesDuplicatesRowFieldOutput
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withAllowMissingColumnNamesSettingThrowsException
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withAutoFlushThrowsException
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withCommentMarkerDoesNotEffectConversion
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withDelimiterDrivesCellBorders
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withEscapeDrivesOutput
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withHeaderCommentsDoesNotEffectConversion
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withHeaderDrivesFieldOrderSubsetOutput
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withIgnoreEmptyLinesDoesNotEffectOutput
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withIgnoreHeaderCaseThrowsException
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withIgnoreSurroundingSpacesThrowsException
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withNullStringReplacesNullValues
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withQuoteDrivesConversion
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withQuoteModeDrivesCellBoundaries
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withSystemRecordSeparatorDoesNotEffectOutput
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withTrailingDelimiterAppendsToLineEnd
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withTrimRemovesCellPadding
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ defaultFormat
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ excel
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ informixUnload
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ informixUnloadCsv
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ mySql
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ oracle
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ postgresqlCSV
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ postgresqlText
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ rfc4180
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ tdf
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testArrayPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testByteSequenceType
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testByteType
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testDoublyNestedRepeatedDataTypes
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testInvalidConfigsFailToBuild
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testNestedRepeatedDataTypes
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testNullableAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testReadWithPCollectionOfFilepatterns
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testReadWithSchemaFilePath
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testStreamingRead
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testTimeContaining
org.apache.beam.sdk.io.fileschematransform.AvroReadSchemaTransformFormatProviderTest ‑ testWriteAndReadWithSchemaTransforms
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ allPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ arrayPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ byteSequenceTypes
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ byteTypes
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ csvConfigurationSet
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ doublyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ doublyNestedDataTypesRepeat
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ invalidConfigurationWithParquet
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ invalidConfigurationWithXml
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ nullableAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ numShardsSetConfiguration
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ shardNameTemplateSetConfiguration
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ singlyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ singlyNestedDataTypesRepeated
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ testAvroErrorCounterFailure
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ testAvroErrorCounterSuccess
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ timeContaining
org.apache.beam.sdk.io.fileschematransform.AvroWriteSchemaTransformFormatProviderTest ‑ withCompression
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ allPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ arrayPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ byteSequenceTypes
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ byteTypeNonRepeated
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ byteTypes
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ csvConfigurationSet
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ doublyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ doublyNestedDataTypesRepeat
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ invalidConfigurationWithParquet
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ invalidConfigurationWithXml
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ nullableAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ numShardsSetConfiguration
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ shardNameTemplateSetConfiguration
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ singlyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ singlyNestedDataTypesRepeated
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ timeContaining
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ timeContainingSchemaWithListRemovedShouldWriteCSV
org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProviderTest ‑ withCompression
org.apache.beam.sdk.io.fileschematransform.FileWriteSchemaTransformFormatProvidersTest ‑ loadProviders
org.apache.beam.sdk.io.fileschematransform.FileWriteSchemaTransformFormatProvidersTest ‑ testErrorCounterDlqSuccess
org.apache.beam.sdk.io.fileschematransform.FileWriteSchemaTransformFormatProvidersTest ‑ testErrorCounterSuccess
org.apache.beam.sdk.io.fileschematransform.FileWriteSchemaTransformProviderTest ‑ formatMapsToFileWriteSchemaFormatTransform
org.apache.beam.sdk.io.fileschematransform.FileWriteSchemaTransformProviderTest ‑ receivedUnexpectedInputTagsThrowsAnError
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testArrayPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testByteSequenceType
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testByteType
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testDoublyNestedRepeatedDataTypes
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testInvalidConfigsFailToBuild
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testNestedRepeatedDataTypes
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testNullableAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testReadWithPCollectionOfFilepatterns
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testReadWithSchemaFilePath
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testStreamingRead
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testTimeContaining
org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProviderTest ‑ testWriteAndReadWithSchemaTransforms
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ allPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ arrayPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ byteSequenceTypes
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ byteTypes
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ csvConfigurationSet
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ doublyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ doublyNestedDataTypesRepeat
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ invalidConfigurationWithParquet
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ invalidConfigurationWithXml
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ nullableAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ numShardsSetConfiguration
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ shardNameTemplateSetConfiguration
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ singlyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ singlyNestedDataTypesRepeated
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ testJsonErrorCounterFailure
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ testJsonErrorCounterSuccess
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ timeContaining
org.apache.beam.sdk.io.fileschematransform.JsonWriteSchemaTransformFormatProviderTest ‑ withCompression
org.apache.beam.sdk.io.fileschematransform.LineReadSchemaTransformFormatProviderTest ‑ testReadStrings
org.apache.beam.sdk.io.fileschematransform.LineReadSchemaTransformFormatProviderTest ‑ testReadWithPCollectionOfFilepatterns
org.apache.beam.sdk.io.fileschematransform.LineReadSchemaTransformFormatProviderTest ‑ testStreamingRead
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testArrayPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testByteSequenceType
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testByteType
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testDoublyNestedRepeatedDataTypes
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testInvalidConfigsFailToBuild
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testNestedRepeatedDataTypes
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testNullableAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testReadWithPCollectionOfFilepatterns
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testReadWithSchemaFilePath
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testStreamingRead
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testTimeContaining
org.apache.beam.sdk.io.fileschematransform.ParquetReadSchemaTransformFormatProviderTest ‑ testWriteAndReadWithSchemaTransforms
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ allPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ arrayPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ byteSequenceTypes
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ byteTypes
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ csvConfigurationSet
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ doublyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ doublyNestedDataTypesRepeat
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ invalidConfigurationWithParquet
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ invalidConfigurationWithXml
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ nullableAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ numShardsSetConfiguration
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ shardNameTemplateSetConfiguration
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ singlyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ singlyNestedDataTypesRepeated
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ testParquetErrorCounterFailure
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ testParquetErrorCounterSuccess
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ timeContaining
org.apache.beam.sdk.io.fileschematransform.ParquetWriteSchemaTransformFormatProviderTest ‑ withCompression
org.apache.beam.sdk.io.fileschematransform.XmlDateTimeAdapterTest ‑ marshal
org.apache.beam.sdk.io.fileschematransform.XmlDateTimeAdapterTest ‑ unmarshal
org.apache.beam.sdk.io.fileschematransform.XmlRowAdapterTest ‑ allPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.XmlRowAdapterTest ‑ nullableAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.XmlRowAdapterTest ‑ timeContaining
org.apache.beam.sdk.io.fileschematransform.XmlRowValueTest ‑ allPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.XmlRowValueTest ‑ arrayPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.XmlRowValueTest ‑ byteType
org.apache.beam.sdk.io.fileschematransform.XmlRowValueTest ‑ doublyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.XmlRowValueTest ‑ nullableAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.XmlRowValueTest ‑ singlyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.XmlRowValueTest ‑ singlyNestedDataTypesRepeat
org.apache.beam.sdk.io.fileschematransform.XmlRowValueTest ‑ timeContaining
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ allPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ arrayPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ byteSequenceTypes
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ byteTypes
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ csvConfigurationSet
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ doublyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ doublyNestedDataTypesRepeat
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ invalidConfigurationWithParquet
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ invalidConfigurationWithXml
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ nullableAllPrimitiveDataTypes
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ numShardsSetConfiguration
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ shardNameTemplateSetConfiguration
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ singlyNestedDataTypesNoRepeat
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ singlyNestedDataTypesRepeated
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ testXmlErrorCounterSuccess
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ timeContaining
org.apache.beam.sdk.io.fileschematransform.XmlWriteSchemaTransformFormatProviderTest ‑ withCompression
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadAllExpandWithDeveloperTokenFromBuilder
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadAllExpandWithDeveloperTokenFromOptions
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadAllExpandWithDeveloperTokenFromOptionsAndBuilder
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadAllExpandWithoutDeveloperToken
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadAllExpandWithoutRateLimitPolicy
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadAllExpandWithoutValidGoogleAdsClientFactory
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadAllExpandWithoutValidRateLimitPolicy
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadExpandWithDeveloperTokenFromBuilder
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadExpandWithDeveloperTokenFromOptions
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadExpandWithDeveloperTokenFromOptionsAndBuilder
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadExpandWithoutDeveloperToken
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadExpandWithoutQuery
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadExpandWithoutRateLimitPolicy
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadExpandWithoutValidGoogleAdsClientFactory
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadExpandWithoutValidQuery
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ConstructionTests ‑ testReadExpandWithoutValidRateLimitPolicy
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ExecutionTests ‑ testRead
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ExecutionTests ‑ testReadWithFailureFromMaxRetriesExceeded
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ExecutionTests ‑ testReadWithFailureFromNonRetryableError
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ExecutionTests ‑ testReadWithRecoveryFromInternalError
org.apache.beam.sdk.io.googleads.GoogleAdsV14Test$ExecutionTests ‑ testReadWithRecoveryFromQuotaErrorWithRetryDelay
org.apache.beam.sdk.io.hbase.HBaseCoderProviderRegistrarTest ‑ testMutationCoderIsRegistered
org.apache.beam.sdk.io.hbase.HBaseCoderProviderRegistrarTest ‑ testResultCoderIsRegistered
org.apache.beam.sdk.io.hbase.HBaseCoderProviderRegistrarTest ‑ testRowMutationsCoderIsRegistered
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadBuildsCorrectly
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadBuildsCorrectlyInDifferentOrder
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReading
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingDisplayData
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingEmptyTable
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingFailsTableDoesNotExist
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingKeyRangeMiddle
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingKeyRangeMiddleSDF
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingKeyRangePrefix
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingKeyRangeSuffix
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingSDF
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingSourceTwice
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingSplitAtFraction
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingSplitAtFractionExhaustive
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingWithFilter
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingWithFilterSDF
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testReadingWithSplits
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testWriteBuildsCorrectly
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testWriteBuildsCorrectlyInDifferentOrder
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testWriteValidationFailsMissingConfiguration
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testWriteValidationFailsMissingTable
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testWriting
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testWritingDisplayData
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testWritingFailsBadElement
org.apache.beam.sdk.io.hbase.HBaseIOTest ‑ testWritingFailsTableDoesNotExist
org.apache.beam.sdk.io.hbase.HBaseMutationCoderTest ‑ testMutationEncoding
org.apache.beam.sdk.io.hbase.HBaseResultCoderTest ‑ testResultEncoding
org.apache.beam.sdk.io.hbase.HBaseSharedConnectionTest ‑ testCloseConnectionMultipleTimes
org.apache.beam.sdk.io.hbase.HBaseSharedConnectionTest ‑ testCloseNonExistentConnection
org.apache.beam.sdk.io.hbase.HBaseSharedConnectionTest ‑ testCloseThenOpenConnection
org.apache.beam.sdk.io.hbase.HBaseSharedConnectionTest ‑ testOpenMultipleConnections
org.apache.beam.sdk.io.hbase.HBaseSharedConnectionTest ‑ testOpenThenCloseConnection
org.apache.beam.sdk.io.hbase.HbaseIOWriteRowMutationsTest ‑ testWritesDeletes
org.apache.beam.sdk.io.hbase.HbaseIOWriteRowMutationsTest ‑ testWritesDeletesThenPutsInOrderByTimestamp
org.apache.beam.sdk.io.hbase.HbaseIOWriteRowMutationsTest ‑ testWritesPuts
org.apache.beam.sdk.io.hbase.RowMutationsCoderTest ‑ testEncodeMultipleComplexRowMutations
org.apache.beam.sdk.io.hbase.RowMutationsCoderTest ‑ testEncodeMultipleMutations
org.apache.beam.sdk.io.hbase.RowMutationsCoderTest ‑ testEncodeMultipleRowMutations
org.apache.beam.sdk.io.hbase.RowMutationsCoderTest ‑ testEncodePut
org.apache.beam.sdk.io.hcatalog.HCatalogBeamSchemaTest ‑ testDoesntHaveDB
org.apache.beam.sdk.io.hcatalog.HCatalogBeamSchemaTest ‑ testDoesntHaveTable
org.apache.beam.sdk.io.hcatalog.HCatalogBeamSchemaTest ‑ testGetTableSchema
org.apache.beam.sdk.io.hcatalog.HCatalogBeamSchemaTest ‑ testGetTableSchemaForPartitionedTable
org.apache.beam.sdk.io.hcatalog.HCatalogBeamSchemaTest ‑ testHasDB
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testReadFailureTableDoesNotExist
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testReadFailureValidationConfig
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testReadFailureValidationTable
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testReadFromSource
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testReadTransformCanBeSerializedMultipleTimes
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testSourceCanBeSerializedMultipleTimes
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testSourceEqualsSplits
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testWriteFailureTableDoesNotExist
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testWriteFailureValidationConfigProp
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testWriteFailureValidationTable
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testWriteThenReadSuccess
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testWriteThenUnboundedReadSuccess
org.apache.beam.sdk.io.hcatalog.SchemaUtilsTest ‑ testParameterizedTypesToBeamTypes
org.apache.beam.sdk.io.influxdb.InfluxDbIOTest ‑ validateReadTest
org.apache.beam.sdk.io.influxdb.InfluxDbIOTest ‑ validateWriteTest
org.apache.beam.sdk.io.jdbc.JdbcIOExceptionHandlingParameterizedTest ‑ testExceptionsAndRetries[0]
org.apache.beam.sdk.io.jdbc.JdbcIOExceptionHandlingParameterizedTest ‑ testExceptionsAndRetries[1]
org.apache.beam.sdk.io.jdbc.JdbcIOExceptionHandlingParameterizedTest ‑ testExceptionsAndRetries[2]
org.apache.beam.sdk.io.jdbc.JdbcIOExceptionHandlingParameterizedTest ‑ testExceptionsAndRetries[3]
org.apache.beam.sdk.io.jdbc.JdbcIOExceptionHandlingParameterizedTest ‑ testExceptionsAndRetries[4]
org.apache.beam.sdk.io.jdbc.JdbcIOExceptionHandlingParameterizedTest ‑ testExceptionsAndRetries[5]
org.apache.beam.sdk.io.jdbc.JdbcIOExceptionHandlingParameterizedTest ‑ testExceptionsAndRetries[6]
org.apache.beam.sdk.io.jdbc.JdbcIOExceptionHandlingParameterizedTest ‑ testExceptionsAndRetries[7]
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testCustomFluentBackOffConfiguration
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testDataSourceConfigurationDataSourceWithPool
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testDataSourceConfigurationDataSourceWithoutPool
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testDataSourceConfigurationDriverAndUrl
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testDataSourceConfigurationNullPassword
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testDataSourceConfigurationNullUsernameAndPassword
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testDataSourceConfigurationUsernameAndPassword
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testDefaultRetryStrategy
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testGetPreparedStatementSetCaller
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testGetPreparedStatementSetCallerForArray
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testGetPreparedStatementSetCallerForLogicalTypes
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testGetPreparedStatementSetNullsCaller
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testIfNumPartitionsIsZero
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testLowerBoundIsMoreThanUpperBound
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testPartitioningDateTime
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testPartitioningLongs
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testRead
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testReadRowsFailedToGetSchema
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testReadRowsWithDataSourceConfiguration
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testReadRowsWithNumericFields
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testReadRowsWithNumericFieldsWithExcessPrecision
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testReadRowsWithoutStatementPreparator
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testReadWithCoderInference
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testReadWithPartitions
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testReadWithPartitionsBySubqery
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testReadWithSchema
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testReadWithSingleStringParameter
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testSerializationAndCachingOfPoolingDataSourceProvider
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testSetConnectoinInitSqlFailWithDerbyDB
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWrite
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteReadNullableTypes
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteRowsResultsAndWaitOn
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteWithAutosharding
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteWithBackoff
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteWithEmptyPCollection
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteWithResultsAndWaitOn
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteWithWriteResults
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteWithoutPreparedStatement
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteWithoutPreparedStatementAndNonRowType
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteWithoutPreparedStatementWithReadRows
org.apache.beam.sdk.io.jdbc.JdbcIOTest ‑ testWriteWithoutPsWithNonNullableTableField
org.apache.beam.sdk.io.jdbc.JdbcReadSchemaTransformProviderTest ‑ testInvalidReadSchemaOptions
org.apache.beam.sdk.io.jdbc.JdbcReadSchemaTransformProviderTest ‑ testRead
org.apache.beam.sdk.io.jdbc.JdbcReadSchemaTransformProviderTest ‑ testReadWithJdbcTypeSpecified
org.apache.beam.sdk.io.jdbc.JdbcReadSchemaTransformProviderTest ‑ testValidReadSchemaOptions
org.apache.beam.sdk.io.jdbc.JdbcSchemaIOProviderTest ‑ testAbleToReadDataSourceConfiguration
org.apache.beam.sdk.io.jdbc.JdbcSchemaIOProviderTest ‑ testPartitionedRead
org.apache.beam.sdk.io.jdbc.JdbcSchemaIOProviderTest ‑ testPartitionedReadThatShouldntWork
org.apache.beam.sdk.io.jdbc.JdbcUtilTest ‑ testDatetimePartitioningWithMultiKey
org.apache.beam.sdk.io.jdbc.JdbcUtilTest ‑ testDatetimePartitioningWithSingleKey
org.apache.beam.sdk.io.jdbc.JdbcUtilTest ‑ testGetPreparedStatementSetCaller
org.apache.beam.sdk.io.jdbc.JdbcUtilTest ‑ testLongPartitioningNotEnoughRanges
org.apache.beam.sdk.io.jdbc.JdbcUtilTest ‑ testLongPartitioningWithSingleKey
org.apache.beam.sdk.io.jdbc.JdbcUtilTest ‑ testSavesFilesAsExpected
org.apache.beam.sdk.io.jdbc.JdbcUtilTest ‑ testStringPartitioningWithMultiletter
org.apache.beam.sdk.io.jdbc.JdbcUtilTest ‑ testStringPartitioningWithSingleKeyFn
org.apache.beam.sdk.io.jdbc.JdbcUtilTest ‑ testStringPartitioningWithSingleKeyMultiletterFn
org.apache.beam.sdk.io.jdbc.JdbcWriteSchemaTransformProviderTest ‑ testInvalidWriteSchemaOptions
org.apache.beam.sdk.io.jdbc.JdbcWriteSchemaTransformProviderTest ‑ testValidWriteSchemaOptions
org.apache.beam.sdk.io.jdbc.JdbcWriteSchemaTransformProviderTest ‑ testWriteToTable
org.apache.beam.sdk.io.jdbc.JdbcWriteSchemaTransformProviderTest ‑ testWriteToTableWithJdbcTypeSpecified
org.apache.beam.sdk.io.jdbc.SchemaUtilTest ‑ testBeamRowMapperArray
org.apache.beam.sdk.io.jdbc.SchemaUtilTest ‑ testBeamRowMapperDateTime
org.apache.beam.sdk.io.jdbc.SchemaUtilTest ‑ testBeamRowMapperPrimitiveTypes
org.apache.beam.sdk.io.jdbc.SchemaUtilTest ‑ testJdbcLogicalTypesMapValidAvroSchemaIT
org.apache.beam.sdk.io.jdbc.SchemaUtilTest ‑ testSchemaFieldComparator
org.apache.beam.sdk.io.jdbc.SchemaUtilTest ‑ testSchemaFieldTypeComparator
org.apache.beam.sdk.io.jdbc.SchemaUtilTest ‑ testToBeamSchema
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testAuthenticationRequired[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testAuthenticationRequired[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testAuthenticationWithBadPassword[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testAuthenticationWithBadPassword[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkAndFinalizeSeparately[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkAndFinalizeSeparately[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkDefaultCoder[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkDefaultCoder[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkSafety[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMarkSafety[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMark[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCheckpointMark[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCloseWithTimeout[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCloseWithTimeout[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCustomAutoscaler[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testCustomAutoscaler[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testDefaultAutoscaler[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testDefaultAutoscaler[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testDiscardCheckpointMark[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testDiscardCheckpointMark[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testPublisherWithRetryConfiguration[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testPublisherWithRetryConfiguration[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testReadBytesMessages[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testReadBytesMessages[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testReadMessages[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testReadMessages[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testRequiresDedup[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testRequiresDedup[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testSplitForQueue[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testSplitForQueue[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testSplitForTopic[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testSplitForTopic[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteDynamicMessage[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteDynamicMessage[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageToStaticTopicWithoutRetryPolicy[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageToStaticTopicWithoutRetryPolicy[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithError[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithError[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithRetryPolicyReachesLimit[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithRetryPolicyReachesLimit[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithRetryPolicy[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessageWithRetryPolicy[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessage[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessage[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessagesWithErrors[with client class class org.apache.activemq.ActiveMQConnectionFactory]
org.apache.beam.sdk.io.jms.JmsIOTest ‑ testWriteMessagesWithErrors[with client class class org.apache.qpid.jms.JmsConnectionFactory]
org.apache.beam.sdk.io.kafka.ConfluentSchemaRegistryDeserializerProviderTest ‑ testDeserialize
org.apache.beam.sdk.io.kafka.ConfluentSchemaRegistryDeserializerProviderTest ‑ testGetCoder
org.apache.beam.sdk.io.kafka.CustomTimestampPolicyWithLimitedDelayTest ‑ testCustomTimestampPolicyWithLimitedDelay
org.apache.beam.sdk.io.kafka.KafkaCommitOffsetTest ‑ testCommitOffsetDoFn
org.apache.beam.sdk.io.kafka.KafkaCommitOffsetTest ‑ testCommitOffsetError
org.apache.beam.sdk.io.kafka.KafkaDlqTest ‑ testKafkaErrorFnFailure
org.apache.beam.sdk.io.kafka.KafkaDlqTest ‑ testKafkaErrorFnSuccess
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testConstructKafkaRead
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testConstructKafkaReadWithoutMetadata
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testConstructKafkaWrite
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testKafkaRecordToExternalKafkaRecord
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testKafkaRecordToExternalKafkaRecordWithNullKeyAndValue
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testKafkaIOReadPropertiesEnumValuePresence
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testPrimitiveKafkaIOReadPropertiesDefaultValueExistence
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testReadTransformCreationWithBothImplementationBoundProperties
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testReadTransformCreationWithLegacyImplementationBoundProperty
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testReadTransformCreationWithSdfImplementationBoundProperty
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testDeserializationWithHeaders
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testExactlyOnceSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testExactlyOnceSinkWithSendException
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testKafkaWriteHeaders
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testReadAvroGenericRecordsWithConfluentSchemaRegistry
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testReadAvroSpecificRecordsWithConfluentSchemaRegistry
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testRecordsSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testResolveDefaultApiTimeout
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testRiskyConfigurationWarnsProperly
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkMetrics
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkProducerRecordsWithCustomPartition
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkProducerRecordsWithCustomTS
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkToMultipleTopics
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkWithSendErrors
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkWithSerializationErrors
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSourceDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSourceWithExplicitPartitionsDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSourceWithPatternDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedReaderLogsCommitFailure
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSource
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCheckpointMark
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCheckpointMarkWithEmptyPartitions
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCreateTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCustomTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceLogAppendTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceMetrics
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceRawSizeMetric
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceSplits
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceStartReadTime
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceStartReadTimeException
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithExceptionInKafkaFetch
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithExplicitPartitions
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithPartiallyMatchedPattern
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithPattern
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithSingleTopic
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithUnmatchedPattern
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithWrongTopic
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithoutBoundedWrapper
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnreachableKafkaBrokers
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testValuesSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testWithInvalidConsumerPollingTimeout
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testWithValidConsumerPollingTimeout
org.apache.beam.sdk.io.kafka.KafkaIOUtilsTest ‑ testOffsetConsumerConfigOverrides
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithAvroSchema
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithJsonSchema
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithManaged
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithProtoFormat
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithProtoFormatWrongMessageName
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithProtoSchemaFormat
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithRawFormat
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithoutProtoSchemaFormat
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testFindTransformAndMakeItWork
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testManagedMappings
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testValidConfigurations
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testCoderIsSerializableWithWellKnownCoderType
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testKafkaRecordSerializableWithHeaders
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testKafkaRecordSerializableWithNullValueHeader
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testKafkaRecordSerializableWithoutHeaders
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testBuildTransformWithManaged
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testKafkaErrorFnProtoSuccess
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testKafkaErrorFnRawSuccess
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testKafkaErrorFnSuccess
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testManagedMappings
org.apache.beam.sdk.io.kafka.LocalDeserializerProviderTest ‑ testInferKeyCoder
org.apache.beam.sdk.io.kafka.LocalDeserializerProviderTest ‑ testInferKeyCoderFailure
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testCoderIsSerializableWithWellKnownCoderType
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithHeaders
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithPartition
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithTimestamp
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithoutHeaders
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithoutPartition
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithoutTimestamp
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordStructuralValueWithHeadersApi
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordStructuralValueWithoutHeadersApi
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testBounded
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testConstructorWithPollTimeout
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStartOffset
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStartTime
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStopOffset
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStopTime
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWithConsumerPosition
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWithException
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElement
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWhenTopicPartitionIsRemoved
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWhenTopicPartitionIsStopped
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithDeserializationExceptionDefaultRecordHandler
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithDeserializationExceptionRecordingRecordHandler
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithEmptyPoll
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithException
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testRawSizeMetric
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testUnbounded
org.apache.beam.sdk.io.kafka.TopicPartitionCoderTest ‑ testEncodeDecodeRoundTrip
org.apache.beam.sdk.io.kafka.TopicPartitionCoderTest ‑ testToString
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testGetAllTopicPartitions
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testGetAllTopicPartitionsWithGivenPattern
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testGetAllTopicPartitionsWithGivenTopics
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testPartitionGrowth
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testPartitionSingle
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testReCreateReadTransformFromRow
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testReCreateReadTransformWithTopics
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testReCreateWriteTransformFromRow
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testReadTransformRowIncludesAllFields
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testReadTransformURNDiscovery
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testWriteTransformRowIncludesAllFields
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testWriteTransformURNDiscovery
org.apache.beam.sdk.io.kudu.KuduIOTest ‑ testRead
org.apache.beam.sdk.io.kudu.KuduIOTest ‑ testWrite

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

850 tests found (test 671 to 850)

There are 850 tests, see "Raw output" for the list of tests 671 to 850.
Raw output
org.apache.beam.sdk.io.mongodb.MongoDBGridFSIOTest ‑ testFullRead
org.apache.beam.sdk.io.mongodb.MongoDBGridFSIOTest ‑ testReadWithParser
org.apache.beam.sdk.io.mongodb.MongoDBGridFSIOTest ‑ testSplit
org.apache.beam.sdk.io.mongodb.MongoDBGridFSIOTest ‑ testWriteMessage
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testBuildAutoBuckets
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testFullRead
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testGetSizeCollection
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testGetSizeView
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testReadWithAggregate
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testReadWithAggregateWithLimit
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testReadWithCustomConnectionOptions
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testReadWithFilter
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testReadWithFilterAndLimit
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testSplitIntoBucket
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testSplitIntoFilters
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testUpdate
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testWrite
org.apache.beam.sdk.io.mongodb.MongoDbIOTest ‑ testWriteUnordered
org.apache.beam.sdk.io.mongodb.SSLUtilsTest ‑ testIgnoreSSLCertificate
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testRead
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadNoClientId
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadObject
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReceiveWithTimeoutAndNoData
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testWrite
org.apache.beam.sdk.io.neo4j.Neo4jIOTest ‑ testDriverConfigurationCreate
org.apache.beam.sdk.io.neo4j.Neo4jIOTest ‑ testDriverConfigurationErrors
org.apache.beam.sdk.io.neo4j.Neo4jIOTest ‑ testDriverConfigurationWith
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testBlockTracker
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testReadDisplayData
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testReadFilesAsJsonForUnknownSchemaFiles
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testReadFilesAsRowForUnknownSchemaFiles
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testReadFilesUnknownSchemaFilesForGenericRecordThrowException
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testSplitBlockWithLimit
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteAndRead
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteAndReadFiles
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteAndReadFilesAsJsonForUnknownSchema
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteAndReadFilesAsJsonForUnknownSchemaWithConfiguration
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteAndReadUsingGenericDataSchemaWithDataModel
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteAndReadUsingReflectDataSchemaWithDataModel
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteAndReadUsingReflectDataSchemaWithoutDataModelThrowsException
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteAndReadWithBeamSchema
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteAndReadWithConfiguration
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteAndReadWithProjection
org.apache.beam.sdk.io.parquet.ParquetIOTest ‑ testWriteWithRowGroupSizeAndRead
org.apache.beam.sdk.io.rabbitmq.RabbitMqIOTest ‑ testDeclareIncompatibleExchangeFails
org.apache.beam.sdk.io.rabbitmq.RabbitMqIOTest ‑ testQueueDeclareWithoutQueueNameFails
org.apache.beam.sdk.io.rabbitmq.RabbitMqIOTest ‑ testReadDeclaredFanoutExchange
org.apache.beam.sdk.io.rabbitmq.RabbitMqIOTest ‑ testReadDeclaredTopicExchange
org.apache.beam.sdk.io.rabbitmq.RabbitMqIOTest ‑ testReadDeclaredTopicExchangeWithQueueDeclare
org.apache.beam.sdk.io.rabbitmq.RabbitMqIOTest ‑ testReadQueue
org.apache.beam.sdk.io.rabbitmq.RabbitMqIOTest ‑ testUseCorrelationIdFailsWhenIdsMissing
org.apache.beam.sdk.io.rabbitmq.RabbitMqIOTest ‑ testUseCorrelationIdSucceedsWhenIdsPresent
org.apache.beam.sdk.io.rabbitmq.RabbitMqIOTest ‑ testWriteExchange
org.apache.beam.sdk.io.rabbitmq.RabbitMqIOTest ‑ testWriteQueue
org.apache.beam.sdk.io.redis.RedisIOTest ‑ redisByteKeyToRedisCursor
org.apache.beam.sdk.io.redis.RedisIOTest ‑ redisCursorToByteKey
org.apache.beam.sdk.io.redis.RedisIOTest ‑ redisCursorToByteKeyAndBack
org.apache.beam.sdk.io.redis.RedisIOTest ‑ redisCursorToByteKeyZeroEnd
org.apache.beam.sdk.io.redis.RedisIOTest ‑ redisCursorToByteKeyZeroStart
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testRead
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testReadSplitBig
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testReadSplitSmall
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testReadWithKeyPattern
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteStreams
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteStreamsWithTruncation
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteUsingDECRBY
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteUsingINCRBY
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteWithMethodLPush
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteWithMethodPFAdd
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteWithMethodPFAddWithExpireTime
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteWithMethodRPush
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteWithMethodSAdd
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteWithMethodSet
org.apache.beam.sdk.io.redis.RedisIOTest ‑ testWriteWithMethodSetWithExpiration
org.apache.beam.sdk.io.singlestore.DataSourceConfigurationTest ‑ testGetDataSource
org.apache.beam.sdk.io.singlestore.ReadTest ‑ testRead
org.apache.beam.sdk.io.singlestore.ReadTest ‑ testReadBothTableAndQuery
org.apache.beam.sdk.io.singlestore.ReadTest ‑ testReadNoTableAndQuery
org.apache.beam.sdk.io.singlestore.ReadTest ‑ testReadWithStatementPreparator
org.apache.beam.sdk.io.singlestore.ReadTest ‑ testReadWithTable
org.apache.beam.sdk.io.singlestore.ReadTest ‑ testReadWithoutOutputParallelization
org.apache.beam.sdk.io.singlestore.ReadWithPartitionsTest ‑ testReadWithPartitions
org.apache.beam.sdk.io.singlestore.ReadWithPartitionsTest ‑ testReadWithPartitionsBothTableAndQuery
org.apache.beam.sdk.io.singlestore.ReadWithPartitionsTest ‑ testReadWithPartitionsNoTableAndQuery
org.apache.beam.sdk.io.singlestore.ReadWithPartitionsTest ‑ testReadWithPartitionsWithTable
org.apache.beam.sdk.io.singlestore.SingleStoreDefaultRowMapperTest ‑ testAllDataTypes
org.apache.beam.sdk.io.singlestore.SingleStoreDefaultRowMapperTest ‑ testEmptyRow
org.apache.beam.sdk.io.singlestore.SingleStoreDefaultRowMapperTest ‑ testNullValues
org.apache.beam.sdk.io.singlestore.SingleStoreDefaultUserDataMapperTest ‑ testAllDataTypes
org.apache.beam.sdk.io.singlestore.SingleStoreDefaultUserDataMapperTest ‑ testBigNegativeNumbers
org.apache.beam.sdk.io.singlestore.SingleStoreDefaultUserDataMapperTest ‑ testBigNumbers
org.apache.beam.sdk.io.singlestore.SingleStoreDefaultUserDataMapperTest ‑ testEmptyRow
org.apache.beam.sdk.io.singlestore.SingleStoreDefaultUserDataMapperTest ‑ testNullValues
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testEscapeIdentifierEmpty
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testEscapeIdentifierNoSpecialCharacters
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testEscapeIdentifierWithSpecialCharacters
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testEscapeStringEmpty
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testEscapeStringNoSpecialCharacters
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testEscapeStringWithSpecialCharacters
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testGetArgumentWithDefault
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testGetArgumentWithDefaultReturnsDefault
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testGetClassNameOrNullClassName
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testGetClassNameOrNullNull
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testGetSelectQueryAllNulls
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testGetSelectQueryBothNonNulls
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testGetSelectQueryNonNullQuery
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testGetSelectQueryNonNullTable
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testInferCoderFromCoderRegistry
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testInferCoderFromRowMapper
org.apache.beam.sdk.io.singlestore.SingleStoreUtilTest ‑ testInferCoderFromSchemaRegistry
org.apache.beam.sdk.io.singlestore.WriteTest ‑ testWrite
org.apache.beam.sdk.io.singlestore.WriteTest ‑ testWriteBigBatchSize
org.apache.beam.sdk.io.singlestore.WriteTest ‑ testWriteInvalidBatchSize
org.apache.beam.sdk.io.singlestore.WriteTest ‑ testWriteSmallBatchSize
org.apache.beam.sdk.io.solr.JavaBinCodecCoderTest ‑ encodeNullThrowsCoderException
org.apache.beam.sdk.io.solr.JavaBinCodecCoderTest ‑ testDecodeEncodeEqual
org.apache.beam.sdk.io.solr.JavaBinCodecCoderTest ‑ testEncodedTypeDescriptor
org.apache.beam.sdk.io.solr.SolrIOTest ‑ testBadCredentials
org.apache.beam.sdk.io.solr.SolrIOTest ‑ testBatchSize
org.apache.beam.sdk.io.solr.SolrIOTest ‑ testDefaultRetryPredicate
org.apache.beam.sdk.io.solr.SolrIOTest ‑ testRead
org.apache.beam.sdk.io.solr.SolrIOTest ‑ testReadAll
org.apache.beam.sdk.io.solr.SolrIOTest ‑ testReadWithQuery
org.apache.beam.sdk.io.solr.SolrIOTest ‑ testWrite
org.apache.beam.sdk.io.solr.SolrIOTest ‑ testWriteRetry
org.apache.beam.sdk.io.solr.SolrIOTest ‑ testWriteWithMaxBatchSize
org.apache.beam.sdk.io.splunk.CustomX509TrustManagerTest ‑ testCustomX509TrustManagerWithRecognizedCertificate
org.apache.beam.sdk.io.splunk.CustomX509TrustManagerTest ‑ testCustomX509TrustManagerWithUnrecognizedCertificate
org.apache.beam.sdk.io.splunk.HttpEventPublisherTest ‑ configureBackOffCustomTest
org.apache.beam.sdk.io.splunk.HttpEventPublisherTest ‑ configureBackOffDefaultTest
org.apache.beam.sdk.io.splunk.HttpEventPublisherTest ‑ contentTest
org.apache.beam.sdk.io.splunk.HttpEventPublisherTest ‑ genericURLTest
org.apache.beam.sdk.io.splunk.HttpEventPublisherTest ‑ invalidRootCaTest
org.apache.beam.sdk.io.splunk.HttpEventPublisherTest ‑ recognizedSelfSignedCertificateTest
org.apache.beam.sdk.io.splunk.HttpEventPublisherTest ‑ stringPayloadTest
org.apache.beam.sdk.io.splunk.HttpEventPublisherTest ‑ unrecognizedSelfSignedCertificateTest
org.apache.beam.sdk.io.splunk.SplunkEventCoderTest ‑ testBackwardsCompatibility_canDecodeVersion1
org.apache.beam.sdk.io.splunk.SplunkEventCoderTest ‑ testBackwardsCompatibility_canDecodeVersion1withEmptyEvent
org.apache.beam.sdk.io.splunk.SplunkEventCoderTest ‑ testBackwardsCompatibility_canDecodeVersion1withEventLength1
org.apache.beam.sdk.io.splunk.SplunkEventCoderTest ‑ testBackwardsCompatibility_canDecodeVersion2
org.apache.beam.sdk.io.splunk.SplunkEventCoderTest ‑ testBackwardsCompatibility_canDecodeVersion2withFields
org.apache.beam.sdk.io.splunk.SplunkEventCoderTest ‑ testEncodeDecode
org.apache.beam.sdk.io.splunk.SplunkEventCoderTest ‑ testEncodeDecodeFields
org.apache.beam.sdk.io.splunk.SplunkEventTest ‑ testEquals
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ eventWriterCustomBatchCountAndValidation
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ eventWriterDefaultBatchCountAndValidation
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ eventWriterFullEndpoint
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ eventWriterInvalidURL
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ eventWriterMissingToken
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ eventWriterMissingURL
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ eventWriterMissingURLProtocol
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ failedSplunkWriteSingleBatchTest
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ successfulSplunkWriteMultiBatchTest
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ successfulSplunkWriteSingleBatchTest
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ testInvalidURL
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ testMissingURLProtocol
org.apache.beam.sdk.io.splunk.SplunkEventWriterTest ‑ testValidURL
org.apache.beam.sdk.io.splunk.SplunkIOTest ‑ successfulSplunkIOMultiBatchNoParallelismTest
org.apache.beam.sdk.io.splunk.SplunkIOTest ‑ successfulSplunkIOMultiBatchParallelismTest
org.apache.beam.sdk.io.splunk.SplunkIOTest ‑ successfulSplunkIOSingleBatchParallelismTest
org.apache.beam.sdk.io.splunk.SplunkWriteErrorTest ‑ testEquals
org.apache.beam.sdk.io.thrift.ThriftIOTest ‑ testReadFilesBinaryProtocol
org.apache.beam.sdk.io.thrift.ThriftIOTest ‑ testReadWriteBinaryProtocol
org.apache.beam.sdk.io.thrift.ThriftIOTest ‑ testReadWriteCompactProtocol
org.apache.beam.sdk.io.thrift.ThriftIOTest ‑ testReadWriteJsonProtocol
org.apache.beam.sdk.io.thrift.ThriftIOTest ‑ testThriftCoder
org.apache.beam.sdk.io.thrift.ThriftPayloadSerializerProviderTest ‑ deserialize
org.apache.beam.sdk.io.thrift.ThriftPayloadSerializerProviderTest ‑ invalidArgs
org.apache.beam.sdk.io.thrift.ThriftPayloadSerializerProviderTest ‑ serialize
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testInnerStructSchemaWithSimpleTypedefs
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testMainStructSchemaWithContainerTypedefRegistered
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testMainStructSchemaWithoutTypedefRegistration
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testSchemaUsage
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testThriftSchemaOnlyAllowsThriftClasses
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testUnionSchema
org.apache.beam.sdk.io.tika.ParseResultTest ‑ testEqualsAndHashCode
org.apache.beam.sdk.io.tika.TikaIOTest ‑ testParseAndParseFiles
org.apache.beam.sdk.io.tika.TikaIOTest ‑ testParseDamagedPdfFile
org.apache.beam.sdk.io.tika.TikaIOTest ‑ testParseDisplayData
org.apache.beam.sdk.io.tika.TikaIOTest ‑ testParseFilesDisplayData