MCPcopy Create free account

hub / github.com/GoogleCloudPlatform/DataflowTemplates / functions

Functions23,218 in github.com/GoogleCloudPlatform/DataflowTemplates

⨍ Functions 23,218◇ Types & classes 3,671↳ Endpoints 7
↓ 102 callersMethodtoUpperCase
(List<String> list)
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/cloudsql/CloudSqlResourceManagerIT.java:98
↓ 101 callersMethodfilter
()
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Index.java:46
↓ 100 callersMethodcreateRows
(String colPrefix, Object... values)
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDataTypesIT.java:139
↓ 99 callersMethodgetPayload
()
v2/common/src/main/java/com/google/cloud/teleport/v2/values/FailsafeElement.java:60
↓ 98 callersMethodbuilder
(String testId, String projectId, String region)
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java:186
↓ 98 callersMethodread
Creates an uninitialized instance of {@link Read}. Before use, the {@link Read} must be configured with a {@link Read#withInstanceId} and {@link Read#
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerIO.java:468
↓ 97 callersMethodbuildSpannerDdlFromSessionFile
Builds a Spanner {@link Ddl} object from a HarbourBridge session file. @param sessionFile Path to the session file. @return A Spanner {@link Ddl} obj
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/utils/SchemaUtils.java:96
↓ 97 callersMethodgetMessage
()
v1/src/main/java/com/google/cloud/teleport/avro/AvroPubsubMessageRecord.java:47
↓ 96 callersMethodbuilder
(List<ConditionCheck> conditionChecks)
it/conditions/src/main/java/org/apache/beam/it/conditions/ChainedConditionCheck.java:59
↓ 96 callersMethodbuilder
@return builder for {@link Range}.
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/reader/io/jdbc/uniformsplitter/range/Range.java:103
↓ 96 callersMethodbytes
Returns the descriptor for the {@code BYTES} type: a variable-length byte string.
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/type/Type.java:145
↓ 96 callersMethoddataType
()
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/models/PreparedStatementValueObject.java:23
↓ 96 callersMethodisEmpty
A boolean columns, true if the character is equal to '\0' at all positions of comparison. False otherwise.
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/reader/io/jdbc/uniformsplitter/stringmapper/CollationOrderRow.java:70
↓ 96 callersMethodmaybeUseStaticInstance
Looks at the system properties if there's an instance id, and reuses it if configured. @return this builder with the instance ID set.
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java:797
↓ 96 callersMethodprimaryKeys
The primary key column names.
v2/cdc-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/model/DataGeneratorTable.java:35
↓ 95 callersMethodgetHost
()
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/shard/Shard.java:117
↓ 95 callersMethodlistArtifacts
Lists all artifacts under test-class-name/run-id/{@code prefix}. @param testName the test name to use as the prefix on the testing artifacts. @param
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/ArtifactClient.java:115
↓ 94 callersMethodset
(self, t)
python/src/test/python/bigquery-anomaly-detection/pipeline_test.py:1332
↓ 93 callersMethodbuildSourceSchemaFromSessionFile
Builds a {@link SourceSchema} object from a HarbourBridge session file. @param sessionFile Path to the session file. @return A {@link SourceSchema} o
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/utils/SchemaUtils.java:238
↓ 92 callersMethodgetLogicalType
Maps a sink type string to a {@link LogicalType}. @param typeName The type name from the sink database (e.g., "VARCHAR", "INT64"). @param dialect The
v2/cdc-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/sink/TypeMapper.java:34
↓ 92 callersMethodnotNull
()
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Column.java:48
↓ 92 callersMethodof
(String name, Type type)
v1/src/main/java/com/google/cloud/teleport/spanner/common/Type.java:407
↓ 92 callersMethodwithDatabaseId
Specifies the Cloud Spanner database.
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerIO.java:824
↓ 91 callersMethodapply
(GenericRecord record)
v1/src/main/java/com/google/cloud/teleport/spanner/AvroRecordConverter.java:47
↓ 91 callersMethodcreateRows
(Object... values)
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToSpannerDataTypesIT.java:374
↓ 91 callersMethodgetCode
Returns the type code corresponding to this type.
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/type/Type.java:409
↓ 90 callersMethodgetProperties
()
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/MappingMapper.java:487
↓ 90 callersMethodtoString
()
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datagenerator/DataGenerator.java:284
↓ 89 callersMethodgetPort
()
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/shard/Shard.java:125
↓ 88 callersMethodgetValue
(Field columnSchema, FieldValue value)
lt/observability/src/test/java/com/google/cloud/teleport/lt/dataset/bigquery/BigQueryPerfDatasetFetcher.java:44
↓ 88 callersMethodmap
Map the extracted value to an object accepted by {@link org.apache.avro.generic.GenericRecordBuilder#set(Field, Object)} as per the schema of the fiel
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/reader/io/jdbc/rowmapper/ResultSetValueMapper.java:43
↓ 88 callersMethodof
( String failsafeValue, String dmlSql, String schemaName, String tableName, List
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/values/DmlInfo.java:48
↓ 88 callersMethodtrackAction
(String name, String executeAfter)
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/JobSpecIndex.java:122
↓ 87 callersMethodend
()
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/IndexColumn.java:181
↓ 87 callersMethodgetType
()
v1/src/main/java/com/google/cloud/teleport/spanner/common/Type.java:420
↓ 87 callersMethodof
(Write write, Op operation, String table)
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerIO.java:1425
↓ 87 callersMethodpublish
( KafkaProducer<String, Object> producer, String topicName, String key, GenericRecord value)
v2/kafka-to-gcs/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToGcsIT.java:161
↓ 86 callersMethodbuilder
(SourceDatabaseType sourceType)
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/sourceddl/SourceColumn.java:52
↓ 86 callersMethodfields
()
v1/src/main/java/com/google/cloud/teleport/splunk/SplunkEvent.java:49
↓ 85 callersMethoddate
Returns the descriptor for the {@code DATE} type: a timezone independent date in the range [1678-01-01, 2262-01-01).
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/type/Type.java:161
↓ 85 callersMethodgetDmlStatement
()
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/models/DMLGeneratorResponse.java:21
↓ 84 callersMethodsetApproxRowCount
(Long value)
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/reader/io/jdbc/iowrapper/config/TableConfig.java:67
↓ 84 callersMethodtoString
()
v2/common/src/main/java/com/google/cloud/teleport/v2/values/FailsafeElement.java:103
↓ 83 callersMethodgetBucket
()
v2/bigquery-to-parquet/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryToParquet.java:166
↓ 83 callersMethodgetTableName
()
v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java:147
↓ 83 callersMethodof
( Document document, String originalDocument, Integer retryCount, String errorMessage,
v2/mongodb-to-mongodb/src/main/java/com/google/cloud/teleport/v2/transforms/DocumentWithMetadata.java:132
↓ 83 callersMethodtoTableSpecLegacy
Convert a BigQuery TableId to a table spec string. @param table TableId to format. @return String in the format {project}:{dataset}.{table}.
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java:741
↓ 83 callersMethoduniqueKeys
Unique keys/indexes defined on this table.
v2/cdc-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/model/DataGeneratorTable.java:45
↓ 81 callersMethodautoBuild
()
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Column.java:231
↓ 81 callersMethodgetArgument
()
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/logicaltypes/IsoDateTime.java:44
↓ 81 callersMethodgetInstance
Get a reference to {@link com.github.nosan.embedded.cassandra.Cassandra Embedded Cassandra} managed by {@link SharedEmbeddedCassandra}.
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/cassandra/reader/io/cassandra/testutils/SharedEmbeddedCassandra.java:61
↓ 81 callersMethodisRoot
Whether this table is a root table (not interleaved/child).
v2/cdc-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/model/DataGeneratorTable.java:48
↓ 80 callersMethodexecuteDdlStatement
Executes a DDL statement. <p>Note: Implementations may do instance creation and database creation here. @param statement The DDL statement. @throws
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java:368
↓ 79 callersMethodcreateDataset
Create a BigQuery dataset in which all tables will exist. @param region the region to store the dataset in. @return Dataset id that was created @thro
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManager.java:181
↓ 79 callersMethodcreateRows
(String colPrefix, Object... values)
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToSpannerDataTypesAndExpressionIT.java:311
↓ 79 callersMethodgetOriginalPayload
()
v2/common/src/main/java/com/google/cloud/teleport/v2/values/FailsafeElement.java:56
↓ 79 callersMethodprimaryKeys
()
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Table.java:44
↓ 79 callersMethodtimestamp
Returns the descriptor for the {@code TIMESTAMP} type: a nano precision timestamp in the range [0000-01-01 00:00:00, 9999-12-31 23:59:59.999999999 UTC
v1/src/main/java/com/google/cloud/teleport/spanner/common/Type.java:158
↓ 78 callersMethodaddColumn
(Column column)
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Table.java:251
↓ 78 callersMethodbuilder
Creates a builder for {@link TableSplitSpecification}. @return a new builder instance.
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/reader/io/jdbc/uniformsplitter/range/TableSplitSpecification.java:101
↓ 78 callersMethodgetInstanceId
()
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/SpannerReadIT.java:84
↓ 78 callersMethodinsertQps
The QPS for inserts.
v2/cdc-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/model/DataGeneratorTable.java:52
↓ 78 callersMethodsetPartitionColumns
(ImmutableList<PartitionColumn> value)
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/reader/io/jdbc/uniformsplitter/range/TableSplitSpecification.java:111
↓ 77 callersMethodbuilder
()
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/reader/io/jdbc/JdbcSchemaReference.java:33
↓ 77 callersMethodtoByteArray
(JsonNode changeEvent, String key, boolean requiredField)
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventTypeConvertor.java:203
↓ 76 callersMethodcreateTempFile
()
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/ParquetTestUtil.java:85
↓ 76 callersMethodrandomAlphanumeric
(int length)
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/RandomUtils.java:31
↓ 76 callersMethodsetDbName
(String value)
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/reader/io/jdbc/JdbcSchemaReference.java:54
↓ 75 callersMethodgetUri
()
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/cloudsql/CloudSqlResourceManager.java:62
↓ 73 callersMethodbuilder
(Dialect dialect)
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Column.java:58
↓ 73 callersMethodcolumns
()
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Table.java:48
↓ 73 callersMethodread
(String sessionFilePath)
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/SessionFileReader.java:36
↓ 72 callersMethodcreateRows
(Object... values)
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDataTypesIT.java:358
↓ 72 callersMethodcreateRows
(Object... values)
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDataTypesPGDialectIT.java:365
↓ 72 callersMethodcreateRows
(String colPrefix, Object... values)
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDataTypesPGDialectIT.java:140
↓ 72 callersMethodgetGcsPath
(String artifactId, GcsResourceManager gcsResourceManager)
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDbLTBase.java:308
↓ 72 callersMethodsizeOf
Estimates the size in bytes of the given element with the configured {@link Coder} . @param element the element instance to be estimated @return the
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/SizeEstimator.java:56
↓ 71 callersMethodautoBuild
()
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Column.java:269
↓ 71 callersMethodgetDatasetId
Return the dataset ID this Resource Manager uses to create and manage tables in. @return the dataset ID.
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManager.java:111
↓ 71 callersMethodsetSchema
(String schema)
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/AvroConverters.java:66
↓ 71 callersMethodtoString
()
v2/sourcedb-to-spanner/src/test/java/org/apache/beam/sdk/io/localcassandra/CassandraIOTest.java:733
↓ 70 callersMethodbuilder
()
v2/gcs-spanner-dv/src/main/java/com/google/cloud/teleport/v2/dto/Column.java:30
↓ 70 callersMethodgetDatabaseId
()
v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java:118
↓ 69 callersMethodbuild
()
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/BigQueryTable.java:119
↓ 69 callersMethodgetProject
()
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/BigQueryTable.java:35
↓ 69 callersMethodgetSpannerColumnName
Retrieves the corresponding Spanner column name given a source table and source column. @param namespace is currently not operational.
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/ISchemaMapper.java:56
↓ 69 callersMethodhasNext
()
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/RandomInsertMutationGenerator.java:205
↓ 68 callersMethoddeleteQps
The QPS for deletes.
v2/cdc-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/model/DataGeneratorTable.java:60
↓ 68 callersMethodgetDMLStatement
Generates a DML statement based on the provided {@link DMLGeneratorRequest}. @param dmlGeneratorRequest the request containing necessary information
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/IDMLGenerator.java:39
↓ 68 callersMethodisGenerated
Whether the column is a generated column.
v2/cdc-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/model/DataGeneratorColumn.java:42
↓ 68 callersMethodsetField
(String fieldName, Object value)
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/reader/io/row/SourceRow.java:210
↓ 68 callersMethodtearDownBase
()
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/IOLoadTestBase.java:59
↓ 68 callersMethodtoInstant
(Timestamp timestamp)
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableChangeStreamsToGcs.java:294
↓ 67 callersMethodgetGcsPath
(String... pathParts)
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/endtoend/EndToEndTestingITBase.java:407
↓ 67 callersMethodregister
()
v2/common/src/main/java/com/google/cloud/teleport/v2/common/UncaughtExceptionLogger.java:41
↓ 66 callersMethodgetStringValue
(String field)
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/values/DatastreamRow.java:91
↓ 66 callersMethodtoString
()
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/values/DatastreamRow.java:209
↓ 66 callersMethodwithSource
(String source)
v1/src/main/java/com/google/cloud/teleport/splunk/SplunkEvent.java:89
↓ 65 callersMethodbuilder
(BigQueryResourceManager resourceManager, TableId tableId)
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/conditions/BigQueryRowsCheck.java:87
↓ 65 callersMethodgetOrCreate
(SpannerConfig spannerConfig)
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerAccessor.java:93
← previousnext →201–300 of 23,218, ranked by callers