Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/data-integrations/wrangler
/ functions
Functions
1,973 in github.com/data-integrations/wrangler
⨍
Functions
1,973
◇
Types & classes
423
↓ 1 callers
Method
description
()
wrangler-api/src/main/java/co/cask/wrangler/api/DirectiveInfo.java:96
↓ 1 callers
Method
deserialize
(String type)
wrangler-service/src/main/java/co/cask/wrangler/service/kafka/KafkaConfiguration.java:101
↓ 1 callers
Method
destroy
Invokes each directives destroy method to perform any cleanup required by each individual directive.
wrangler-core/src/main/java/co/cask/wrangler/executor/RecipePipelineExecutor.java:75
↓ 1 callers
Method
drop
Drops a path from the schema to generate a new {@link Schema}. @param schema to be modified. @param path to be removed from {@link Schema}. @return m
wrangler-core/src/main/java/co/cask/functions/DDL.java:115
↓ 1 callers
Method
encodeAsJsonGenericRecord
()
wrangler-core/src/test/java/co/cask/directives/parser/ParseAvroTest.java:140
↓ 1 callers
Method
ensureInitialized
(ExecutorContext context)
wrangler-core/src/main/java/co/cask/directives/lookup/TableLookup.java:76
↓ 1 callers
Method
ensureJDBCDriverIsAvailable
(Class<? extends Driver> classz, String url)
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:706
↓ 1 callers
Method
error
(Object o)
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:160
↓ 1 callers
Method
errors
Returns records that are errored out. @return records that have errored out.
wrangler-core/src/main/java/co/cask/wrangler/executor/RecipePipelineExecutor.java:151
↓ 1 callers
Method
extractDomainAndAccount
(String emailId)
wrangler-core/src/main/java/co/cask/directives/transformation/SplitEmail.java:108
↓ 1 callers
Method
findUnionSchema
(Schema unionSchema, @Nullable Object value)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordJsonConverter.java:425
↓ 1 callers
Method
fromJsonBytes
(byte[] bytes)
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:423
↓ 1 callers
Method
fromWorkspace
Converts the data in workspace into records. @param id name of the workspace from which the records are generated. @return list of records. @throws W
wrangler-service/src/main/java/co/cask/wrangler/service/directive/DirectivesService.java:1170
↓ 1 callers
Method
functions
()
wrangler-core/src/main/java/co/cask/wrangler/expression/ELRegistration.java:25
↓ 1 callers
Method
get
Generates all json paths for the json being passed as a string. @param json string for which json paths need to be extracted. @return list of json pa
wrangler-core/src/main/java/co/cask/wrangler/utils/JsonPathGenerator.java:48
↓ 1 callers
Method
get
A value associated with the variable in the transient store. @param name of the variable to be retrieved. @return instance of object of type T.
wrangler-core/src/main/java/co/cask/directives/aggregates/DefaultTransientStore.java:79
↓ 1 callers
Method
get
()
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Service.java:552
↓ 1 callers
Method
getAWSAccessKeyId
()
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Configuration.java:52
↓ 1 callers
Method
getAWSSecretKey
()
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Configuration.java:57
↓ 1 callers
Method
getAll
@return A map of directive to {@link UsageEntry}.
wrangler-core/src/main/java/co/cask/wrangler/parser/UsageRegistry.java:131
↓ 1 callers
Method
getBucketWhitelist
(Connection connection)
wrangler-service/src/main/java/co/cask/wrangler/service/gcs/GCSService.java:509
↓ 1 callers
Method
getBuckets
(Storage storage, Set<String> whitelist, int objectLimit)
wrangler-service/src/main/java/co/cask/wrangler/service/gcs/GCSService.java:521
↓ 1 callers
Method
getBuckets
()
wrangler-service/src/main/java/co/cask/wrangler/service/gcs/Buckets.java:36
↓ 1 callers
Method
getCatalog
@return name of the catalog.
wrangler-core/src/main/java/co/cask/directives/lookup/StaticCatalog.java:46
↓ 1 callers
Method
getColumnNumber
()
wrangler-api/src/main/java/co/cask/wrangler/api/SourceInfo.java:40
↓ 1 callers
Method
getCompiledUnit
Returns a <code>RecipeSymbol</code> for the recipe being parsed. This object has all the tokens that were successfully parsed along with source inform
wrangler-core/src/main/java/co/cask/wrangler/parser/RecipeVisitor.java:76
↓ 1 callers
Method
getConfig
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:333
↓ 1 callers
Method
getConfig
Updates the configuration. @param request to gather information of the request. @param responder to respond to the service request.
wrangler-service/src/main/java/co/cask/wrangler/service/directive/DirectivesService.java:1130
↓ 1 callers
Method
getContextName
@return Context name.
wrangler-api/src/main/java/co/cask/wrangler/api/ExecutorContext.java:55
↓ 1 callers
Method
getCurrent
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaEntry.java:68
↓ 1 callers
Method
getDPServiceURL
Retrieves the base url from the context and appends method to value to the final url. @param method to be invoked. @return fully formed url to the me
wrangler-transform/src/main/java/co/cask/wrangler/Wrangler.java:516
↓ 1 callers
Method
getDataType
(String value)
wrangler-core/src/main/java/co/cask/wrangler/dq/TypeInference.java:182
↓ 1 callers
Method
getDataType
get data type from the file type. @param fileName @return DataType @throws IOException
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Service.java:563
↓ 1 callers
Method
getDatabases
(Connection connection, String instanceId)
wrangler-service/src/main/java/co/cask/wrangler/service/spanner/SpannerService.java:402
↓ 1 callers
Method
getDatasets
(BigQuery bigQuery, Set<DatasetId> datasetWhitelist)
wrangler-service/src/main/java/co/cask/wrangler/service/bigquery/BigQueryService.java:548
↓ 1 callers
Method
getDefaultConnection
(List<Connection> connections, ConnectionTypeConfig connectionTypeConfig)
wrangler-service/src/main/java/co/cask/wrangler/service/connections/ConnectionService.java:247
↓ 1 callers
Method
getDescription
(String id)
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:242
↓ 1 callers
Method
getDescription
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaEntry.java:52
↓ 1 callers
Method
getDescription
@return Description associated with the directive.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:153
↓ 1 callers
Method
getDescriptor
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:161
↓ 1 callers
Method
getDescriptor
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:367
↓ 1 callers
Method
getDescriptor
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1917
↓ 1 callers
Method
getDirectives
@return List of directives specified by the user.
wrangler-service/src/main/java/co/cask/wrangler/proto/Recipe.java:43
↓ 1 callers
Method
getEnvironment
@return Environment this context is prepared for.
wrangler-api/src/main/java/co/cask/wrangler/api/ExecutorContext.java:45
↓ 1 callers
Method
getFromBase
@return Multiplier to be applied when converting from base.
wrangler-core/src/main/java/co/cask/wrangler/dq/ConvertDistances.java:88
↓ 1 callers
Method
getId
@return id of the connection.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:52
↓ 1 callers
Method
getId
@return recipe id.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:71
↓ 1 callers
Method
getIdFromName
(String name)
wrangler-core/src/test/java/co/cask/wrangler/ExperimentTests.java:31
↓ 1 callers
Method
getIdFromName
(String name)
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeService.java:152
↓ 1 callers
Method
getInteger
()
wrangler-core/src/main/java/co/cask/wrangler/expression/ELResult.java:43
↓ 1 callers
Method
getJdbcUrlPattern
()
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:173
↓ 1 callers
Method
getKeyDeserializer
@return String representation of key deserializer of kafka topic.
wrangler-service/src/main/java/co/cask/wrangler/service/kafka/KafkaConfiguration.java:90
↓ 1 callers
Method
getLine
@return Original line that has the syntax error.
wrangler-api/src/main/java/co/cask/wrangler/api/parser/SyntaxError.java:66
↓ 1 callers
Method
getLineNumber
()
wrangler-api/src/main/java/co/cask/wrangler/api/SourceInfo.java:36
↓ 1 callers
Method
getMacros
Extracts all the macros within a string expression. @param expression specifies the expression. @return list of macros present within an expression.
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:660
↓ 1 callers
Method
getName
@return name of the connection.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:59
↓ 1 callers
Method
getName
Given an id, returns the name of the schema. @param id of the schema for which name needs to be returned. @return string value for the id.
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:231
↓ 1 callers
Method
getName
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaEntry.java:48
↓ 1 callers
Method
getName
@return Display name of the directive.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:137
↓ 1 callers
Method
getNextToken
(StringTokenizer tokenizer, String directive, String field, int lineno)
wrangler-core/src/main/java/co/cask/wrangler/parser/MigrateToV2.java:800
↓ 1 callers
Method
getNextVersion
(String id)
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:328
↓ 1 callers
Method
getOptionalTokensCount
Returns the count of <code>TokenDefinition</code> that have been specified as optional in the <code>UsageDefinition</code>. @return number of tokens
wrangler-api/src/main/java/co/cask/wrangler/api/parser/UsageDefinition.java:85
↓ 1 callers
Method
getOriginalSource
(ParserRuleContext ctx)
wrangler-core/src/main/java/co/cask/wrangler/parser/RecipeVisitor.java:319
↓ 1 callers
Method
getPeopleCount
<code>repeated .tutorial.Person people = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1947
↓ 1 callers
Method
getPeopleList
<code>repeated .tutorial.Person people = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1829
↓ 1 callers
Method
getPhonesCount
<code>repeated .tutorial.Person.PhoneNumber phones = 4;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:975
↓ 1 callers
Method
getPhonesList
<code>repeated .tutorial.Person.PhoneNumber phones = 4;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:53
↓ 1 callers
Method
getPort
()
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:109
↓ 1 callers
Method
getRecipe
@return {@link Recipe} information associated with this request.
wrangler-service/src/main/java/co/cask/wrangler/proto/RequestV1.java:76
↓ 1 callers
Method
getRegion
()
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Configuration.java:62
↓ 1 callers
Method
getReverseAlias
()
wrangler-api/src/main/java/co/cask/wrangler/api/DirectiveConfig.java:79
↓ 1 callers
Method
getSave
@return true if directives need to be saved, else false.
wrangler-service/src/main/java/co/cask/wrangler/proto/Recipe.java:64
↓ 1 callers
Method
getSchemaType
(@Nullable Object value)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordJsonConverter.java:437
↓ 1 callers
Method
getSource
()
wrangler-api/src/main/java/co/cask/wrangler/api/SourceInfo.java:44
↓ 1 callers
Method
getSourceInfo
()
wrangler-api/src/main/java/co/cask/wrangler/api/TokenGroup.java:58
↓ 1 callers
Method
getSpecification
@return schema definition being requested.
wrangler-core/src/main/java/co/cask/wrangler/clients/SchemaInfo.java:94
↓ 1 callers
Method
getStorage
(String projectId, String path)
wrangler-service/src/test/java/co/cask/wrangler/service/gcs/GCSServiceTest.java:99
↓ 1 callers
Method
getTableData
Execute Spanner select query on table with row limit and convert the {@link ResultSet} to {@link Row} and return the list of rows
wrangler-service/src/main/java/co/cask/wrangler/service/spanner/SpannerService.java:314
↓ 1 callers
Method
getTableSchema
(Connection connection, String instanceId, String databaseId, String tableId)
wrangler-service/src/main/java/co/cask/wrangler/service/spanner/SpannerService.java:261
↓ 1 callers
Method
getTag
()
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:105
↓ 1 callers
Method
getTag
()
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:181
↓ 1 callers
Method
getThird
@return Third element of the triplet.
wrangler-api/src/main/java/co/cask/wrangler/api/Triplet.java:55
↓ 1 callers
Method
getTimeUnit
(String unitValue)
wrangler-core/src/main/java/co/cask/directives/parser/ParseTimestamp.java:104
↓ 1 callers
Method
getToBase
@return Multiplier to be applied when converting to base.
wrangler-core/src/main/java/co/cask/wrangler/dq/ConvertDistances.java:81
↓ 1 callers
Method
getTokens
This method returns the list of <code>TokenDefinition</code> that should be used for parsing the directive into <code>Arguments</code>. @return List
wrangler-api/src/main/java/co/cask/wrangler/api/parser/UsageDefinition.java:75
↓ 1 callers
Method
getType
(String id)
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:253
↓ 1 callers
Method
getType
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaEntry.java:56
↓ 1 callers
Method
getTypeValue
<code>.tutorial.Person.PhoneType type = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:297
↓ 1 callers
Method
getUsage
Gets the usage of a directive. @param directive for which usage is returned. @return null if not found, else the usage.
wrangler-core/src/main/java/co/cask/wrangler/parser/UsageRegistry.java:108
↓ 1 callers
Method
getValueDeserializer
@return String representation of value deserializer of kafka topic.
wrangler-service/src/main/java/co/cask/wrangler/service/kafka/KafkaConfiguration.java:97
↓ 1 callers
Method
getVersions
Given an id, returns all the versions of schema. @param id of schema for which all version of registered schema versions should be returned. @return
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:200
↓ 1 callers
Method
getWorkspaces
Lists all the workspaces registered in the 'default' scope. @return List of workspaces. @throws WorkspaceException throw if there is issue listing wo
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:176
↓ 1 callers
Method
getZonedDateTime
(long ts, TimeUnit unit, ZoneId zoneId)
wrangler-core/src/main/java/co/cask/directives/parser/ParseTimestamp.java:140
↓ 1 callers
Method
getZonedDateTime
(long microTs)
wrangler-service/src/main/java/co/cask/wrangler/service/bigquery/BigQueryService.java:472
↓ 1 callers
Method
guessLocationType
Inspects the location to detect the type of the file. @param path of the file or path to be investigated. @param lookahead Specifies a look a head pa
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/Explorer.java:165
↓ 1 callers
Method
hasErrors
()
wrangler-core/src/main/java/co/cask/wrangler/parser/SyntaxErrorListener.java:84
↓ 1 callers
Method
hasHeader
Checks if the request has a HTTP header. @param name of the header to be checked. @return true if header is found, false otherwise.
wrangler-service/src/main/java/co/cask/wrangler/RequestExtractor.java:47
↓ 1 callers
Method
hasNext
()
wrangler-core/src/main/java/co/cask/wrangler/sampling/Reservoir.java:100
↓ 1 callers
Method
hasNext
()
wrangler-core/src/main/java/co/cask/wrangler/sampling/Bernoulli.java:86
↓ 1 callers
Method
hasWorkspace
Checks if a workspace exists. @param id of the workspace to be checked for. @return true if workspace exists, false otherwise. @throws WorkspaceExcep
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:155
← previous
next →
401–500 of 1,973, ranked by callers