MCPcopy Create free account

hub / github.com/data-integrations/wrangler / functions

Functions3,047 in github.com/data-integrations/wrangler

↓ 3 callersMethodupdateWorkspaceRequest
Update the directive execution request for the specified workspace. @param id the workspace id @param request the directive execution request @throws
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/WorkspaceDataset.java:258
↓ 3 callersMethodvalidateProjectCredentials
Validates that the project and credentials are either explicitly set in the connection or are available through the environment. @param connection th
wrangler-service/src/main/java/io/cdap/wrangler/service/gcp/GCPUtils.java:139
↓ 2 callersMethodBool
Allocates a {@code Boolean} object representing the {@code value} argument. @param value the value of the {@code Boolean}.
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/Bool.java:58
↓ 2 callersMethodaddRepeatedField
( com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1278
↓ 2 callersMethodaggregate
(List<Row> rows)
wrangler-core/src/main/java/io/cdap/wrangler/statistics/BasicStatistics.java:37
↓ 2 callersMethodbrowse
Explores the path provided on the filesystem. @param path to be explored. @return Information about all the files/directories in the path. @throws Ex
wrangler-service/src/main/java/io/cdap/wrangler/service/explorer/Explorer.java:77
↓ 2 callersMethodbuildRecipeFromRequest
(HttpServiceRequest request, RecipeId recipeId)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/RecipeHandler.java:173
↓ 2 callersMethodbuilder
(String name, String type)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/ADLSDirectoryEntryInfo.java:52
↓ 2 callersMethodcall
()
wrangler-core/src/main/java/io/cdap/directives/parser/ParseProtobuf.java:114
↓ 2 callersMethodcleanseColumnName
(String columnName)
wrangler-core/src/main/java/io/cdap/directives/column/CleanseColumnNames.java:107
↓ 2 callersMethodclearField
( com.google.protobuf.Descriptors.FieldDescriptor field)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1265
↓ 2 callersMethodclearOneof
( com.google.protobuf.Descriptors.OneofDescriptor oneof)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1269
↓ 2 callersMethodclone
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1257
↓ 2 callersMethodclose
Closes the underlying <code>Reader quietly. This method is useful if you only want to process the first few lines of a larger file. If you do not clos
wrangler-service/src/main/java/io/cdap/wrangler/service/explorer/BoundedLineInputStream.java:149
↓ 2 callersMethodcloseQuietly
Closes the iterator, handling null and ignoring exceptions. @param iterator the iterator to close
wrangler-service/src/main/java/io/cdap/wrangler/service/explorer/BoundedLineInputStream.java:169
↓ 2 callersMethodconcat
(URI uri, String extraPath)
wrangler-core/src/main/java/io/cdap/wrangler/datamodel/HTTPSchemaLoader.java:173
↓ 2 callersMethodconfigure
Configures a catalog. @return true if success in configuring, false otherwise.
wrangler-core/src/main/java/io/cdap/directives/lookup/StaticCatalog.java:33
↓ 2 callersMethodconvertType
Converts the column type into another type. Only target types int, short, long, double, boolean, string, and bytes are supported. @param row source r
wrangler-core/src/main/java/io/cdap/wrangler/utils/ColumnConverter.java:77
↓ 2 callersMethodconvertValidationException
(ValidationException e)
wrangler-core/src/main/java/io/cdap/directives/validation/conformers/JsonConformer.java:52
↓ 2 callersMethodcreateAndUploadWorkspace
(URL baseURL, String workspace, List<String> lines)
wrangler-service/src/test/java/io/cdap/wrangler/service/WranglerServiceTestBase.java:49
↓ 2 callersMethodcreateQueryParams
(List<Map.Entry<String, String>> queryParams)
wrangler-service/src/test/java/io/cdap/wrangler/service/WranglerServiceTestBase.java:74
↓ 2 callersMethodcvc
(int i)
wrangler-core/src/main/java/io/cdap/directives/nlp/internal/PorterStemmer.java:233
↓ 2 callersMethoddateTimePatternReplace
(List<Map<Pattern, String>> patternGroupList, String value)
wrangler-core/src/main/java/io/cdap/wrangler/dq/DateTimePattern.java:160
↓ 2 callersMethoddecode
(byte[] bytes)
wrangler-core/src/main/java/io/cdap/wrangler/codec/JsonAvroDecoder.java:46
↓ 2 callersMethoddecodeArray
(String name, Object object, Schema schema)
wrangler-core/src/main/java/io/cdap/wrangler/utils/RecordConvertor.java:432
↓ 2 callersMethoddeleteRecipe
Delete the specified Recipe @param recipeId id of the recipe to delete @throws RecipeNotFoundException if recipe with given id is not found
wrangler-storage/src/main/java/io/cdap/wrangler/store/recipe/RecipeStore.java:208
↓ 2 callersMethoddeleteScope
Deletes a workspaces that have the specified scope. TODO: (CDAP-14692) make sure scope is indexed so this doesn't require a full table scan @param s
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/WorkspaceDataset.java:302
↓ 2 callersMethoddeleteWorkspace
Deletes the workspace. @param id to be deleted.
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/WorkspaceDataset.java:290
↓ 2 callersMethoddeserialize
(String type)
wrangler-service/src/main/java/io/cdap/wrangler/service/kafka/KafkaConfiguration.java:101
↓ 2 callersMethoddoublec
(int j)
wrangler-core/src/main/java/io/cdap/directives/nlp/internal/PorterStemmer.java:215
↓ 2 callersMethoddownloadResource
(String baseUrl, String resourceName, Function<InputStream, R> callable)
wrangler-core/src/main/java/io/cdap/wrangler/datamodel/HTTPSchemaLoader.java:122
↓ 2 callersMethodequals
(Object o)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/Workspace.java:69
↓ 2 callersMethodextractDomainAndAccount
(String emailId)
wrangler-core/src/main/java/io/cdap/directives/transformation/SplitEmail.java:123
↓ 2 callersMethodforNumber
(int value)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:223
↓ 2 callersMethodfromSystem
Creates a {@link DirectiveInfo} of the given class coming from the {@link DirectiveScope#SYSTEM} scope.
wrangler-core/src/main/java/io/cdap/wrangler/registry/DirectiveInfo.java:54
↓ 2 callersMethodfromWorkspace
Converts the data in workspace into records. @param workspace the workspace to get records from @return list of records.
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/DirectivesHandler.java:1033
↓ 2 callersMethodfunctions
()
wrangler-core/src/main/java/io/cdap/wrangler/expression/ELRegistration.java:25
↓ 2 callersMethodgenerateExecutionResponse
Transform the rows to response that is user friendly. Also generates the summary from the rows.
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/AbstractDirectiveHandler.java:161
↓ 2 callersMethodget
(int i)
wrangler-api/src/main/java/io/cdap/wrangler/api/TokenGroup.java:50
↓ 2 callersMethodgetADLSClientID
()
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSConfiguration.java:54
↓ 2 callersMethodgetAWSAccessKeyId
()
wrangler-service/src/main/java/io/cdap/wrangler/service/s3/S3Configuration.java:50
↓ 2 callersMethodgetAWSSecretKey
()
wrangler-service/src/main/java/io/cdap/wrangler/service/s3/S3Configuration.java:55
↓ 2 callersMethodgetAccountFQDN
()
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSConfiguration.java:66
↓ 2 callersMethodgetAll
Retrieves all of the {@link Schema} contained within the glossary. @return a collection of all {@link Schema}
wrangler-core/src/main/java/io/cdap/wrangler/utils/AvroSchemaGlossary.java:96
↓ 2 callersMethodgetAll
@return A map of directive to {@link UsageEntry}.
wrangler-core/src/main/java/io/cdap/wrangler/parser/UsageRegistry.java:131
↓ 2 callersMethodgetArguments
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/DirectiveUsage.java:59
↓ 2 callersMethodgetCatalog
@return name of the catalog.
wrangler-core/src/main/java/io/cdap/directives/lookup/StaticCatalog.java:46
↓ 2 callersMethodgetClientKey
()
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSConfiguration.java:58
↓ 2 callersMethodgetColumnDisplayType
(Schema schema)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/AbstractDirectiveHandler.java:277
↓ 2 callersMethodgetConfig
()
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/ConfigStore.java:80
↓ 2 callersMethodgetConnectionName
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/SampleSpec.java:63
↓ 2 callersMethodgetConnections
Return the list of default connections to be created
wrangler-service/src/main/java/io/cdap/wrangler/service/connections/ConnectionTypeConfig.java:58
↓ 2 callersMethodgetConnectorName
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionType.java:67
↓ 2 callersMethodgetCountMetrics
This method provides a way to emit metrics from the Directive. Metadata about each metric to be emitted can be returned and used in the metrics emissi
wrangler-api/src/main/java/io/cdap/wrangler/api/Directive.java:124
↓ 2 callersMethodgetDataType
get data type from the file type. @param fileName @return DataType @throws IOException
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSHandler.java:436
↓ 2 callersMethodgetDataType
get data type from the file type. @param fileName the file name @return DataType
wrangler-service/src/main/java/io/cdap/wrangler/service/s3/S3Handler.java:408
↓ 2 callersMethodgetDatasetWhitelist
Parses the dataset whitelist in the connection properties into a set of DatasetId. The whitelist is expected to be a comma separated list of dataset i
wrangler-service/src/main/java/io/cdap/wrangler/service/bigquery/BigQueryHandler.java:491
↓ 2 callersMethodgetDescription
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/recipe/v2/Recipe.java:55
↓ 2 callersMethodgetDescription
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/schema/SchemaEntry.java:55
↓ 2 callersMethodgetDisabledTypes
Return the set of disabled connection types
wrangler-service/src/main/java/io/cdap/wrangler/service/connections/ConnectionTypeConfig.java:51
↓ 2 callersMethodgetElement
()
wrangler-core/src/main/java/io/cdap/wrangler/sampling/Reservoir.java:135
↓ 2 callersMethodgetEmail
<code>string email = 3;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:928
↓ 2 callersMethodgetEmailBytes
<code>string email = 3;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:943
↓ 2 callersMethodgetEndpointURL
()
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSConfiguration.java:62
↓ 2 callersMethodgetErrors
()
wrangler-api/src/main/java/io/cdap/wrangler/api/CompileStatus.java:48
↓ 2 callersMethodgetFilePath
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/FileQueryDetails.java:39
↓ 2 callersMethodgetId
<pre> Unique ID number for this person. </pre> <code>int32 id = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:919
↓ 2 callersMethodgetInstances
(ConnectionMeta connection)
wrangler-service/src/main/java/io/cdap/wrangler/service/spanner/SpannerHandler.java:384
↓ 2 callersMethodgetJdbcUrlPattern
()
wrangler-service/src/main/java/io/cdap/wrangler/service/database/DatabaseHandler.java:120
↓ 2 callersMethodgetKey
(NamespacedId id)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/connections/ConnectionStore.java:243
↓ 2 callersMethodgetLatestWranglerArtifact
Retrieve latest Wrangler transform artifact information
wrangler-core/src/main/java/io/cdap/wrangler/registry/DirectiveRegistry.java:68
↓ 2 callersMethodgetLongValue
(Object object)
wrangler-core/src/main/java/io/cdap/directives/parser/ParseTimestamp.java:134
↓ 2 callersMethodgetName
@return Name of the workspace.
wrangler-proto/src/main/java/io/cdap/wrangler/proto/Workspace.java:39
↓ 2 callersMethodgetName
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/WorkspaceIdentifier.java:36
↓ 2 callersMethodgetName
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/schema/SchemaEntry.java:51
↓ 2 callersMethodgetName
<code>string name = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:881
↓ 2 callersMethodgetNameBytes
<code>string name = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:896
↓ 2 callersMethodgetNamespaceKeys
(NamespaceSummary namespace)
wrangler-storage/src/main/java/io/cdap/wrangler/store/workspace/WorkspaceStore.java:240
↓ 2 callersMethodgetNextSampledElement
()
wrangler-core/src/main/java/io/cdap/wrangler/sampling/Bernoulli.java:108
↓ 2 callersMethodgetNumber
<code>string number = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:384
↓ 2 callersMethodgetNumberBytes
<code>string number = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:399
↓ 2 callersMethodgetOutputSchema
This method is used to get the updated schema of the data after the directive's transformation has been applied. @param schemaResolutionContext conte
wrangler-api/src/main/java/io/cdap/wrangler/api/Executor.java:95
↓ 2 callersMethodgetPageSize
()
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/utils/PageRequest.java:68
↓ 2 callersMethodgetPeopleList
<code>repeated .tutorial.Person people = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1934
↓ 2 callersMethodgetPhonesList
<code>repeated .tutorial.Person.PhoneNumber phones = 4;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:962
↓ 2 callersMethodgetRecipeParser
This method creates a {@link CompositeDirectiveRegistry} and initializes the {@link RecipeParser} with {@link NoOpDirectiveContext} @param context @r
wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java:594
↓ 2 callersMethodgetResults
@return Number of results to return in the API.
wrangler-proto/src/main/java/io/cdap/wrangler/proto/Workspace.java:46
↓ 2 callersMethodgetRowValue
(StandardSQLTypeName standardType, FieldValue fieldValue)
wrangler-service/src/main/java/io/cdap/wrangler/service/bigquery/BigQueryHandler.java:432
↓ 2 callersMethodgetRows
(int lines, ResultSet result)
wrangler-service/src/main/java/io/cdap/wrangler/service/database/DatabaseHandler.java:454
↓ 2 callersMethodgetSampleAsBytes
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/WorkspaceDetail.java:62
↓ 2 callersMethodgetSampleRequest
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/WorkspaceCreationRequest.java:44
↓ 2 callersMethodgetSedReplacedColumnName
(String colName)
wrangler-core/src/main/java/io/cdap/directives/column/ColumnsReplace.java:109
↓ 2 callersMethodgetSortOrder
()
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/utils/PageRequest.java:81
↓ 2 callersMethodgetSources
@return a {@link List} of source columns.
wrangler-api/src/main/java/io/cdap/wrangler/api/lineage/Relation.java:142
↓ 2 callersMethodgetSpecification
@return schema definition being requested.
wrangler-core/src/main/java/io/cdap/wrangler/clients/SchemaInfo.java:94
↓ 2 callersMethodgetSpecification
(String namespace, String connectionName, SpecGenerationRequest requ
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/ConnectionDiscoverer.java:89
↓ 2 callersMethodgetSupportedSampleTypes
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/SampleSpec.java:81
↓ 2 callersMethodgetTables
(Connection connection, String instanceId, String databaseId)
wrangler-service/src/main/java/io/cdap/wrangler/service/spanner/SpannerHandler.java:408
↓ 2 callersMethodgetType
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/schema/SchemaEntry.java:59
↓ 2 callersMethodgetUpdatedTimeMillis
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/Workspace.java:69
← previousnext →501–600 of 3,047, ranked by callers